Lines Matching refs:vmci_trans

755 			vmci_trans(vsk)->notify_ops->handle_notify_pkt(  in vmci_transport_recv_stream_cb()
818 if (vmci_handle_is_equal(vmci_trans(vsk)->qp_handle, in vmci_transport_peer_attach_cb()
837 if (!vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle)) { in vmci_transport_handle_detach()
890 if (vmci_handle_is_equal(vmci_trans(vsk)->qp_handle, in vmci_transport_peer_detach_cb()
1041 if (pkt->u.size >= vmci_trans(vpending)->queue_pair_min_size && in vmci_transport_recv_listen()
1042 pkt->u.size <= vmci_trans(vpending)->queue_pair_max_size) { in vmci_transport_recv_listen()
1045 qp_size = vmci_trans(vpending)->queue_pair_size; in vmci_transport_recv_listen()
1112 vmci_trans(vpending)->produce_size = in vmci_transport_recv_listen()
1113 vmci_trans(vpending)->consume_size = qp_size; in vmci_transport_recv_listen()
1114 vmci_trans(vpending)->queue_pair_size = qp_size; in vmci_transport_recv_listen()
1116 vmci_trans(vpending)->notify_ops->process_request(pending); in vmci_transport_recv_listen()
1192 vmci_trans(vpending)->detach_sub_id = detach_sub_id; in vmci_transport_recv_connecting_server()
1208 vmci_trans(vpending)->produce_size, in vmci_transport_recv_connecting_server()
1209 vmci_trans(vpending)->consume_size, in vmci_transport_recv_connecting_server()
1221 vmci_trans(vpending)->qp_handle = handle; in vmci_transport_recv_connecting_server()
1222 vmci_trans(vpending)->qpair = qpair; in vmci_transport_recv_connecting_server()
1298 vmci_trans(vsk)->qp_handle)) { in vmci_transport_recv_connecting_client()
1320 || !vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle) in vmci_transport_recv_connecting_client()
1321 || vmci_trans(vsk)->qpair in vmci_transport_recv_connecting_client()
1322 || vmci_trans(vsk)->produce_size != 0 in vmci_transport_recv_connecting_client()
1323 || vmci_trans(vsk)->consume_size != 0 in vmci_transport_recv_connecting_client()
1324 || vmci_trans(vsk)->attach_sub_id != VMCI_INVALID_ID in vmci_transport_recv_connecting_client()
1325 || vmci_trans(vsk)->detach_sub_id != VMCI_INVALID_ID) { in vmci_transport_recv_connecting_client()
1412 if (pkt->u.size < vmci_trans(vsk)->queue_pair_min_size || in vmci_transport_recv_connecting_client_negotiate()
1413 pkt->u.size > vmci_trans(vsk)->queue_pair_max_size) { in vmci_transport_recv_connecting_client_negotiate()
1493 vmci_trans(vsk)->qp_handle = handle; in vmci_transport_recv_connecting_client_negotiate()
1494 vmci_trans(vsk)->qpair = qpair; in vmci_transport_recv_connecting_client_negotiate()
1496 vmci_trans(vsk)->produce_size = vmci_trans(vsk)->consume_size = in vmci_transport_recv_connecting_client_negotiate()
1499 vmci_trans(vsk)->attach_sub_id = attach_sub_id; in vmci_transport_recv_connecting_client_negotiate()
1500 vmci_trans(vsk)->detach_sub_id = detach_sub_id; in vmci_transport_recv_connecting_client_negotiate()
1502 vmci_trans(vsk)->notify_ops->process_negotiate(sk); in vmci_transport_recv_connecting_client_negotiate()
1531 sk, vmci_trans(vsk)->queue_pair_size); in vmci_transport_recv_connecting_client_invalid()
1587 vmci_trans(vsk)->notify_ops->handle_notify_pkt( in vmci_transport_recv_connected()
1606 vmci_trans(vsk)->dg_handle = VMCI_INVALID_HANDLE; in vmci_transport_socket_init()
1607 vmci_trans(vsk)->qp_handle = VMCI_INVALID_HANDLE; in vmci_transport_socket_init()
1608 vmci_trans(vsk)->qpair = NULL; in vmci_transport_socket_init()
1609 vmci_trans(vsk)->produce_size = vmci_trans(vsk)->consume_size = 0; in vmci_transport_socket_init()
1610 vmci_trans(vsk)->attach_sub_id = vmci_trans(vsk)->detach_sub_id = in vmci_transport_socket_init()
1612 vmci_trans(vsk)->notify_ops = NULL; in vmci_transport_socket_init()
1614 vmci_trans(vsk)->queue_pair_size = in vmci_transport_socket_init()
1615 vmci_trans(psk)->queue_pair_size; in vmci_transport_socket_init()
1616 vmci_trans(vsk)->queue_pair_min_size = in vmci_transport_socket_init()
1617 vmci_trans(psk)->queue_pair_min_size; in vmci_transport_socket_init()
1618 vmci_trans(vsk)->queue_pair_max_size = in vmci_transport_socket_init()
1619 vmci_trans(psk)->queue_pair_max_size; in vmci_transport_socket_init()
1621 vmci_trans(vsk)->queue_pair_size = in vmci_transport_socket_init()
1623 vmci_trans(vsk)->queue_pair_min_size = in vmci_transport_socket_init()
1625 vmci_trans(vsk)->queue_pair_max_size = in vmci_transport_socket_init()
1634 if (vmci_trans(vsk)->attach_sub_id != VMCI_INVALID_ID) { in vmci_transport_destruct()
1635 vmci_event_unsubscribe(vmci_trans(vsk)->attach_sub_id); in vmci_transport_destruct()
1636 vmci_trans(vsk)->attach_sub_id = VMCI_INVALID_ID; in vmci_transport_destruct()
1639 if (vmci_trans(vsk)->detach_sub_id != VMCI_INVALID_ID) { in vmci_transport_destruct()
1640 vmci_event_unsubscribe(vmci_trans(vsk)->detach_sub_id); in vmci_transport_destruct()
1641 vmci_trans(vsk)->detach_sub_id = VMCI_INVALID_ID; in vmci_transport_destruct()
1644 if (!vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle)) { in vmci_transport_destruct()
1645 vmci_qpair_detach(&vmci_trans(vsk)->qpair); in vmci_transport_destruct()
1646 vmci_trans(vsk)->qp_handle = VMCI_INVALID_HANDLE; in vmci_transport_destruct()
1647 vmci_trans(vsk)->produce_size = 0; in vmci_transport_destruct()
1648 vmci_trans(vsk)->consume_size = 0; in vmci_transport_destruct()
1651 if (vmci_trans(vsk)->notify_ops) in vmci_transport_destruct()
1652 vmci_trans(vsk)->notify_ops->socket_destruct(vsk); in vmci_transport_destruct()
1660 if (!vmci_handle_is_invalid(vmci_trans(vsk)->dg_handle)) { in vmci_transport_release()
1661 vmci_datagram_destroy_handle(vmci_trans(vsk)->dg_handle); in vmci_transport_release()
1662 vmci_trans(vsk)->dg_handle = VMCI_INVALID_HANDLE; in vmci_transport_release()
1688 &vmci_trans(vsk)->dg_handle); in vmci_transport_dgram_bind()
1692 vmci_trans(vsk)->dg_handle.resource); in vmci_transport_dgram_bind()
1813 sk, vmci_trans(vsk)->queue_pair_size); in vmci_transport_connect()
1822 sk, vmci_trans(vsk)->queue_pair_size, in vmci_transport_connect()
1842 return vmci_qpair_peekv(vmci_trans(vsk)->qpair, msg, len, 0); in vmci_transport_stream_dequeue()
1844 return vmci_qpair_dequev(vmci_trans(vsk)->qpair, msg, len, 0); in vmci_transport_stream_dequeue()
1852 return vmci_qpair_enquev(vmci_trans(vsk)->qpair, msg, len, 0); in vmci_transport_stream_enqueue()
1857 return vmci_qpair_consume_buf_ready(vmci_trans(vsk)->qpair); in vmci_transport_stream_has_data()
1862 return vmci_qpair_produce_free_space(vmci_trans(vsk)->qpair); in vmci_transport_stream_has_space()
1867 return vmci_trans(vsk)->consume_size; in vmci_transport_stream_rcvhiwat()
1872 return !vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle); in vmci_transport_stream_is_active()
1877 return vmci_trans(vsk)->queue_pair_size; in vmci_transport_get_buffer_size()
1882 return vmci_trans(vsk)->queue_pair_min_size; in vmci_transport_get_min_buffer_size()
1887 return vmci_trans(vsk)->queue_pair_max_size; in vmci_transport_get_max_buffer_size()
1892 if (val < vmci_trans(vsk)->queue_pair_min_size) in vmci_transport_set_buffer_size()
1893 vmci_trans(vsk)->queue_pair_min_size = val; in vmci_transport_set_buffer_size()
1894 if (val > vmci_trans(vsk)->queue_pair_max_size) in vmci_transport_set_buffer_size()
1895 vmci_trans(vsk)->queue_pair_max_size = val; in vmci_transport_set_buffer_size()
1896 vmci_trans(vsk)->queue_pair_size = val; in vmci_transport_set_buffer_size()
1902 if (val > vmci_trans(vsk)->queue_pair_size) in vmci_transport_set_min_buffer_size()
1903 vmci_trans(vsk)->queue_pair_size = val; in vmci_transport_set_min_buffer_size()
1904 vmci_trans(vsk)->queue_pair_min_size = val; in vmci_transport_set_min_buffer_size()
1910 if (val < vmci_trans(vsk)->queue_pair_size) in vmci_transport_set_max_buffer_size()
1911 vmci_trans(vsk)->queue_pair_size = val; in vmci_transport_set_max_buffer_size()
1912 vmci_trans(vsk)->queue_pair_max_size = val; in vmci_transport_set_max_buffer_size()
1920 return vmci_trans(vsk)->notify_ops->poll_in( in vmci_transport_notify_poll_in()
1929 return vmci_trans(vsk)->notify_ops->poll_out( in vmci_transport_notify_poll_out()
1938 return vmci_trans(vsk)->notify_ops->recv_init( in vmci_transport_notify_recv_init()
1948 return vmci_trans(vsk)->notify_ops->recv_pre_block( in vmci_transport_notify_recv_pre_block()
1958 return vmci_trans(vsk)->notify_ops->recv_pre_dequeue( in vmci_transport_notify_recv_pre_dequeue()
1970 return vmci_trans(vsk)->notify_ops->recv_post_dequeue( in vmci_transport_notify_recv_post_dequeue()
1979 return vmci_trans(vsk)->notify_ops->send_init( in vmci_transport_notify_send_init()
1988 return vmci_trans(vsk)->notify_ops->send_pre_block( in vmci_transport_notify_send_pre_block()
1997 return vmci_trans(vsk)->notify_ops->send_pre_enqueue( in vmci_transport_notify_send_pre_enqueue()
2007 return vmci_trans(vsk)->notify_ops->send_post_enqueue( in vmci_transport_notify_send_post_enqueue()
2038 vmci_trans(vsk)->notify_ops = &vmci_transport_notify_pkt_ops; in vmci_transport_proto_to_notify_struct()
2044 vmci_trans(vsk)->notify_ops = in vmci_transport_proto_to_notify_struct()
2053 vmci_trans(vsk)->notify_ops->socket_init(sk); in vmci_transport_proto_to_notify_struct()