ucs_status_t wait_for_request()

in dissociated-ipc/ucx_conn.cc [27:40]


ucs_status_t wait_for_request(ucs_status_ptr_t request, UcpWorker& worker) {
  ucs_status_t status = UCS_OK;
  if (UCS_PTR_IS_ERR(request)) {
    status = UCS_PTR_STATUS(request);
  } else if (UCS_PTR_IS_PTR(request)) {
    while ((status = ucp_request_check_status(request)) == UCS_INPROGRESS) {
      ucp_worker_progress(worker.get());
    }
    ucp_request_free(request);
  } else {
    DCHECK(!request);
  }
  return status;
}