Lines Matching refs:rx
24 struct rxrpc_sock *rx,
31 static int rxrpc_sendmsg_cmsg(struct rxrpc_sock *rx, struct msghdr *msg, in rxrpc_sendmsg_cmsg() argument
129 int rxrpc_client_sendmsg(struct kiocb *iocb, struct rxrpc_sock *rx, in rxrpc_client_sendmsg() argument
146 ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code, in rxrpc_client_sendmsg()
153 service_id = rx->service_id; in rxrpc_client_sendmsg()
159 key = rx->key; in rxrpc_client_sendmsg()
160 if (key && !rx->key->payload.data) in rxrpc_client_sendmsg()
162 bundle = rxrpc_get_bundle(rx, trans, key, service_id, in rxrpc_client_sendmsg()
168 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, in rxrpc_client_sendmsg()
191 ret = rxrpc_send_data(iocb, rx, call, msg, len); in rxrpc_client_sendmsg()
274 int rxrpc_server_sendmsg(struct kiocb *iocb, struct rxrpc_sock *rx, in rxrpc_server_sendmsg() argument
285 ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code, in rxrpc_server_sendmsg()
291 call = rxrpc_accept_call(rx, user_call_ID); in rxrpc_server_sendmsg()
298 call = rxrpc_find_server_call(rx, user_call_ID); in rxrpc_server_sendmsg()
316 ret = rxrpc_send_data(iocb, rx, call, msg, len); in rxrpc_server_sendmsg()
399 static int rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, in rxrpc_wait_for_tx_window() argument
423 release_sock(&rx->sk); in rxrpc_wait_for_tx_window()
425 lock_sock(&rx->sk); in rxrpc_wait_for_tx_window()
524 struct rxrpc_sock *rx, in rxrpc_send_data() argument
532 struct sock *sk = &rx->sk; in rxrpc_send_data()
576 ret = rxrpc_wait_for_tx_window(rx, call, in rxrpc_send_data()