Lines Matching refs:pending
54 struct sock *pending,
474 struct sock *pending; in vmci_transport_get_pending() local
485 pending = sk_vsock(vpending); in vmci_transport_get_pending()
486 sock_hold(pending); in vmci_transport_get_pending()
491 pending = NULL; in vmci_transport_get_pending()
493 return pending; in vmci_transport_get_pending()
497 static void vmci_transport_release_pending(struct sock *pending) in vmci_transport_release_pending() argument
499 sock_put(pending); in vmci_transport_release_pending()
957 struct sock *pending; in vmci_transport_recv_listen() local
973 pending = vmci_transport_get_pending(sk, pkt); in vmci_transport_recv_listen()
974 if (pending) { in vmci_transport_recv_listen()
975 lock_sock(pending); in vmci_transport_recv_listen()
978 vsock_sk(pending)->local_addr.svm_cid = pkt->dg.dst.context; in vmci_transport_recv_listen()
980 switch (pending->sk_state) { in vmci_transport_recv_listen()
983 pending, in vmci_transport_recv_listen()
987 vmci_transport_send_reset(pending, pkt); in vmci_transport_recv_listen()
992 vsock_remove_pending(sk, pending); in vmci_transport_recv_listen()
994 release_sock(pending); in vmci_transport_recv_listen()
995 vmci_transport_release_pending(pending); in vmci_transport_recv_listen()
1024 pending = __vsock_create(sock_net(sk), NULL, sk, GFP_KERNEL, in vmci_transport_recv_listen()
1026 if (!pending) { in vmci_transport_recv_listen()
1031 vpending = vsock_sk(pending); in vmci_transport_recv_listen()
1065 pending, &version, true)) in vmci_transport_recv_listen()
1066 err = vmci_transport_send_negotiate(pending, qp_size); in vmci_transport_recv_listen()
1089 pending, &active_proto_version, false)) in vmci_transport_recv_listen()
1090 err = vmci_transport_send_negotiate2(pending, in vmci_transport_recv_listen()
1103 sock_put(pending); in vmci_transport_recv_listen()
1108 vsock_add_pending(sk, pending); in vmci_transport_recv_listen()
1111 pending->sk_state = SS_CONNECTING; in vmci_transport_recv_listen()
1116 vmci_trans(vpending)->notify_ops->process_request(pending); in vmci_transport_recv_listen()
1129 sock_hold(pending); in vmci_transport_recv_listen()
1139 struct sock *pending, in vmci_transport_recv_connecting_server() argument
1151 vpending = vsock_sk(pending); in vmci_transport_recv_connecting_server()
1157 vmci_transport_send_reset(pending, pkt); in vmci_transport_recv_connecting_server()
1165 vmci_transport_send_reset(pending, pkt); in vmci_transport_recv_connecting_server()
1184 pending, &detach_sub_id); in vmci_transport_recv_connecting_server()
1186 vmci_transport_send_reset(pending, pkt); in vmci_transport_recv_connecting_server()
1216 vmci_transport_send_reset(pending, pkt); in vmci_transport_recv_connecting_server()
1240 pending->sk_state = SS_CONNECTED; in vmci_transport_recv_connecting_server()
1245 err = vmci_transport_send_attach(pending, handle); in vmci_transport_recv_connecting_server()
1249 vmci_transport_send_reset(pending, pkt); in vmci_transport_recv_connecting_server()
1259 vsock_remove_pending(listener, pending); in vmci_transport_recv_connecting_server()
1260 vsock_enqueue_accept(listener, pending); in vmci_transport_recv_connecting_server()
1270 pending->sk_err = skerr; in vmci_transport_recv_connecting_server()
1271 pending->sk_state = SS_UNCONNECTED; in vmci_transport_recv_connecting_server()
1279 sock_put(pending); in vmci_transport_recv_connecting_server()