38 static int rxrpc_wait_for_tx_window_intr(struct rxrpc_sock *rx,  in rxrpc_wait_for_tx_window_intr()  argument
62 static int rxrpc_wait_for_tx_window_waitall(struct rxrpc_sock *rx,  in rxrpc_wait_for_tx_window_waitall()  argument
103 static int rxrpc_wait_for_tx_window_nonintr(struct rxrpc_sock *rx,  in rxrpc_wait_for_tx_window_nonintr()  argument
124 static int rxrpc_wait_for_tx_window(struct rxrpc_sock *rx,  in rxrpc_wait_for_tx_window()  argument
140 			ret = rxrpc_wait_for_tx_window_waitall(rx, call);  in rxrpc_wait_for_tx_window()
142 			ret = rxrpc_wait_for_tx_window_intr(rx, call, timeo);  in rxrpc_wait_for_tx_window()
147 		ret = rxrpc_wait_for_tx_window_nonintr(rx, call, timeo);  in rxrpc_wait_for_tx_window()
179 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call,  in rxrpc_notify_end_tx()  argument
183 		notify_end_tx(&rx->sk, call, call->user_call_ID);  in rxrpc_notify_end_tx()
191 static int rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call,  in rxrpc_queue_packet()  argument
230 			rxrpc_notify_end_tx(rx, call, notify_end_tx);  in rxrpc_queue_packet()
244 			rxrpc_notify_end_tx(rx, call, notify_end_tx);  in rxrpc_queue_packet()
287 static int rxrpc_send_data(struct rxrpc_sock *rx,  in rxrpc_send_data()  argument
295 	struct sock *sk = &rx->sk;  in rxrpc_send_data()
437 			ret = rxrpc_queue_packet(rx, call, skb,  in rxrpc_send_data()
478 	ret = rxrpc_wait_for_tx_window(rx, call, &timeo,  in rxrpc_send_data()
603 rxrpc_new_client_call_for_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg,  in rxrpc_new_client_call_for_sendmsg()  argument
605 	__releases(&rx->sk.sk_lock.slock)  in rxrpc_new_client_call_for_sendmsg()
617 		release_sock(&rx->sk);  in rxrpc_new_client_call_for_sendmsg()
621 	key = rx->key;  in rxrpc_new_client_call_for_sendmsg()
622 	if (key && !rx->key->payload.data[0])  in rxrpc_new_client_call_for_sendmsg()
626 	cp.local		= rx->local;  in rxrpc_new_client_call_for_sendmsg()
627 	cp.key			= rx->key;  in rxrpc_new_client_call_for_sendmsg()
628 	cp.security_level	= rx->min_sec_level;  in rxrpc_new_client_call_for_sendmsg()
629 	cp.exclusive		= rx->exclusive | p->exclusive;  in rxrpc_new_client_call_for_sendmsg()
632 	call = rxrpc_new_client_call(rx, &cp, srx, &p->call, GFP_KERNEL,  in rxrpc_new_client_call_for_sendmsg()
646 int rxrpc_do_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, size_t len)  in rxrpc_do_sendmsg()  argument
647 	__releases(&rx->sk.sk_lock.slock)  in rxrpc_do_sendmsg()
675 		if (rx->sk.sk_state != RXRPC_SERVER_LISTENING)  in rxrpc_do_sendmsg()
677 		ret = rxrpc_user_charge_accept(rx, p.call.user_call_ID);  in rxrpc_do_sendmsg()
681 	call = rxrpc_find_call_by_user_ID(rx, p.call.user_call_ID);  in rxrpc_do_sendmsg()
686 		call = rxrpc_new_client_call_for_sendmsg(rx, msg, &p);  in rxrpc_do_sendmsg()
708 		release_sock(&rx->sk);  in rxrpc_do_sendmsg()
763 		ret = rxrpc_send_data(rx, call, msg, len, NULL, &dropped_lock);  in rxrpc_do_sendmsg()
775 	release_sock(&rx->sk);  in rxrpc_do_sendmsg()