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