Lines Matching full:call
20 * Post a call for attention by the socket or kernel service. Further
23 void rxrpc_notify_socket(struct rxrpc_call *call) in rxrpc_notify_socket() argument
28 _enter("%d", call->debug_id); in rxrpc_notify_socket()
30 if (!list_empty(&call->recvmsg_link)) in rxrpc_notify_socket()
35 rx = rcu_dereference(call->socket); in rxrpc_notify_socket()
38 if (call->notify_rx) { in rxrpc_notify_socket()
39 spin_lock(&call->notify_lock); in rxrpc_notify_socket()
40 call->notify_rx(sk, call, call->user_call_ID); in rxrpc_notify_socket()
41 spin_unlock(&call->notify_lock); in rxrpc_notify_socket()
44 if (list_empty(&call->recvmsg_link)) { in rxrpc_notify_socket()
45 rxrpc_get_call(call, rxrpc_call_get_notify_socket); in rxrpc_notify_socket()
46 list_add_tail(&call->recvmsg_link, &rx->recvmsg_q); in rxrpc_notify_socket()
51 _debug("call %ps", sk->sk_data_ready); in rxrpc_notify_socket()
62 * Pass a call terminating message to userspace.
64 static int rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) in rxrpc_recvmsg_term() argument
69 switch (call->completion) { in rxrpc_recvmsg_term()
72 if (rxrpc_is_service_call(call)) in rxrpc_recvmsg_term()
76 tmp = call->abort_code; in rxrpc_recvmsg_term()
80 tmp = call->abort_code; in rxrpc_recvmsg_term()
84 tmp = -call->error; in rxrpc_recvmsg_term()
88 tmp = -call->error; in rxrpc_recvmsg_term()
92 pr_err("Invalid terminal call state %u\n", call->completion); in rxrpc_recvmsg_term()
97 trace_rxrpc_recvdata(call, rxrpc_recvmsg_terminal, in rxrpc_recvmsg_term()
98 call->ackr_window - 1, in rxrpc_recvmsg_term()
99 call->rx_pkt_offset, call->rx_pkt_len, ret); in rxrpc_recvmsg_term()
106 static void rxrpc_rotate_rx_window(struct rxrpc_call *call) in rxrpc_rotate_rx_window() argument
111 rxrpc_seq_t old_consumed = call->rx_consumed, tseq; in rxrpc_rotate_rx_window()
115 _enter("%d", call->debug_id); in rxrpc_rotate_rx_window()
117 skb = skb_dequeue(&call->recvmsg_queue); in rxrpc_rotate_rx_window()
126 if (after(tseq, call->rx_consumed)) in rxrpc_rotate_rx_window()
127 smp_store_release(&call->rx_consumed, tseq); in rxrpc_rotate_rx_window()
131 trace_rxrpc_receive(call, last ? rxrpc_receive_rotate_last : rxrpc_receive_rotate, in rxrpc_rotate_rx_window()
132 serial, call->rx_consumed); in rxrpc_rotate_rx_window()
135 set_bit(RXRPC_CALL_RECVMSG_READ_ALL, &call->flags); in rxrpc_rotate_rx_window()
138 acked = atomic_add_return(call->rx_consumed - old_consumed, in rxrpc_rotate_rx_window()
139 &call->ackr_nr_consumed); in rxrpc_rotate_rx_window()
141 !test_and_set_bit(RXRPC_CALL_RX_IS_IDLE, &call->flags)) in rxrpc_rotate_rx_window()
142 rxrpc_poke_call(call, rxrpc_call_poke_idle); in rxrpc_rotate_rx_window()
148 static int rxrpc_verify_data(struct rxrpc_call *call, struct sk_buff *skb) in rxrpc_verify_data() argument
154 return call->security->verify_packet(call, skb); in rxrpc_verify_data()
158 * Deliver messages to a call. This keeps processing packets until the buffer
161 * call has failed it returns -EIO.
163 static int rxrpc_recvmsg_data(struct socket *sock, struct rxrpc_call *call, in rxrpc_recvmsg_data() argument
174 rx_pkt_offset = call->rx_pkt_offset; in rxrpc_recvmsg_data()
175 rx_pkt_len = call->rx_pkt_len; in rxrpc_recvmsg_data()
177 if (rxrpc_call_has_failed(call)) { in rxrpc_recvmsg_data()
178 seq = call->ackr_window - 1; in rxrpc_recvmsg_data()
183 if (test_bit(RXRPC_CALL_RECVMSG_READ_ALL, &call->flags)) { in rxrpc_recvmsg_data()
184 seq = call->ackr_window - 1; in rxrpc_recvmsg_data()
192 skb = skb_peek(&call->recvmsg_queue); in rxrpc_recvmsg_data()
199 trace_rxrpc_receive(call, rxrpc_receive_front, in rxrpc_recvmsg_data()
206 ret2 = rxrpc_verify_data(call, skb); in rxrpc_recvmsg_data()
207 trace_rxrpc_recvdata(call, rxrpc_recvmsg_next, seq, in rxrpc_recvmsg_data()
217 trace_rxrpc_recvdata(call, rxrpc_recvmsg_cont, seq, in rxrpc_recvmsg_data()
241 trace_rxrpc_recvdata(call, rxrpc_recvmsg_full, seq, in rxrpc_recvmsg_data()
254 skb = skb_peek_next(skb, &call->recvmsg_queue); in rxrpc_recvmsg_data()
257 rxrpc_rotate_rx_window(call); in rxrpc_recvmsg_data()
262 call->rx_pkt_offset = rx_pkt_offset; in rxrpc_recvmsg_data()
263 call->rx_pkt_len = rx_pkt_len; in rxrpc_recvmsg_data()
266 trace_rxrpc_recvdata(call, rxrpc_recvmsg_data_return, seq, in rxrpc_recvmsg_data()
269 set_bit(RXRPC_CALL_RX_IS_IDLE, &call->flags); in rxrpc_recvmsg_data()
281 struct rxrpc_call *call; in rxrpc_recvmsg() local
312 call = NULL; in rxrpc_recvmsg()
335 /* Find the next call and dequeue it if we're not just peeking. If we in rxrpc_recvmsg()
342 call = list_entry(l, struct rxrpc_call, recvmsg_link); in rxrpc_recvmsg()
344 if (!rxrpc_call_is_complete(call) && in rxrpc_recvmsg()
345 skb_queue_empty(&call->recvmsg_queue)) { in rxrpc_recvmsg()
346 list_del_init(&call->recvmsg_link); in rxrpc_recvmsg()
349 trace_rxrpc_recvmsg(call->debug_id, rxrpc_recvmsg_unqueue, 0); in rxrpc_recvmsg()
350 rxrpc_put_call(call, rxrpc_call_put_recvmsg); in rxrpc_recvmsg()
355 list_del_init(&call->recvmsg_link); in rxrpc_recvmsg()
357 rxrpc_get_call(call, rxrpc_call_get_recvmsg); in rxrpc_recvmsg()
360 call_debug_id = call->debug_id; in rxrpc_recvmsg()
363 /* We're going to drop the socket lock, so we need to lock the call in rxrpc_recvmsg()
366 if (!mutex_trylock(&call->user_mutex)) { in rxrpc_recvmsg()
371 if (mutex_lock_interruptible(&call->user_mutex) < 0) in rxrpc_recvmsg()
377 if (test_bit(RXRPC_CALL_RELEASED, &call->flags)) in rxrpc_recvmsg()
380 if (test_bit(RXRPC_CALL_HAS_USERID, &call->flags)) { in rxrpc_recvmsg()
382 unsigned int id32 = call->user_call_ID; in rxrpc_recvmsg()
387 unsigned long idl = call->user_call_ID; in rxrpc_recvmsg()
396 if (msg->msg_name && call->peer) { in rxrpc_recvmsg()
397 size_t len = sizeof(call->dest_srx); in rxrpc_recvmsg()
399 memcpy(msg->msg_name, &call->dest_srx, len); in rxrpc_recvmsg()
403 ret = rxrpc_recvmsg_data(sock, call, msg, &msg->msg_iter, len, in rxrpc_recvmsg()
412 if (rxrpc_call_is_complete(call) && in rxrpc_recvmsg()
413 skb_queue_empty(&call->recvmsg_queue)) in rxrpc_recvmsg()
415 if (rxrpc_call_has_failed(call)) in rxrpc_recvmsg()
418 if (!skb_queue_empty(&call->recvmsg_queue)) in rxrpc_recvmsg()
419 rxrpc_notify_socket(call); in rxrpc_recvmsg()
423 rxrpc_purge_queue(&call->recvmsg_queue); in rxrpc_recvmsg()
425 ret = rxrpc_recvmsg_term(call, msg); in rxrpc_recvmsg()
429 rxrpc_release_call(rx, call); in rxrpc_recvmsg()
441 mutex_unlock(&call->user_mutex); in rxrpc_recvmsg()
442 rxrpc_put_call(call, rxrpc_call_put_recvmsg); in rxrpc_recvmsg()
449 list_add(&call->recvmsg_link, &rx->recvmsg_q); in rxrpc_recvmsg()
453 rxrpc_put_call(call, rxrpc_call_put_recvmsg); in rxrpc_recvmsg()
465 call = NULL; in rxrpc_recvmsg()
471 * @sock: The socket that the call exists on
472 * @call: The call to send data through
480 * state of a call. Returns 0 if got what was asked for and there's more
489 int rxrpc_kernel_recv_data(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_recv_data() argument
496 _enter("{%d},%zu,%d", call->debug_id, *_len, want_more); in rxrpc_kernel_recv_data()
498 mutex_lock(&call->user_mutex); in rxrpc_kernel_recv_data()
500 ret = rxrpc_recvmsg_data(sock, call, NULL, iter, *_len, 0, &offset); in rxrpc_kernel_recv_data()
528 *_service = call->dest_srx.srx_service; in rxrpc_kernel_recv_data()
529 mutex_unlock(&call->user_mutex); in rxrpc_kernel_recv_data()
534 trace_rxrpc_abort(call->debug_id, rxrpc_recvmsg_short_data, in rxrpc_kernel_recv_data()
535 call->cid, call->call_id, call->rx_consumed, in rxrpc_kernel_recv_data()
540 trace_rxrpc_abort(call->debug_id, rxrpc_recvmsg_excess_data, in rxrpc_kernel_recv_data()
541 call->cid, call->call_id, call->rx_consumed, in rxrpc_kernel_recv_data()
546 *_abort = call->abort_code; in rxrpc_kernel_recv_data()
547 ret = call->error; in rxrpc_kernel_recv_data()
548 if (call->completion == RXRPC_CALL_SUCCEEDED) { in rxrpc_kernel_recv_data()