Lines Matching refs:cm_event

924     struct rdma_cm_event *cm_event;  in qemu_rdma_resolve_host()  local
992 ret = rdma_get_cm_event(rdma->channel, &cm_event); in qemu_rdma_resolve_host()
998 if (cm_event->event != RDMA_CM_EVENT_ADDR_RESOLVED) { in qemu_rdma_resolve_host()
1001 rdma_event_str(cm_event->event)); in qemu_rdma_resolve_host()
1002 rdma_ack_cm_event(cm_event); in qemu_rdma_resolve_host()
1005 rdma_ack_cm_event(cm_event); in qemu_rdma_resolve_host()
1014 ret = rdma_get_cm_event(rdma->channel, &cm_event); in qemu_rdma_resolve_host()
1019 if (cm_event->event != RDMA_CM_EVENT_ROUTE_RESOLVED) { in qemu_rdma_resolve_host()
1022 rdma_event_str(cm_event->event)); in qemu_rdma_resolve_host()
1023 rdma_ack_cm_event(cm_event); in qemu_rdma_resolve_host()
1026 rdma_ack_cm_event(cm_event); in qemu_rdma_resolve_host()
1511 struct rdma_cm_event *cm_event; in qemu_rdma_wait_comp_channel() local
1547 if (rdma_get_cm_event(rdma->channel, &cm_event) < 0) { in qemu_rdma_wait_comp_channel()
1551 if (cm_event->event == RDMA_CM_EVENT_DISCONNECTED || in qemu_rdma_wait_comp_channel()
1552 cm_event->event == RDMA_CM_EVENT_DEVICE_REMOVAL) { in qemu_rdma_wait_comp_channel()
1553 rdma_ack_cm_event(cm_event); in qemu_rdma_wait_comp_channel()
1556 rdma_ack_cm_event(cm_event); in qemu_rdma_wait_comp_channel()
2494 struct rdma_cm_event **cm_event, in qemu_get_cm_event_timeout() argument
2516 if (rdma_get_cm_event(rdma->channel, cm_event) < 0) { in qemu_get_cm_event_timeout()
2540 struct rdma_cm_event *cm_event; in qemu_rdma_connect() local
2567 ret = qemu_get_cm_event_timeout(rdma, &cm_event, 5000, errp); in qemu_rdma_connect()
2569 ret = rdma_get_cm_event(rdma->channel, &cm_event); in qemu_rdma_connect()
2579 if (cm_event->event != RDMA_CM_EVENT_ESTABLISHED) { in qemu_rdma_connect()
2581 rdma_ack_cm_event(cm_event); in qemu_rdma_connect()
2586 memcpy(&cap, cm_event->param.conn.private_data, sizeof(cap)); in qemu_rdma_connect()
2601 rdma_ack_cm_event(cm_event); in qemu_rdma_connect()
3307 struct rdma_cm_event *cm_event; in rdma_cm_poll_handler() local
3310 if (rdma_get_cm_event(rdma->channel, &cm_event) < 0) { in rdma_cm_poll_handler()
3315 if (cm_event->event == RDMA_CM_EVENT_DISCONNECTED || in rdma_cm_poll_handler()
3316 cm_event->event == RDMA_CM_EVENT_DEVICE_REMOVAL) { in rdma_cm_poll_handler()
3320 error_report("receive cm event, cm event is %d", cm_event->event); in rdma_cm_poll_handler()
3326 rdma_ack_cm_event(cm_event); in rdma_cm_poll_handler()
3332 rdma_ack_cm_event(cm_event); in rdma_cm_poll_handler()
3346 struct rdma_cm_event *cm_event; in qemu_rdma_accept() local
3350 ret = rdma_get_cm_event(rdma->channel, &cm_event); in qemu_rdma_accept()
3355 if (cm_event->event != RDMA_CM_EVENT_CONNECT_REQUEST) { in qemu_rdma_accept()
3356 rdma_ack_cm_event(cm_event); in qemu_rdma_accept()
3371 rdma_ack_cm_event(cm_event); in qemu_rdma_accept()
3378 memcpy(&cap, cm_event->param.conn.private_data, sizeof(cap)); in qemu_rdma_accept()
3385 rdma_ack_cm_event(cm_event); in qemu_rdma_accept()
3402 rdma->cm_id = cm_event->id; in qemu_rdma_accept()
3403 verbs = cm_event->id->verbs; in qemu_rdma_accept()
3405 rdma_ack_cm_event(cm_event); in qemu_rdma_accept()
3462 ret = rdma_get_cm_event(rdma->channel, &cm_event); in qemu_rdma_accept()
3468 if (cm_event->event != RDMA_CM_EVENT_ESTABLISHED) { in qemu_rdma_accept()
3470 rdma_ack_cm_event(cm_event); in qemu_rdma_accept()
3474 rdma_ack_cm_event(cm_event); in qemu_rdma_accept()