How to get pending tasks number in UCP worker queue?

[MoFHeka]

I'm not sure if I understand this correctly. It can't submit too many nbx to the UCP worker, or it will cause ucp_worker_progress to process too slowly. So is there an API that knows how many tasks ucp_worker_progress will be handle in currently running?

What does ucx_worker->flush_ops_count actually means? Could I just use it directly?

[yosefe]

".. it will cause ucp_worker_progress to process too slowly." - it is not expected, do you see in which function most of the time is spend in such case? there is no API to count how many requests are pending, but the application can count how many requests started and not completed yet. flush_ops_count is counting specific operations (rma emulation over active messages, and wireup message)