Lines Matching refs:rx
26 static int rxrpc_send_data(struct rxrpc_sock *rx,
33 static int rxrpc_sendmsg_cmsg(struct rxrpc_sock *rx, struct msghdr *msg, in rxrpc_sendmsg_cmsg() argument
131 int rxrpc_client_sendmsg(struct rxrpc_sock *rx, struct rxrpc_transport *trans, in rxrpc_client_sendmsg() argument
147 ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code, in rxrpc_client_sendmsg()
154 service_id = rx->service_id; in rxrpc_client_sendmsg()
160 key = rx->key; in rxrpc_client_sendmsg()
161 if (key && !rx->key->payload.data) in rxrpc_client_sendmsg()
163 bundle = rxrpc_get_bundle(rx, trans, key, service_id, in rxrpc_client_sendmsg()
169 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, in rxrpc_client_sendmsg()
192 ret = rxrpc_send_data(rx, call, msg, len); in rxrpc_client_sendmsg()
272 int rxrpc_server_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, size_t len) in rxrpc_server_sendmsg() argument
282 ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code, in rxrpc_server_sendmsg()
288 call = rxrpc_accept_call(rx, user_call_ID); in rxrpc_server_sendmsg()
295 call = rxrpc_find_server_call(rx, user_call_ID); in rxrpc_server_sendmsg()
313 ret = rxrpc_send_data(rx, call, msg, len); in rxrpc_server_sendmsg()
396 static int rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, in rxrpc_wait_for_tx_window() argument
420 release_sock(&rx->sk); in rxrpc_wait_for_tx_window()
422 lock_sock(&rx->sk); in rxrpc_wait_for_tx_window()
520 static int rxrpc_send_data(struct rxrpc_sock *rx, in rxrpc_send_data() argument
526 struct sock *sk = &rx->sk; in rxrpc_send_data()
556 ret = rxrpc_wait_for_tx_window(rx, call, in rxrpc_send_data()