Searched defs:rx (Results 1 - 21 of 21) sorted by relevance

/net/rxrpc/
H A Dar-recvmsg.c23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call) argument
28 write_lock_bh(&rx->call_lock);
31 write_unlock_bh(&rx->call_lock);
51 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); local
66 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT);
69 lock_sock(&rx->sk);
74 if (RB_EMPTY_ROOT(&rx->calls)) {
77 if (rx->sk.sk_state != RXRPC_SERVER_LISTENING) {
78 release_sock(&rx->sk);
86 skb = skb_peek(&rx
[all...]
H A Dar-security.c167 struct rxrpc_sock *rx; local
184 list_for_each_entry(rx, &local->services, listen_link) {
185 if (rx->service_id == conn->service_id)
196 if (!rx->securities) {
204 kref = keyring_search(make_key_ref(rx->securities, 1UL),
H A Dar-accept.c74 struct rxrpc_sock *rx,
123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO);
133 if (rx->sk.sk_state == RXRPC_CLOSE)
136 write_lock(&rx->call_lock);
144 list_add_tail(&call->accept_link, &rx->secureq);
152 list_add_tail(&call->accept_link, &rx->acceptq);
171 write_unlock(&rx->call_lock);
213 struct rxrpc_sock *rx; local
261 list_for_each_entry(rx, &local->services, listen_link) {
262 if (rx
73 rxrpc_accept_incoming_call(struct rxrpc_local *local, struct rxrpc_sock *rx, struct sk_buff *skb, struct sockaddr_rxrpc *srx) argument
319 rxrpc_accept_call(struct rxrpc_sock *rx, unsigned long user_call_ID) argument
413 rxrpc_reject_call(struct rxrpc_sock *rx) argument
[all...]
H A Dar-input.c46 struct rxrpc_sock *rx = call->socket; local
69 sk = &rx->sk;
100 if (rx->interceptor) {
101 rx->interceptor(sk, call->user_call_ID, skb);
231 _debug("drain rx oos now");
H A Dar-call.c252 struct rxrpc_sock *rx,
262 ASSERT(rx != NULL);
270 sock_hold(&rx->sk);
271 call->socket = rx;
274 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp);
281 call->proto = rx->proto;
315 struct rxrpc_call *rxrpc_get_client_call(struct rxrpc_sock *rx, argument
326 rx, trans ? trans->debug_id : -1, bundle ? bundle->debug_id : -1,
331 read_lock(&rx->call_lock);
333 p = rx
251 rxrpc_alloc_client_call( struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle, gfp_t gfp) argument
415 rxrpc_incoming_call(struct rxrpc_sock *rx, struct rxrpc_connection *conn, struct rxrpc_header *hdr, gfp_t gfp) argument
574 rxrpc_find_server_call(struct rxrpc_sock *rx, unsigned long user_call_ID) argument
616 struct rxrpc_sock *rx = call->socket; local
780 rxrpc_release_calls_on_socket(struct rxrpc_sock *rx) argument
[all...]
H A Dar-connection.c69 struct rxrpc_conn_bundle *rxrpc_get_bundle(struct rxrpc_sock *rx, argument
79 rx, key_serial(key), trans->debug_id, ntohs(service_id));
81 if (rx->trans == trans && rx->bundle) {
82 atomic_inc(&rx->bundle->usage);
83 return rx->bundle;
139 if (!rx->bundle && rx->sk.sk_state == RXRPC_CLIENT_CONNECTED) {
141 rx->bundle = bundle;
151 if (!rx
335 rxrpc_connect_exclusive(struct rxrpc_sock *rx, struct rxrpc_transport *trans, __be16 service_id, struct rxrpc_call *call, gfp_t gfp) argument
429 rxrpc_connect_call(struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle, struct rxrpc_call *call, gfp_t gfp) argument
[all...]
H A Dar-output.c27 struct rxrpc_sock *rx,
34 static int rxrpc_sendmsg_cmsg(struct rxrpc_sock *rx, struct msghdr *msg, argument
132 int rxrpc_client_sendmsg(struct kiocb *iocb, struct rxrpc_sock *rx, argument
149 ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code,
156 service_id = rx->service_id;
162 key = rx->key;
163 if (key && !rx->key->payload.data)
165 bundle = rxrpc_get_bundle(rx, trans, key, service_id,
171 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID,
194 ret = rxrpc_send_data(iocb, rx, cal
277 rxrpc_server_sendmsg(struct kiocb *iocb, struct rxrpc_sock *rx, struct msghdr *msg, size_t len) argument
402 rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) argument
526 rxrpc_send_data(struct kiocb *iocb, struct rxrpc_sock *rx, struct rxrpc_call *call, struct msghdr *msg, size_t len) argument
[all...]
H A Daf_rxrpc.c80 static int rxrpc_validate_address(struct rxrpc_sock *rx, argument
98 if (srx->transport.family != rx->proto)
127 struct rxrpc_sock *rx = rxrpc_sk(sk), *prx; local
131 _enter("%p,%p,%d", rx, saddr, len);
133 ret = rxrpc_validate_address(rx, srx, len);
137 lock_sock(&rx->sk);
139 if (rx->sk.sk_state != RXRPC_UNCONNECTED) {
144 memcpy(&rx->srx, srx, sizeof(rx->srx));
147 local = rxrpc_lookup_local(&rx
191 struct rxrpc_sock *rx = rxrpc_sk(sk); local
230 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); local
278 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); local
360 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); local
380 struct rxrpc_sock *rx = rxrpc_sk(sk); local
448 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); local
516 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); local
618 struct rxrpc_sock *rx; local
684 struct rxrpc_sock *rx = rxrpc_sk(sk); local
[all...]
H A Dar-key.c889 int rxrpc_request_key(struct rxrpc_sock *rx, char __user *optval, int optlen) argument
916 rx->key = key;
925 int rxrpc_server_keyring(struct rxrpc_sock *rx, char __user *optval, argument
953 rx->securities = key;
/net/dccp/
H A Dccid.c144 struct ccid *ccid_new(const u8 id, struct sock *sk, bool rx) argument
152 ccid = kmem_cache_alloc(rx ? ccid_ops->ccid_hc_rx_slab :
157 if (rx) {
171 kmem_cache_free(rx ? ccid_ops->ccid_hc_rx_slab :
H A Dproto.c431 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx) argument
455 rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len);
458 if (rx)
H A Dfeat.c41 static int dccp_hdlr_ccid(struct sock *sk, u64 ccid, bool rx) argument
44 struct ccid *new_ccid = ccid_new(ccid, sk, rx);
49 if (rx) {
59 static int dccp_hdlr_seq_win(struct sock *sk, u64 seq_win, bool rx) argument
63 if (rx) {
75 static int dccp_hdlr_ack_ratio(struct sock *sk, u64 ratio, bool rx) argument
77 if (rx)
84 static int dccp_hdlr_ackvec(struct sock *sk, u64 enable, bool rx) argument
88 if (rx) {
101 static int dccp_hdlr_ndp(struct sock *sk, u64 enable, bool rx) argument
117 dccp_hdlr_min_cscov(struct sock *sk, u64 cscov, bool rx) argument
311 bool rx; local
1448 } tx, rx; local
[all...]
/net/mac80211/
H A Dwep.c275 ieee80211_crypto_wep_decrypt(struct ieee80211_rx_data *rx) argument
277 struct sk_buff *skb = rx->skb;
286 if (skb_linearize(rx->skb))
288 if (ieee80211_wep_decrypt(rx->local, rx->skb, rx->key))
291 if (!pskb_may_pull(rx->skb, ieee80211_hdrlen(fc) +
294 ieee80211_wep_remove_iv(rx->local, rx->skb, rx
[all...]
H A Dkey.h73 struct tkip_ctx rx[IEEE80211_NUM_TIDS]; member in struct:ieee80211_key::__anon77::__anon78
H A Dwpa.c85 ieee80211_rx_h_michael_mic_verify(struct ieee80211_rx_data *rx) argument
91 struct sk_buff *skb = rx->skb;
112 if (!(status->flag & RX_FLAG_IV_STRIPPED) && rx->key &&
113 rx->key->conf.cipher == WLAN_CIPHER_SUITE_TKIP)
124 if (!rx->key || rx->key->conf.cipher != WLAN_CIPHER_SUITE_TKIP ||
128 if (rx->sdata->vif.type == NL80211_IFTYPE_AP && rx->key->conf.keyidx) {
145 if (skb_linearize(rx->skb))
151 key = &rx
258 ieee80211_crypto_tkip_decrypt(struct ieee80211_rx_data *rx) argument
489 ieee80211_crypto_ccmp_decrypt(struct ieee80211_rx_data *rx) argument
599 ieee80211_crypto_cs_decrypt(struct ieee80211_rx_data *rx) argument
739 ieee80211_crypto_aes_cmac_decrypt(struct ieee80211_rx_data *rx) argument
815 ieee80211_crypto_hw_decrypt(struct ieee80211_rx_data *rx) argument
[all...]
H A Ddriver-ops.h831 u32 tx, u32 rx)
837 trace_drv_set_ringparam(local, tx, rx);
839 ret = local->ops->set_ringparam(&local->hw, tx, rx);
846 u32 *tx, u32 *tx_max, u32 *rx, u32 *rx_max)
850 trace_drv_get_ringparam(local, tx, tx_max, rx, rx_max);
852 local->ops->get_ringparam(&local->hw, tx, tx_max, rx, rx_max);
830 drv_set_ringparam(struct ieee80211_local *local, u32 tx, u32 rx) argument
845 drv_get_ringparam(struct ieee80211_local *local, u32 *tx, u32 *tx_max, u32 *rx, u32 *rx_max) argument
H A Drx.c488 static void ieee80211_parse_qos(struct ieee80211_rx_data *rx) argument
490 struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)rx->skb->data;
491 struct ieee80211_rx_status *status = IEEE80211_SKB_RXCB(rx->skb);
523 rx->seqno_idx = seqno_idx;
524 rx->security_idx = security_idx;
527 rx->skb->priority = (tid > 7) ? 0 : tid;
555 static void ieee80211_verify_alignment(struct ieee80211_rx_data *rx) argument
558 WARN_ONCE((unsigned long)rx->skb->data & 1,
559 "unaligned packet at 0x%p\n", rx->skb->data);
564 /* rx handler
630 ieee80211_rx_mesh_check(struct ieee80211_rx_data *rx) argument
912 ieee80211_rx_reorder_ampdu(struct ieee80211_rx_data *rx, struct sk_buff_head *frames) argument
988 ieee80211_rx_h_check(struct ieee80211_rx_data *rx) argument
1070 ieee80211_rx_h_check_more_data(struct ieee80211_rx_data *rx) argument
1167 ieee80211_rx_h_uapsd_and_pspoll(struct ieee80211_rx_data *rx) argument
1242 ieee80211_rx_h_sta_process(struct ieee80211_rx_data *rx) argument
1380 ieee80211_rx_h_decrypt(struct ieee80211_rx_data *rx) argument
1662 ieee80211_rx_h_defragment(struct ieee80211_rx_data *rx) argument
1785 ieee80211_802_1x_port_control(struct ieee80211_rx_data *rx) argument
1793 ieee80211_drop_unencrypted(struct ieee80211_rx_data *rx, __le16 fc) argument
1815 ieee80211_drop_unencrypted_mgmt(struct ieee80211_rx_data *rx) argument
1862 __ieee80211_data_to_8023(struct ieee80211_rx_data *rx, bool *port_control) argument
1904 ieee80211_frame_allowed(struct ieee80211_rx_data *rx, __le16 fc) argument
1930 ieee80211_deliver_skb(struct ieee80211_rx_data *rx) argument
2022 ieee80211_rx_h_amsdu(struct ieee80211_rx_data *rx) argument
2080 ieee80211_rx_h_mesh_fwding(struct ieee80211_rx_data *rx) argument
2217 ieee80211_rx_h_data(struct ieee80211_rx_data *rx) argument
2281 ieee80211_rx_h_ctrl(struct ieee80211_rx_data *rx, struct sk_buff_head *frames) argument
2382 ieee80211_rx_h_mgmt_check(struct ieee80211_rx_data *rx) argument
2422 ieee80211_rx_h_action(struct ieee80211_rx_data *rx) argument
2719 ieee80211_rx_h_userspace_mgmt(struct ieee80211_rx_data *rx) argument
2750 ieee80211_rx_h_action_return(struct ieee80211_rx_data *rx) argument
2813 ieee80211_rx_h_mgmt(struct ieee80211_rx_data *rx) argument
2865 ieee80211_rx_cooked_monitor(struct ieee80211_rx_data *rx, struct ieee80211_rate *rate) argument
2934 ieee80211_rx_handlers_result(struct ieee80211_rx_data *rx, ieee80211_rx_result res) argument
2970 ieee80211_rx_handlers(struct ieee80211_rx_data *rx, struct sk_buff_head *frames) argument
3027 ieee80211_invoke_rx_handlers(struct ieee80211_rx_data *rx) argument
3061 struct ieee80211_rx_data rx = { local
3087 prepare_for_handlers(struct ieee80211_rx_data *rx, struct ieee80211_hdr *hdr) argument
3203 ieee80211_prepare_and_rx_handle(struct ieee80211_rx_data *rx, struct sk_buff *skb, bool consume) argument
3245 struct ieee80211_rx_data rx; local
[all...]
/net/nfc/nci/
H A Dspi.c186 struct spi_transfer tx, rx; local
200 memset(&rx, 0, sizeof(struct spi_transfer));
201 rx.rx_buf = resp_hdr;
202 rx.len = 2;
203 rx.cs_change = 1;
204 spi_message_add_tail(&rx, &m);
222 memset(&rx, 0, sizeof(struct spi_transfer));
223 rx.rx_buf = skb_put(skb, rx_len);
224 rx.len = rx_len;
225 rx
[all...]
/net/can/
H A Daf_can.h49 /* af_can rx dispatcher structures */
70 struct hlist_head rx[RX_MAX]; member in struct:dev_rcv_lists
124 extern struct hlist_head can_rx_dev_list; /* rx dispatcher structures */
/net/xfrm/
H A Dxfrm_state.c890 struct xfrm_state *rx = NULL, *x = NULL; local
903 rx = x;
908 if (rx)
909 xfrm_state_hold(rx);
913 return rx;
/net/core/
H A Ddev.c1264 /* Block netpoll from trying to do any rx path servicing.
2436 /* openvswitch calls this on rx path, so we need a different check.
3141 * different from current CPU (one in the rx-queue flow
3544 * @rx_handler_data: data pointer that is used by rx handler
6083 struct netdev_rx_queue *rx; local
6087 rx = kcalloc(count, sizeof(struct netdev_rx_queue), GFP_KERNEL);
6088 if (!rx)
6091 dev->_rx = rx;
6094 rx[i].dev = dev;

Completed in 240 milliseconds