Lines Matching refs:vmci_trans
771 vmci_trans(vsk)->notify_ops->handle_notify_pkt( in vmci_transport_recv_stream_cb()
815 if (!vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle)) { in vmci_transport_handle_detach()
1033 if (pkt->u.size >= vmci_trans(vpending)->queue_pair_min_size && in vmci_transport_recv_listen()
1034 pkt->u.size <= vmci_trans(vpending)->queue_pair_max_size) { in vmci_transport_recv_listen()
1037 qp_size = vmci_trans(vpending)->queue_pair_size; in vmci_transport_recv_listen()
1104 vmci_trans(vpending)->produce_size = in vmci_transport_recv_listen()
1105 vmci_trans(vpending)->consume_size = qp_size; in vmci_transport_recv_listen()
1106 vmci_trans(vpending)->queue_pair_size = qp_size; in vmci_transport_recv_listen()
1108 vmci_trans(vpending)->notify_ops->process_request(pending); in vmci_transport_recv_listen()
1175 vmci_trans(vpending), &detach_sub_id); in vmci_transport_recv_connecting_server()
1183 vmci_trans(vpending)->detach_sub_id = detach_sub_id; in vmci_transport_recv_connecting_server()
1199 vmci_trans(vpending)->produce_size, in vmci_transport_recv_connecting_server()
1200 vmci_trans(vpending)->consume_size, in vmci_transport_recv_connecting_server()
1212 vmci_trans(vpending)->qp_handle = handle; in vmci_transport_recv_connecting_server()
1213 vmci_trans(vpending)->qpair = qpair; in vmci_transport_recv_connecting_server()
1289 vmci_trans(vsk)->qp_handle)) { in vmci_transport_recv_connecting_client()
1311 || !vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle) in vmci_transport_recv_connecting_client()
1312 || vmci_trans(vsk)->qpair in vmci_transport_recv_connecting_client()
1313 || vmci_trans(vsk)->produce_size != 0 in vmci_transport_recv_connecting_client()
1314 || vmci_trans(vsk)->consume_size != 0 in vmci_transport_recv_connecting_client()
1315 || vmci_trans(vsk)->detach_sub_id != VMCI_INVALID_ID) { in vmci_transport_recv_connecting_client()
1400 if (pkt->u.size < vmci_trans(vsk)->queue_pair_min_size || in vmci_transport_recv_connecting_client_negotiate()
1401 pkt->u.size > vmci_trans(vsk)->queue_pair_max_size) { in vmci_transport_recv_connecting_client_negotiate()
1443 vmci_trans(vsk), &detach_sub_id); in vmci_transport_recv_connecting_client_negotiate()
1473 vmci_trans(vsk)->qp_handle = handle; in vmci_transport_recv_connecting_client_negotiate()
1474 vmci_trans(vsk)->qpair = qpair; in vmci_transport_recv_connecting_client_negotiate()
1476 vmci_trans(vsk)->produce_size = vmci_trans(vsk)->consume_size = in vmci_transport_recv_connecting_client_negotiate()
1479 vmci_trans(vsk)->detach_sub_id = detach_sub_id; in vmci_transport_recv_connecting_client_negotiate()
1481 vmci_trans(vsk)->notify_ops->process_negotiate(sk); in vmci_transport_recv_connecting_client_negotiate()
1507 sk, vmci_trans(vsk)->queue_pair_size); in vmci_transport_recv_connecting_client_invalid()
1563 vmci_trans(vsk)->notify_ops->handle_notify_pkt( in vmci_transport_recv_connected()
1582 vmci_trans(vsk)->dg_handle = VMCI_INVALID_HANDLE; in vmci_transport_socket_init()
1583 vmci_trans(vsk)->qp_handle = VMCI_INVALID_HANDLE; in vmci_transport_socket_init()
1584 vmci_trans(vsk)->qpair = NULL; in vmci_transport_socket_init()
1585 vmci_trans(vsk)->produce_size = vmci_trans(vsk)->consume_size = 0; in vmci_transport_socket_init()
1586 vmci_trans(vsk)->detach_sub_id = VMCI_INVALID_ID; in vmci_transport_socket_init()
1587 vmci_trans(vsk)->notify_ops = NULL; in vmci_transport_socket_init()
1588 INIT_LIST_HEAD(&vmci_trans(vsk)->elem); in vmci_transport_socket_init()
1589 vmci_trans(vsk)->sk = &vsk->sk; in vmci_transport_socket_init()
1590 spin_lock_init(&vmci_trans(vsk)->lock); in vmci_transport_socket_init()
1592 vmci_trans(vsk)->queue_pair_size = in vmci_transport_socket_init()
1593 vmci_trans(psk)->queue_pair_size; in vmci_transport_socket_init()
1594 vmci_trans(vsk)->queue_pair_min_size = in vmci_transport_socket_init()
1595 vmci_trans(psk)->queue_pair_min_size; in vmci_transport_socket_init()
1596 vmci_trans(vsk)->queue_pair_max_size = in vmci_transport_socket_init()
1597 vmci_trans(psk)->queue_pair_max_size; in vmci_transport_socket_init()
1599 vmci_trans(vsk)->queue_pair_size = in vmci_transport_socket_init()
1601 vmci_trans(vsk)->queue_pair_min_size = in vmci_transport_socket_init()
1603 vmci_trans(vsk)->queue_pair_max_size = in vmci_transport_socket_init()
1647 if (!vmci_trans(vsk)) in vmci_transport_destruct()
1653 spin_lock_bh(&vmci_trans(vsk)->lock); in vmci_transport_destruct()
1654 vmci_trans(vsk)->sk = NULL; in vmci_transport_destruct()
1655 spin_unlock_bh(&vmci_trans(vsk)->lock); in vmci_transport_destruct()
1657 if (vmci_trans(vsk)->notify_ops) in vmci_transport_destruct()
1658 vmci_trans(vsk)->notify_ops->socket_destruct(vsk); in vmci_transport_destruct()
1661 list_add(&vmci_trans(vsk)->elem, &vmci_transport_cleanup_list); in vmci_transport_destruct()
1672 if (!vmci_handle_is_invalid(vmci_trans(vsk)->dg_handle)) { in vmci_transport_release()
1673 vmci_datagram_destroy_handle(vmci_trans(vsk)->dg_handle); in vmci_transport_release()
1674 vmci_trans(vsk)->dg_handle = VMCI_INVALID_HANDLE; in vmci_transport_release()
1700 &vmci_trans(vsk)->dg_handle); in vmci_transport_dgram_bind()
1704 vmci_trans(vsk)->dg_handle.resource); in vmci_transport_dgram_bind()
1822 sk, vmci_trans(vsk)->queue_pair_size); in vmci_transport_connect()
1831 sk, vmci_trans(vsk)->queue_pair_size, in vmci_transport_connect()
1851 return vmci_qpair_peekv(vmci_trans(vsk)->qpair, msg, len, 0); in vmci_transport_stream_dequeue()
1853 return vmci_qpair_dequev(vmci_trans(vsk)->qpair, msg, len, 0); in vmci_transport_stream_dequeue()
1861 return vmci_qpair_enquev(vmci_trans(vsk)->qpair, msg, len, 0); in vmci_transport_stream_enqueue()
1866 return vmci_qpair_consume_buf_ready(vmci_trans(vsk)->qpair); in vmci_transport_stream_has_data()
1871 return vmci_qpair_produce_free_space(vmci_trans(vsk)->qpair); in vmci_transport_stream_has_space()
1876 return vmci_trans(vsk)->consume_size; in vmci_transport_stream_rcvhiwat()
1881 return !vmci_handle_is_invalid(vmci_trans(vsk)->qp_handle); in vmci_transport_stream_is_active()
1886 return vmci_trans(vsk)->queue_pair_size; in vmci_transport_get_buffer_size()
1891 return vmci_trans(vsk)->queue_pair_min_size; in vmci_transport_get_min_buffer_size()
1896 return vmci_trans(vsk)->queue_pair_max_size; in vmci_transport_get_max_buffer_size()
1901 if (val < vmci_trans(vsk)->queue_pair_min_size) in vmci_transport_set_buffer_size()
1902 vmci_trans(vsk)->queue_pair_min_size = val; in vmci_transport_set_buffer_size()
1903 if (val > vmci_trans(vsk)->queue_pair_max_size) in vmci_transport_set_buffer_size()
1904 vmci_trans(vsk)->queue_pair_max_size = val; in vmci_transport_set_buffer_size()
1905 vmci_trans(vsk)->queue_pair_size = val; in vmci_transport_set_buffer_size()
1911 if (val > vmci_trans(vsk)->queue_pair_size) in vmci_transport_set_min_buffer_size()
1912 vmci_trans(vsk)->queue_pair_size = val; in vmci_transport_set_min_buffer_size()
1913 vmci_trans(vsk)->queue_pair_min_size = val; in vmci_transport_set_min_buffer_size()
1919 if (val < vmci_trans(vsk)->queue_pair_size) in vmci_transport_set_max_buffer_size()
1920 vmci_trans(vsk)->queue_pair_size = val; in vmci_transport_set_max_buffer_size()
1921 vmci_trans(vsk)->queue_pair_max_size = val; in vmci_transport_set_max_buffer_size()
1929 return vmci_trans(vsk)->notify_ops->poll_in( in vmci_transport_notify_poll_in()
1938 return vmci_trans(vsk)->notify_ops->poll_out( in vmci_transport_notify_poll_out()
1947 return vmci_trans(vsk)->notify_ops->recv_init( in vmci_transport_notify_recv_init()
1957 return vmci_trans(vsk)->notify_ops->recv_pre_block( in vmci_transport_notify_recv_pre_block()
1967 return vmci_trans(vsk)->notify_ops->recv_pre_dequeue( in vmci_transport_notify_recv_pre_dequeue()
1979 return vmci_trans(vsk)->notify_ops->recv_post_dequeue( in vmci_transport_notify_recv_post_dequeue()
1988 return vmci_trans(vsk)->notify_ops->send_init( in vmci_transport_notify_send_init()
1997 return vmci_trans(vsk)->notify_ops->send_pre_block( in vmci_transport_notify_send_pre_block()
2006 return vmci_trans(vsk)->notify_ops->send_pre_enqueue( in vmci_transport_notify_send_pre_enqueue()
2016 return vmci_trans(vsk)->notify_ops->send_post_enqueue( in vmci_transport_notify_send_post_enqueue()
2047 vmci_trans(vsk)->notify_ops = &vmci_transport_notify_pkt_ops; in vmci_transport_proto_to_notify_struct()
2053 vmci_trans(vsk)->notify_ops = in vmci_transport_proto_to_notify_struct()
2062 vmci_trans(vsk)->notify_ops->socket_init(sk); in vmci_transport_proto_to_notify_struct()