Lines Matching refs:sk

113 vmci_transport_handle_waiting_read(struct sock *sk,  in vmci_transport_handle_waiting_read()  argument
122 vsk = vsock_sk(sk); in vmci_transport_handle_waiting_read()
134 sent = vmci_transport_send_wrote(sk) > 0; in vmci_transport_handle_waiting_read()
143 vmci_transport_handle_waiting_write(struct sock *sk, in vmci_transport_handle_waiting_write() argument
152 vsk = vsock_sk(sk); in vmci_transport_handle_waiting_write()
164 sent = vmci_transport_send_read(sk) > 0; in vmci_transport_handle_waiting_write()
173 vmci_transport_handle_read(struct sock *sk, in vmci_transport_handle_read() argument
181 vsk = vsock_sk(sk); in vmci_transport_handle_read()
185 sk->sk_write_space(sk); in vmci_transport_handle_read()
188 static bool send_waiting_read(struct sock *sk, u64 room_needed) in send_waiting_read() argument
198 vsk = vsock_sk(sk); in send_waiting_read()
220 ret = vmci_transport_send_waiting_read(sk, &waiting_info) > 0; in send_waiting_read()
230 static bool send_waiting_write(struct sock *sk, u64 room_needed) in send_waiting_write() argument
240 vsk = vsock_sk(sk); in send_waiting_write()
257 ret = vmci_transport_send_waiting_write(sk, &waiting_info) > 0; in send_waiting_write()
267 static int vmci_transport_send_read_notification(struct sock *sk) in vmci_transport_send_read_notification() argument
274 vsk = vsock_sk(sk); in vmci_transport_send_read_notification()
290 err = vmci_transport_send_read(sk); in vmci_transport_send_read_notification()
298 pr_err("%p unable to send read notify to peer\n", sk); in vmci_transport_send_read_notification()
309 vmci_transport_handle_wrote(struct sock *sk, in vmci_transport_handle_wrote() argument
315 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_handle_wrote()
318 sk->sk_data_ready(sk); in vmci_transport_handle_wrote()
321 static void vmci_transport_notify_pkt_socket_init(struct sock *sk) in vmci_transport_notify_pkt_socket_init() argument
323 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_socket_init()
346 vmci_transport_notify_pkt_poll_in(struct sock *sk, in vmci_transport_notify_pkt_poll_in() argument
349 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_poll_in()
358 if (sk->sk_state == SS_CONNECTED) { in vmci_transport_notify_pkt_poll_in()
359 if (!send_waiting_read(sk, 1)) in vmci_transport_notify_pkt_poll_in()
370 vmci_transport_notify_pkt_poll_out(struct sock *sk, in vmci_transport_notify_pkt_poll_out() argument
374 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_poll_out()
389 if (!send_waiting_write(sk, 1)) in vmci_transport_notify_pkt_poll_out()
400 struct sock *sk, in vmci_transport_notify_pkt_recv_init() argument
404 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_recv_init()
436 struct sock *sk, in vmci_transport_notify_pkt_recv_pre_block() argument
443 if (!send_waiting_read(sk, target)) { in vmci_transport_notify_pkt_recv_pre_block()
449 err = vmci_transport_send_read_notification(sk); in vmci_transport_notify_pkt_recv_pre_block()
462 struct sock *sk, in vmci_transport_notify_pkt_recv_pre_dequeue() argument
466 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_recv_pre_dequeue()
482 struct sock *sk, in vmci_transport_notify_pkt_recv_post_dequeue() argument
491 vsk = vsock_sk(sk); in vmci_transport_notify_pkt_recv_post_dequeue()
505 err = vmci_transport_send_read_notification(sk); in vmci_transport_notify_pkt_recv_post_dequeue()
515 struct sock *sk, in vmci_transport_notify_pkt_send_init() argument
528 struct sock *sk, in vmci_transport_notify_pkt_send_pre_block() argument
532 if (!send_waiting_write(sk, 1)) in vmci_transport_notify_pkt_send_pre_block()
540 struct sock *sk, in vmci_transport_notify_pkt_send_pre_enqueue() argument
543 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_send_pre_enqueue()
556 struct sock *sk, in vmci_transport_notify_pkt_send_post_enqueue() argument
565 vsk = vsock_sk(sk); in vmci_transport_notify_pkt_send_post_enqueue()
586 err = vmci_transport_send_wrote(sk); in vmci_transport_notify_pkt_send_post_enqueue()
594 pr_err("%p unable to send wrote notify to peer\n", sk); in vmci_transport_notify_pkt_send_post_enqueue()
607 struct sock *sk, in vmci_transport_notify_pkt_handle_pkt() argument
617 vmci_transport_handle_wrote(sk, pkt, bottom_half, dst, src); in vmci_transport_notify_pkt_handle_pkt()
621 vmci_transport_handle_read(sk, pkt, bottom_half, dst, src); in vmci_transport_notify_pkt_handle_pkt()
625 vmci_transport_handle_waiting_write(sk, pkt, bottom_half, in vmci_transport_notify_pkt_handle_pkt()
631 vmci_transport_handle_waiting_read(sk, pkt, bottom_half, in vmci_transport_notify_pkt_handle_pkt()
641 static void vmci_transport_notify_pkt_process_request(struct sock *sk) in vmci_transport_notify_pkt_process_request() argument
643 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_process_request()
652 static void vmci_transport_notify_pkt_process_negotiate(struct sock *sk) in vmci_transport_notify_pkt_process_negotiate() argument
654 struct vsock_sock *vsk = vsock_sk(sk); in vmci_transport_notify_pkt_process_negotiate()