Home
last modified time | relevance | path

Searched refs:rx (Results 1 – 25 of 40) sorted by relevance

12

/net/rxrpc/
Daf_rxrpc.c80 static int rxrpc_validate_address(struct rxrpc_sock *rx, in rxrpc_validate_address() argument
98 if (srx->transport.family != rx->proto) in rxrpc_validate_address()
127 struct rxrpc_sock *rx = rxrpc_sk(sk), *prx; in rxrpc_bind() local
131 _enter("%p,%p,%d", rx, saddr, len); in rxrpc_bind()
133 ret = rxrpc_validate_address(rx, srx, len); in rxrpc_bind()
137 lock_sock(&rx->sk); in rxrpc_bind()
139 if (rx->sk.sk_state != RXRPC_UNCONNECTED) { in rxrpc_bind()
144 memcpy(&rx->srx, srx, sizeof(rx->srx)); in rxrpc_bind()
147 local = rxrpc_lookup_local(&rx->srx); in rxrpc_bind()
153 rx->local = local; in rxrpc_bind()
[all …]
Dar-recvmsg.c23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call) in rxrpc_remove_user_ID() argument
28 write_lock_bh(&rx->call_lock); in rxrpc_remove_user_ID()
31 write_unlock_bh(&rx->call_lock); in rxrpc_remove_user_ID()
51 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_recvmsg() local
66 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
69 lock_sock(&rx->sk); in rxrpc_recvmsg()
74 if (RB_EMPTY_ROOT(&rx->calls)) { in rxrpc_recvmsg()
77 if (rx->sk.sk_state != RXRPC_SERVER_LISTENING) { in rxrpc_recvmsg()
78 release_sock(&rx->sk); in rxrpc_recvmsg()
86 skb = skb_peek(&rx->sk.sk_receive_queue); in rxrpc_recvmsg()
[all …]
Dar-accept.c74 struct rxrpc_sock *rx, in rxrpc_accept_incoming_call() argument
123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO); in rxrpc_accept_incoming_call()
133 if (rx->sk.sk_state == RXRPC_CLOSE) in rxrpc_accept_incoming_call()
136 write_lock(&rx->call_lock); in rxrpc_accept_incoming_call()
144 list_add_tail(&call->accept_link, &rx->secureq); in rxrpc_accept_incoming_call()
152 list_add_tail(&call->accept_link, &rx->acceptq); in rxrpc_accept_incoming_call()
171 write_unlock(&rx->call_lock); in rxrpc_accept_incoming_call()
213 struct rxrpc_sock *rx; in rxrpc_accept_incoming_calls() local
261 list_for_each_entry(rx, &local->services, listen_link) { in rxrpc_accept_incoming_calls()
262 if (rx->service_id == service_id && in rxrpc_accept_incoming_calls()
[all …]
Dar-call.c103 struct rxrpc_sock *rx, in rxrpc_alloc_client_call() argument
113 ASSERT(rx != NULL); in rxrpc_alloc_client_call()
121 sock_hold(&rx->sk); in rxrpc_alloc_client_call()
122 call->socket = rx; in rxrpc_alloc_client_call()
125 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp); in rxrpc_alloc_client_call()
146 struct rxrpc_call *rxrpc_get_client_call(struct rxrpc_sock *rx, in rxrpc_get_client_call() argument
157 rx, trans ? trans->debug_id : -1, bundle ? bundle->debug_id : -1, in rxrpc_get_client_call()
162 read_lock(&rx->call_lock); in rxrpc_get_client_call()
164 p = rx->calls.rb_node; in rxrpc_get_client_call()
176 read_unlock(&rx->call_lock); in rxrpc_get_client_call()
[all …]
Dar-output.c24 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()
[all …]
Dar-connection.c65 struct rxrpc_conn_bundle *rxrpc_get_bundle(struct rxrpc_sock *rx, in rxrpc_get_bundle() argument
75 rx, key_serial(key), trans->debug_id, ntohs(service_id)); in rxrpc_get_bundle()
77 if (rx->trans == trans && rx->bundle) { in rxrpc_get_bundle()
78 atomic_inc(&rx->bundle->usage); in rxrpc_get_bundle()
79 return rx->bundle; in rxrpc_get_bundle()
135 if (!rx->bundle && rx->sk.sk_state == RXRPC_CLIENT_CONNECTED) { in rxrpc_get_bundle()
137 rx->bundle = bundle; in rxrpc_get_bundle()
147 if (!rx->bundle && rx->sk.sk_state == RXRPC_CLIENT_CONNECTED) { in rxrpc_get_bundle()
149 rx->bundle = bundle; in rxrpc_get_bundle()
160 if (!rx->bundle && rx->sk.sk_state == RXRPC_CLIENT_CONNECTED) { in rxrpc_get_bundle()
[all …]
Dar-security.c167 struct rxrpc_sock *rx; in rxrpc_init_server_conn_security() local
184 list_for_each_entry(rx, &local->services, listen_link) { in rxrpc_init_server_conn_security()
185 if (rx->service_id == conn->service_id) in rxrpc_init_server_conn_security()
196 if (!rx->securities) { in rxrpc_init_server_conn_security()
204 kref = keyring_search(make_key_ref(rx->securities, 1UL), in rxrpc_init_server_conn_security()
Dar-input.c48 struct rxrpc_sock *rx = call->socket; in rxrpc_queue_rcv_skb() local
71 sk = &rx->sk; in rxrpc_queue_rcv_skb()
102 if (rx->interceptor) { in rxrpc_queue_rcv_skb()
103 rx->interceptor(sk, call->user_call_ID, skb); in rxrpc_queue_rcv_skb()
/net/mac80211/
Drx.c473 static void ieee80211_parse_qos(struct ieee80211_rx_data *rx) in ieee80211_parse_qos() argument
475 struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)rx->skb->data; in ieee80211_parse_qos()
476 struct ieee80211_rx_status *status = IEEE80211_SKB_RXCB(rx->skb); in ieee80211_parse_qos()
508 rx->seqno_idx = seqno_idx; in ieee80211_parse_qos()
509 rx->security_idx = security_idx; in ieee80211_parse_qos()
512 rx->skb->priority = (tid > 7) ? 0 : tid; in ieee80211_parse_qos()
540 static void ieee80211_verify_alignment(struct ieee80211_rx_data *rx) in ieee80211_verify_alignment() argument
543 WARN_ONCE((unsigned long)rx->skb->data & 1, in ieee80211_verify_alignment()
544 "unaligned packet at 0x%p\n", rx->skb->data); in ieee80211_verify_alignment()
594 static ieee80211_rx_result ieee80211_rx_mesh_check(struct ieee80211_rx_data *rx) in ieee80211_rx_mesh_check() argument
[all …]
Dwpa.c82 ieee80211_rx_h_michael_mic_verify(struct ieee80211_rx_data *rx) in ieee80211_rx_h_michael_mic_verify() argument
88 struct sk_buff *skb = rx->skb; in ieee80211_rx_h_michael_mic_verify()
109 if (!(status->flag & RX_FLAG_IV_STRIPPED) && rx->key && in ieee80211_rx_h_michael_mic_verify()
110 rx->key->conf.cipher == WLAN_CIPHER_SUITE_TKIP) in ieee80211_rx_h_michael_mic_verify()
121 if (!rx->key || rx->key->conf.cipher != WLAN_CIPHER_SUITE_TKIP || in ieee80211_rx_h_michael_mic_verify()
125 if (rx->sdata->vif.type == NL80211_IFTYPE_AP && rx->key->conf.keyidx) { in ieee80211_rx_h_michael_mic_verify()
142 if (skb_linearize(rx->skb)) in ieee80211_rx_h_michael_mic_verify()
148 key = &rx->key->conf.key[NL80211_TKIP_DATA_OFFSET_RX_MIC_KEY]; in ieee80211_rx_h_michael_mic_verify()
158 rx->key->u.tkip.rx[rx->security_idx].iv32 = rx->tkip_iv32; in ieee80211_rx_h_michael_mic_verify()
159 rx->key->u.tkip.rx[rx->security_idx].iv16 = rx->tkip_iv16; in ieee80211_rx_h_michael_mic_verify()
[all …]
Dwep.c290 ieee80211_crypto_wep_decrypt(struct ieee80211_rx_data *rx) in ieee80211_crypto_wep_decrypt() argument
292 struct sk_buff *skb = rx->skb; in ieee80211_crypto_wep_decrypt()
301 if (skb_linearize(rx->skb)) in ieee80211_crypto_wep_decrypt()
303 if (rx->sta && ieee80211_wep_is_weak_iv(rx->skb, rx->key)) in ieee80211_crypto_wep_decrypt()
304 rx->sta->wep_weak_iv_count++; in ieee80211_crypto_wep_decrypt()
305 if (ieee80211_wep_decrypt(rx->local, rx->skb, rx->key)) in ieee80211_crypto_wep_decrypt()
308 if (!pskb_may_pull(rx->skb, ieee80211_hdrlen(fc) + WEP_IV_LEN)) in ieee80211_crypto_wep_decrypt()
310 if (rx->sta && ieee80211_wep_is_weak_iv(rx->skb, rx->key)) in ieee80211_crypto_wep_decrypt()
311 rx->sta->wep_weak_iv_count++; in ieee80211_crypto_wep_decrypt()
312 ieee80211_wep_remove_iv(rx->local, rx->skb, rx->key); in ieee80211_crypto_wep_decrypt()
[all …]
Dtkip.c268 if (key->u.tkip.rx[queue].state != TKIP_STATE_NOT_INIT && in ieee80211_tkip_decrypt_data()
269 (iv32 < key->u.tkip.rx[queue].iv32 || in ieee80211_tkip_decrypt_data()
270 (iv32 == key->u.tkip.rx[queue].iv32 && in ieee80211_tkip_decrypt_data()
271 iv16 <= key->u.tkip.rx[queue].iv16))) in ieee80211_tkip_decrypt_data()
276 key->u.tkip.rx[queue].state = TKIP_STATE_PHASE1_HW_UPLOADED; in ieee80211_tkip_decrypt_data()
280 if (key->u.tkip.rx[queue].state == TKIP_STATE_NOT_INIT || in ieee80211_tkip_decrypt_data()
281 key->u.tkip.rx[queue].iv32 != iv32) { in ieee80211_tkip_decrypt_data()
283 tkip_mixing_phase1(tk, &key->u.tkip.rx[queue], ta, iv32); in ieee80211_tkip_decrypt_data()
287 key->u.tkip.rx[queue].state != TKIP_STATE_PHASE1_HW_UPLOADED) { in ieee80211_tkip_decrypt_data()
294 iv32, key->u.tkip.rx[queue].p1k); in ieee80211_tkip_decrypt_data()
[all …]
Dwpa.h19 ieee80211_rx_h_michael_mic_verify(struct ieee80211_rx_data *rx);
24 ieee80211_crypto_tkip_decrypt(struct ieee80211_rx_data *rx);
29 ieee80211_crypto_ccmp_decrypt(struct ieee80211_rx_data *rx);
34 ieee80211_crypto_aes_cmac_decrypt(struct ieee80211_rx_data *rx);
DMakefile10 ht.o agg-tx.o agg-rx.o \
20 rx.o \
Dmain.c394 .rx = BIT(IEEE80211_STYPE_ACTION >> 4) |
401 .rx = BIT(IEEE80211_STYPE_ACTION >> 4) |
406 .rx = BIT(IEEE80211_STYPE_ASSOC_REQ >> 4) |
417 .rx = BIT(IEEE80211_STYPE_ASSOC_REQ >> 4) |
427 .rx = BIT(IEEE80211_STYPE_ACTION >> 4) |
432 .rx = BIT(IEEE80211_STYPE_ASSOC_REQ >> 4) |
442 .rx = BIT(IEEE80211_STYPE_ACTION >> 4) |
448 .rx = BIT(IEEE80211_STYPE_ACTION >> 4) |
Dtrace.h1101 TP_PROTO(struct ieee80211_local *local, u32 tx, u32 rx),
1103 TP_ARGS(local, tx, rx),
1108 __field(u32, rx)
1114 __entry->rx = rx;
1119 LOCAL_PR_ARG, __entry->tx, __entry->rx
1125 u32 *rx, u32 *rx_max),
1127 TP_ARGS(local, tx, tx_max, rx, rx_max),
1133 __field(u32, rx)
1141 __entry->rx = *rx;
1148 __entry->tx, __entry->tx_max, __entry->rx, __entry->rx_max
Dwep.h30 ieee80211_crypto_wep_decrypt(struct ieee80211_rx_data *rx);
Dkey.c346 key->u.tkip.rx[i].iv32 = in ieee80211_key_alloc()
348 key->u.tkip.rx[i].iv16 = in ieee80211_key_alloc()
733 seq->tkip.iv32 = key->u.tkip.rx[tid].iv32; in ieee80211_get_key_rx_seq()
734 seq->tkip.iv16 = key->u.tkip.rx[tid].iv16; in ieee80211_get_key_rx_seq()
/net/dccp/
Dfeat.c41 static int dccp_hdlr_ccid(struct sock *sk, u64 ccid, bool rx) in dccp_hdlr_ccid() argument
44 struct ccid *new_ccid = ccid_new(ccid, sk, rx); in dccp_hdlr_ccid()
49 if (rx) { in dccp_hdlr_ccid()
59 static int dccp_hdlr_seq_win(struct sock *sk, u64 seq_win, bool rx) in dccp_hdlr_seq_win() argument
63 if (rx) { in dccp_hdlr_seq_win()
75 static int dccp_hdlr_ack_ratio(struct sock *sk, u64 ratio, bool rx) in dccp_hdlr_ack_ratio() argument
77 if (rx) in dccp_hdlr_ack_ratio()
84 static int dccp_hdlr_ackvec(struct sock *sk, u64 enable, bool rx) in dccp_hdlr_ackvec() argument
88 if (rx) { in dccp_hdlr_ackvec()
101 static int dccp_hdlr_ndp(struct sock *sk, u64 enable, bool rx) in dccp_hdlr_ndp() argument
[all …]
Dccid.c144 struct ccid *ccid_new(const u8 id, struct sock *sk, bool rx) in ccid_new() argument
152 ccid = kmem_cache_alloc(rx ? ccid_ops->ccid_hc_rx_slab : in ccid_new()
157 if (rx) { in ccid_new()
171 kmem_cache_free(rx ? ccid_ops->ccid_hc_rx_slab : in ccid_new()
/net/can/
Daf_can.c375 return &d->rx[RX_ERR]; in find_rcv_list()
391 return &d->rx[RX_INV]; in find_rcv_list()
395 return &d->rx[RX_ALL]; in find_rcv_list()
404 return &d->rx[RX_EFF]; in find_rcv_list()
413 return &d->rx[RX_FIL]; in find_rcv_list()
598 hlist_for_each_entry_rcu(r, &d->rx[RX_ERR], list) { in can_rcv_filter()
608 hlist_for_each_entry_rcu(r, &d->rx[RX_ALL], list) { in can_rcv_filter()
614 hlist_for_each_entry_rcu(r, &d->rx[RX_FIL], list) { in can_rcv_filter()
622 hlist_for_each_entry_rcu(r, &d->rx[RX_INV], list) { in can_rcv_filter()
634 hlist_for_each_entry_rcu(r, &d->rx[RX_EFF], list) { in can_rcv_filter()
Daf_can.h66 struct hlist_head rx[RX_MAX]; member
/net/wireless/
Dtrace.h1360 TP_PROTO(struct wiphy *wiphy, int ret, u32 tx, u32 rx),
1361 TP_ARGS(wiphy, ret, tx, rx),
1366 __field(u32, rx)
1372 __entry->rx = rx;
1375 WIPHY_PR_ARG, __entry->ret, __entry->tx, __entry->rx)
1380 u32 rx, u32 rx_max),
1381 TP_ARGS(wiphy, tx, tx_max, rx, rx_max),
1386 __field(u32, rx)
1393 __entry->rx = rx;
1397 WIPHY_PR_ARG, __entry->tx, __entry->tx_max, __entry->rx,
[all …]
/net/mac802154/
DMakefile2 mac802154-objs := ieee802154_dev.o rx.o tx.o mac_cmd.o mib.o monitor.o wpan.o
/net/core/
Dnetpoll.c542 list_for_each_entry_safe(np, tmp, &npinfo->rx_np, rx) { in netpoll_neigh_reply()
591 list_for_each_entry_safe(np, tmp, &npinfo->rx_np, rx) { in netpoll_neigh_reply()
679 list_for_each_entry_safe(np, tmp, &npinfo->rx_np, rx) { in netpoll_neigh_reply()
834 list_for_each_entry_safe(np, tmp, &npinfo->rx_np, rx) { in __netpoll_rx()
872 list_for_each_entry_safe(np, tmp, &npinfo->rx_np, rx) { in __netpoll_rx()
1073 list_add_tail(&np->rx, &npinfo->rx_np); in __netpoll_setup()
1253 list_del(&np->rx); in __netpoll_cleanup()

12