pub unsafe extern "C" fn ucp_stream_worker_poll(
worker: ucp_worker_h,
poll_eps: *mut ucp_stream_poll_ep_t,
max_eps: size_t,
flags: c_uint,
) -> ssize_tExpand description
@ingroup UCP_WORKER @brief Poll for endpoints that are ready to consume streaming data.
This non-blocking routine returns endpoints on a worker which are ready to consume streaming data. The ready endpoints are placed in @a poll_eps array, and the function return value indicates how many are there.
@param [in] worker Worker to poll. @param [out] poll_eps Pointer to array of endpoints, should be allocated by user. @param [in] max_eps Maximum number of endpoints that should be filled in @a poll_eps. @param [in] flags Reserved for future use.
@return Negative value indicates an error according to @ref ucs_status_t. On success, non-negative value (less or equal @a max_eps) indicates actual number of endpoints filled in @a poll_eps array.