Lines Matching refs:rx

107 static int rxrpc_wait_for_tx_window_intr(struct rxrpc_sock *rx,
131 static int rxrpc_wait_for_tx_window_waitall(struct rxrpc_sock *rx,
171 static int rxrpc_wait_for_tx_window_nonintr(struct rxrpc_sock *rx,
192 static int rxrpc_wait_for_tx_window(struct rxrpc_sock *rx,
208 			ret = rxrpc_wait_for_tx_window_waitall(rx, call);
210 			ret = rxrpc_wait_for_tx_window_intr(rx, call, timeo);
215 		ret = rxrpc_wait_for_tx_window_nonintr(rx, call, timeo);
229 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call,
233 		notify_end_tx(&rx->sk, call, call->user_call_ID);
241 static void rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call,
270 		rxrpc_notify_end_tx(rx, call, notify_end_tx);
320 static int rxrpc_send_data(struct rxrpc_sock *rx,
327 	struct sock *sk = &rx->sk;
448 			rxrpc_queue_packet(rx, call, txb, notify_end_tx);
483 	ret = rxrpc_wait_for_tx_window(rx, call, &timeo,
608 rxrpc_new_client_call_for_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg,
610 	__releases(&rx->sk.sk_lock)
623 		release_sock(&rx->sk);
627 	peer = rxrpc_lookup_peer(rx->local, srx, GFP_KERNEL);
629 		release_sock(&rx->sk);
633 	key = rx->key;
634 	if (key && !rx->key->payload.data[0])
638 	cp.local		= rx->local;
640 	cp.key			= rx->key;
641 	cp.security_level	= rx->min_sec_level;
642 	cp.exclusive		= rx->exclusive | p->exclusive;
645 	call = rxrpc_new_client_call(rx, &cp, &p->call, GFP_KERNEL,
659 int rxrpc_do_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, size_t len)
684 		if (rx->sk.sk_state != RXRPC_SERVER_LISTENING)
686 		ret = rxrpc_user_charge_accept(rx, p.call.user_call_ID);
690 	call = rxrpc_find_call_by_user_ID(rx, p.call.user_call_ID);
695 		call = rxrpc_new_client_call_for_sendmsg(rx, msg, &p);
721 		release_sock(&rx->sk);
771 		ret = rxrpc_send_data(rx, call, msg, len, NULL, &dropped_lock);
787 	release_sock(&rx->sk);