pub async fn close(self) {
        trace!("close: endpoint={:?}", self.handle);
        let status = unsafe {
            ucp_ep_close_nb(
                self.handle,
                ucp_ep_close_mode::UCP_EP_CLOSE_MODE_FLUSH as u32,
            )
        };
        if status.is_null() {
            trace!("close: complete");
        } else if UCS_PTR_IS_PTR(status) {
            while unsafe { poll_normal(status) }.is_pending() {
                futures_lite::future::yield_now().await;
            }
        } else {
            panic!("failed to close endpoint: {:?}", UCS_PTR_RAW_STATUS(status));
        }
        std::mem::forget(self);
    }
/// This routine releases the endpoint.
This routine releases the endpoint.
This routine releases the endpoint .
pub async fn close(self) {
        trace!("close: endpoint={:?}", self.handle);
        let status = unsafe {
            ucp_ep_close_nb(
                self.handle,
                ucp_ep_close_mode::UCP_EP_CLOSE_MODE_FLUSH as u32,
            )
        };
        if status.is_null() {
            trace!("close: complete");
        } else if UCS_PTR_IS_PTR(status) {
            while unsafe { poll_normal(status) }.is_pending() {
                futures_lite::future::yield_now().await;
            }
        } else {
            panic!("failed to close endpoint: {:?}", UCS_PTR_RAW_STATUS(status));
        }
        std::mem::forget(self);
    }
pub async fn close ( self ) { trace ! ( " " self handle ) ; let status = unsafe { ucp_ep_close_nb ( self . handle , ucp_ep_close_mode :: UCP_EP_CLOSE_MODE_FLUSH as u32 , ) } ; if status . is_null ( ) { trace ! ( " " ) ; } else if UCS_PTR_IS_PTR ( status ) { while unsafe { poll_normal ( status ) } . is_pending ( ) { futures_lite :: future :: yield_now ( ) . await ; } } else { panic ! ( " " UCS_PTR_RAW_STATUS ( status ) ) ; } std :: mem :: forget ( self ) ; }
This routine releases the endpoint.
This routine releases the endpoint .
self
self