pub async fn flush(&self) {
        trace!("flush: endpoint={:?}", self.handle);
        unsafe extern "C" fn callback(request: *mut c_void, _status: ucs_status_t) {
            trace!("flush: complete");
            ucp_request_free(request);
        }
        let status = unsafe { ucp_ep_flush_nb(self.handle, 0, Some(callback)) };
        if status.is_null() {
            trace!("flush: complete");
        } else if UCS_PTR_IS_PTR(status) {
            RequestHandle {
                ptr: status,
                poll_fn: poll_normal,
            }
            .await;
        } else {
            panic!("failed to flush endpoint: {:?}", UCS_PTR_RAW_STATUS(status));
        }
    }
/// This routine flushes all outstanding AMO and RMA communications on the endpoint.
This routine flushes all outstanding AMO and RMA communications on the endpoint.
This routine flushes all outstanding AMO and RMA communications on the endpoint .
pub async fn flush(&self) {
        trace!("flush: endpoint={:?}", self.handle);
        unsafe extern "C" fn callback(request: *mut c_void, _status: ucs_status_t) {
            trace!("flush: complete");
            ucp_request_free(request);
        }
        let status = unsafe { ucp_ep_flush_nb(self.handle, 0, Some(callback)) };
        if status.is_null() {
            trace!("flush: complete");
        } else if UCS_PTR_IS_PTR(status) {
            RequestHandle {
                ptr: status,
                poll_fn: poll_normal,
            }
            .await;
        } else {
            panic!("failed to flush endpoint: {:?}", UCS_PTR_RAW_STATUS(status));
        }
    }
pub async fn flush ( & self ) { trace ! ( " " self handle ) ; unsafe extern " " fn callback ( request : * mut c_void , _status : ucs_status_t ) { trace ! ( " " ) ; ucp_request_free ( request ) ; } let status = unsafe { ucp_ep_flush_nb ( self . handle , 0 , Some ( callback ) ) } ; if status . is_null ( ) { trace ! ( " " ) ; } else if UCS_PTR_IS_PTR ( status ) { RequestHandle { ptr : status , poll_fn : poll_normal , } . await ; } else { panic ! ( " " UCS_PTR_RAW_STATUS ( status ) ) ; } }
This routine flushes all outstanding AMO and RMA communications on the endpoint.
This routine flushes all outstanding AMO and RMA communications on the endpoint .
&self
&self