Home
last modified time | relevance | path

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

123

/net/rxrpc/
A Daf_rxrpc.c145 lock_sock(&rx->sk); in rxrpc_bind()
149 rx->srx = *srx; in rxrpc_bind()
150 local = rxrpc_lookup_local(sock_net(&rx->sk), &rx->srx); in rxrpc_bind()
219 lock_sock(&rx->sk); in rxrpc_listen()
363 key = rx->key; in rxrpc_kernel_begin_call()
562 rx->srx.transport.family = rx->family; in rxrpc_sendmsg()
656 if (rx->key) in rxrpc_setsockopt()
666 if (rx->key) in rxrpc_setsockopt()
847 memset(&rx->srx, 0, sizeof(rx->srx)); in rxrpc_create()
956 if (rx->local && rx->local->service == rx) { in rxrpc_release_sock()
[all …]
A Dcall_accept.c48 tmp = rx->sk.sk_ack_backlog; in rxrpc_service_prealloc_one()
110 pp = &rx->calls.rb_node; in rxrpc_service_prealloc_one()
125 if (rx->app_ops && in rxrpc_service_prealloc_one()
170 rx->backlog = b; in rxrpc_service_prealloc()
187 rx->backlog = NULL; in rxrpc_discard_prealloc()
224 if (rx->app_ops && in rxrpc_discard_prealloc()
344 struct rxrpc_sock *rx; in rxrpc_new_incoming_call() local
358 rx = local->service; in rxrpc_new_incoming_call()
359 if (!rx || (sp->hdr.serviceId != rx->srx.srx_service && in rxrpc_new_incoming_call()
396 if (rx->app_ops && in rxrpc_new_incoming_call()
[all …]
A Drecvmsg.c25 struct rxrpc_sock *rx; in rxrpc_notify_socket() local
40 sk = &rx->sk; in rxrpc_notify_socket()
339 if (!rx->app_ops && in rxrpc_recvmsg_data()
387 lock_sock(&rx->sk); in rxrpc_recvmsg()
394 release_sock(&rx->sk); in rxrpc_recvmsg()
405 release_sock(&rx->sk); in rxrpc_recvmsg()
428 release_sock(&rx->sk); in rxrpc_recvmsg()
440 l = rx->recvmsg_q.next; in rxrpc_recvmsg()
448 release_sock(&rx->sk); in rxrpc_recvmsg()
485 release_sock(&rx->sk); in rxrpc_recvmsg()
[all …]
A Doob.c38 struct rxrpc_sock *rx; in rxrpc_notify_socket_oob() local
43 rx = rcu_dereference(call->socket); in rxrpc_notify_socket_oob()
44 if (rx) { in rxrpc_notify_socket_oob()
45 sk = &rx->sk; in rxrpc_notify_socket_oob()
46 spin_lock_irq(&rx->recvmsg_lock); in rxrpc_notify_socket_oob()
54 if (rx->app_ops) in rxrpc_notify_socket_oob()
55 rx->app_ops->notify_oob(sk, skb); in rxrpc_notify_socket_oob()
74 p = rx->pending_oobq.rb_node; in rxrpc_find_pending_oob()
185 release_sock(&rx->sk); in rxrpc_respond_to_oob()
236 release_sock(&rx->sk); in rxrpc_sendmsg_oob()
[all …]
A Dcall_object.c93 read_lock(&rx->call_lock); in rxrpc_find_call_by_user_ID()
95 p = rx->calls.rb_node; in rxrpc_find_call_by_user_ID()
107 read_unlock(&rx->call_lock); in rxrpc_find_call_by_user_ID()
136 if (rx->sk.sk_kern_sock) in rxrpc_alloc_call()
337 release_sock(&rx->sk); in rxrpc_new_client_call()
343 release_sock(&rx->sk); in rxrpc_new_client_call()
349 release_sock(&rx->sk); in rxrpc_new_client_call()
363 pp = &rx->calls.rb_node; in rxrpc_new_client_call()
393 release_sock(&rx->sk); in rxrpc_new_client_call()
412 release_sock(&rx->sk); in rxrpc_new_client_call()
[all …]
A Dsendmsg.c327 struct sock *sk = &rx->sk; in rxrpc_send_data()
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()
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()
721 release_sock(&rx->sk); in rxrpc_do_sendmsg()
[all …]
A Dserver_key.c121 int rxrpc_server_keyring(struct rxrpc_sock *rx, sockptr_t optval, int optlen) in rxrpc_server_keyring() argument
142 rx->securities = key; in rxrpc_server_keyring()
160 struct rxrpc_sock *rx = rxrpc_sk(sk); in rxrpc_sock_set_security_keyring() local
164 if (rx->securities) in rxrpc_sock_set_security_keyring()
166 else if (rx->sk.sk_state != RXRPC_UNBOUND) in rxrpc_sock_set_security_keyring()
169 rx->securities = key_get(keyring); in rxrpc_sock_set_security_keyring()
201 struct rxrpc_sock *rx = rxrpc_sk(sk); in rxrpc_sock_set_manage_response() local
205 ret = !!test_bit(RXRPC_SOCK_MANAGE_RESPONSE, &rx->flags); in rxrpc_sock_set_manage_response()
207 set_bit(RXRPC_SOCK_MANAGE_RESPONSE, &rx->flags); in rxrpc_sock_set_manage_response()
209 clear_bit(RXRPC_SOCK_MANAGE_RESPONSE, &rx->flags); in rxrpc_sock_set_manage_response()
A Dsecurity.c133 const struct rxrpc_security *rxrpc_get_incoming_security(struct rxrpc_sock *rx, in rxrpc_get_incoming_security() argument
149 !rx->securities) { in rxrpc_get_incoming_security()
166 struct rxrpc_sock *rx; in rxrpc_look_up_server_security() local
186 rx = conn->local->service; in rxrpc_look_up_server_security()
187 if (!rx) in rxrpc_look_up_server_security()
191 kref = keyring_search(make_key_ref(rx->securities, 1UL), in rxrpc_look_up_server_security()
A Dconn_service.c148 void rxrpc_new_incoming_connection(struct rxrpc_sock *rx, in rxrpc_new_incoming_connection() argument
174 conn->service_id == rx->service_upgrade.from) in rxrpc_new_incoming_connection()
175 conn->service_id = rx->service_upgrade.to; in rxrpc_new_incoming_connection()
A Dconn_event.c416 struct rxrpc_sock *rx; in rxrpc_post_challenge() local
432 rx = rcu_dereference(call->socket); in rxrpc_post_challenge()
433 if (!rx) { in rxrpc_post_challenge()
439 if (test_bit(RXRPC_SOCK_MANAGE_RESPONSE, &rx->flags)) in rxrpc_post_challenge()
/net/mac80211/
A Drx.c2309 rx->seqno_idx, &(rx->skb)); in ieee80211_rx_h_defragment()
3096 switch (ieee80211_rx_mesh_data(rx->sdata, rx->sta, rx->skb)) { in __ieee80211_rx_h_amsdu()
3193 rx->sdata->dev, rx->sta->sta.addr, rx->link_id, in ieee80211_rx_h_data()
3202 res = ieee80211_rx_mesh_data(rx->sdata, rx->sta, rx->skb); in ieee80211_rx_h_data()
3222 rx->sta, rx->skb); in ieee80211_rx_h_data()
3444 rx->skb->data, rx->skb->len, in ieee80211_rx_h_mgmt_check()
4200 return rx->link && rx->link_sta; in ieee80211_rx_data_set_link()
4224 rx->link = &rx->sdata->deflink; in ieee80211_rx_data_set_sta()
4929 res = ieee80211_rx_mesh_data(rx->sdata, rx->sta, rx->skb); in ieee80211_invoke_fast_rx()
5047 memset(&rx, 0, sizeof(rx)); in __ieee80211_rx_handle_8023()
[all …]
A Dwpa.c134 if (!rx->key || rx->key->conf.cipher != WLAN_CIPHER_SUITE_TKIP || in ieee80211_rx_h_michael_mic_verify()
138 if (rx->sdata->vif.type == NL80211_IFTYPE_AP && rx->key->conf.keyidx) { in ieee80211_rx_h_michael_mic_verify()
155 if (skb_linearize(rx->skb)) in ieee80211_rx_h_michael_mic_verify()
171 rx->key->u.tkip.rx[rx->security_idx].iv32 = rx->tkip.iv32; in ieee80211_rx_h_michael_mic_verify()
172 rx->key->u.tkip.rx[rx->security_idx].iv16 = rx->tkip.iv16; in ieee80211_rx_h_michael_mic_verify()
189 rx->key ? rx->key->conf.keyidx : -1, in ieee80211_rx_h_michael_mic_verify()
282 if (skb_linearize(rx->skb)) in ieee80211_crypto_tkip_decrypt()
298 &rx->tkip.iv32, in ieee80211_crypto_tkip_decrypt()
299 &rx->tkip.iv16); in ieee80211_crypto_tkip_decrypt()
555 queue = rx->security_idx; in ieee80211_crypto_ccmp_decrypt()
[all …]
A Dwpa.h17 ieee80211_rx_h_michael_mic_verify(struct ieee80211_rx_data *rx);
22 ieee80211_crypto_tkip_decrypt(struct ieee80211_rx_data *rx);
28 ieee80211_crypto_ccmp_decrypt(struct ieee80211_rx_data *rx,
36 ieee80211_crypto_aes_cmac_decrypt(struct ieee80211_rx_data *rx);
38 ieee80211_crypto_aes_cmac_256_decrypt(struct ieee80211_rx_data *rx);
42 ieee80211_crypto_aes_gmac_decrypt(struct ieee80211_rx_data *rx);
47 ieee80211_crypto_gcmp_decrypt(struct ieee80211_rx_data *rx);
A Dwep.c242 ieee80211_crypto_wep_decrypt(struct ieee80211_rx_data *rx) in ieee80211_crypto_wep_decrypt() argument
244 struct sk_buff *skb = rx->skb; in ieee80211_crypto_wep_decrypt()
253 if (skb_linearize(rx->skb)) in ieee80211_crypto_wep_decrypt()
255 if (ieee80211_wep_decrypt(rx->local, rx->skb, rx->key)) in ieee80211_crypto_wep_decrypt()
258 if (!pskb_may_pull(rx->skb, ieee80211_hdrlen(fc) + in ieee80211_crypto_wep_decrypt()
261 ieee80211_wep_remove_iv(rx->local, rx->skb, rx->key); in ieee80211_crypto_wep_decrypt()
264 pskb_trim(rx->skb, rx->skb->len - IEEE80211_WEP_ICV_LEN)) in ieee80211_crypto_wep_decrypt()
A DMakefile13 ht.o agg-tx.o agg-rx.o \
28 rx.o \
/net/tipc/
A Dcrypto.c1219 rx = c; in tipc_crypto_key_flush()
1335 skb_cb->tx_clone_ctx.rx = rx; in tipc_crypto_key_pick_tx()
1872 if (rx) { in tipc_crypto_rcv()
1878 rx->nokey = !(rx->skey || in tipc_crypto_rcv()
1881 rx->name, rx->nokey, in tipc_crypto_rcv()
1909 rx = skb_cb->tx_clone_ctx.rx; in tipc_crypto_rcv_complete()
1928 if (!rx) { in tipc_crypto_rcv_complete()
2003 if (rx) in tipc_crypto_rcv_complete()
2312 if (unlikely(rx->skey || (key_gen == rx->key_gen && rx->key.keys))) { in tipc_crypto_key_rcv()
2314 rx->skey, key_gen, rx->key_gen); in tipc_crypto_key_rcv()
[all …]
A Dcrypto.h162 void tipc_crypto_timeout(struct tipc_crypto *rx);
166 int tipc_crypto_rcv(struct net *net, struct tipc_crypto *rx,
/net/can/
A Disotp.c518 if (so->rx.len > so->rx.buflen && so->rx.buflen < max_pdu_size) { in isotp_rcv_ff()
527 if (so->rx.len > so->rx.buflen) { in isotp_rcv_ff()
536 so->rx.buf[so->rx.idx++] = cf->data[i]; in isotp_rcv_ff()
579 if (so->rx.len - so->rx.idx > so->rx.ll_dl - ae - N_PCI_SZ) in isotp_rcv_cf()
597 so->rx.buf[so->rx.idx++] = cf->data[i]; in isotp_rcv_cf()
598 if (so->rx.idx >= so->rx.len) in isotp_rcv_cf()
602 if (so->rx.idx >= so->rx.len) { in isotp_rcv_cf()
619 memcpy(skb_put(nskb, so->rx.len), so->rx.buf, in isotp_rcv_cf()
1233 if (so->rx.buf != so->rx.sbuf) in isotp_release()
1634 so->rx.buf = so->rx.sbuf; in isotp_init()
[all …]
A Daf_can.c375 return &dev_rcv_lists->rx[RX_ERR]; in can_rcv_list_find()
391 return &dev_rcv_lists->rx[RX_INV]; in can_rcv_list_find()
395 return &dev_rcv_lists->rx[RX_ALL]; in can_rcv_list_find()
410 return &dev_rcv_lists->rx[RX_FIL]; in can_rcv_list_find()
591 hlist_for_each_entry_rcu(rcv, &dev_rcv_lists->rx[RX_ERR], list) { in can_rcv_filter()
601 hlist_for_each_entry_rcu(rcv, &dev_rcv_lists->rx[RX_ALL], list) { in can_rcv_filter()
607 hlist_for_each_entry_rcu(rcv, &dev_rcv_lists->rx[RX_FIL], list) { in can_rcv_filter()
615 hlist_for_each_entry_rcu(rcv, &dev_rcv_lists->rx[RX_INV], list) { in can_rcv_filter()
/net/nfc/nci/
A Dspi.c180 struct spi_transfer tx, rx; in __nci_spi_read() local
196 rx.rx_buf = resp_hdr; in __nci_spi_read()
197 rx.len = 2; in __nci_spi_read()
198 rx.cs_change = 1; in __nci_spi_read()
199 rx.speed_hz = nspi->xfer_speed_hz; in __nci_spi_read()
200 spi_message_add_tail(&rx, &m); in __nci_spi_read()
219 rx.rx_buf = skb_put(skb, rx_len); in __nci_spi_read()
220 rx.len = rx_len; in __nci_spi_read()
221 rx.cs_change = 0; in __nci_spi_read()
224 rx.speed_hz = nspi->xfer_speed_hz; in __nci_spi_read()
[all …]
/net/mac80211/tests/
A Dmfp.c216 struct ieee80211_rx_data rx = { in accept_mfp() local
241 rx.skb = kunit_zalloc_skb(test, 128, GFP_KERNEL); in accept_mfp()
242 KUNIT_ASSERT_NOT_NULL(test, rx.skb); in accept_mfp()
243 status = IEEE80211_SKB_RXCB(rx.skb); in accept_mfp()
255 skb_put_data(rx.skb, &hdr, sizeof(hdr)); in accept_mfp()
259 skb_put_u8(rx.skb, params->category); in accept_mfp()
260 skb_put_u8(rx.skb, params->action); in accept_mfp()
266 skb_put_data(rx.skb, &reason, sizeof(reason)); in accept_mfp()
272 (__force u32)ieee80211_drop_unencrypted_mgmt(&rx), in accept_mfp()
/net/core/
A Dnetdev-genl.c601 if (netdev_stat_put(rsp, NETDEV_A_QSTATS_RX_PACKETS, rx->packets) || in netdev_nl_stats_write_rx()
602 netdev_stat_put(rsp, NETDEV_A_QSTATS_RX_BYTES, rx->bytes) || in netdev_nl_stats_write_rx()
644 struct netdev_queue_stats_rx rx; in netdev_nl_stats_queue() local
658 memset(&rx, 0xff, sizeof(rx)); in netdev_nl_stats_queue()
659 ops->get_queue_stats_rx(netdev, i, &rx); in netdev_nl_stats_queue()
660 if (!memchr_inv(&rx, 0xff, sizeof(rx))) in netdev_nl_stats_queue()
662 if (netdev_nl_stats_write_rx(rsp, &rx)) in netdev_nl_stats_queue()
742 struct netdev_queue_stats_rx rx; in netdev_stat_queue_sum() local
749 memset(&rx, 0xff, sizeof(rx)); in netdev_stat_queue_sum()
751 ops->get_queue_stats_rx(netdev, i, &rx); in netdev_stat_queue_sum()
[all …]
/net/smc/
A Dsmc_stats.h134 SMC_STAT_PAYLOAD_SUB(_smc_stats, SMC_TYPE_D, rx, _len, _rc); \
136 SMC_STAT_PAYLOAD_SUB(_smc_stats, SMC_TYPE_R, rx, _len, _rc); \
173 SMC_STAT_RMB_SIZE_SUB(_smc_stats, SMC_TYPE_D, rx, is_add, l); \
177 SMC_STAT_RMB_SIZE_SUB(_smc_stats, SMC_TYPE_R, rx, is_add, l); \
190 SMC_STAT_RMB_SUB(_smc_stats, type, SMC_TYPE_D, rx); \
194 SMC_STAT_RMB_SUB(_smc_stats, type, SMC_TYPE_R, rx); \
/net/xdp/
A Dxsk.c265 if (xskq_prod_nb_free(xs->rx, num_desc) < num_desc) { in __xsk_rcv()
338 xskq_prod_submit(xs->rx); in xsk_flush()
958 if (unlikely(!xs->rx)) in __xsk_recvmsg()
1009 if (xs->rx && !xskq_prod_is_empty(xs->rx)) in xsk_poll()
1121 xskq_destroy(xs->rx); in xsk_release()
1195 if (!xs->rx && !xs->tx) { in xsk_bind()
1370 q = (optname == XDP_TX_RING) ? &xs->tx : &xs->rx; in xsk_setsockopt()
1555 &off.rx); in xsk_getsockopt()
1562 off.rx.flags = offsetof(struct xdp_rxtx_ring, in xsk_getsockopt()
1574 xsk_enter_rxtx_offsets(&off_v1.rx); in xsk_getsockopt()
[all …]
A Dxsk_diag.c40 if (xs->rx) in xsk_diag_put_rings_cfg()
41 err = xsk_diag_put_ring(xs->rx, XDP_DIAG_RX_RING, nlskb); in xsk_diag_put_rings_cfg()
84 du.n_rx_invalid = xskq_nb_invalid_descs(xs->rx); in xsk_diag_put_stats()

Completed in 55 milliseconds

123