/net/rxrpc/ |
H A D | ar-recvmsg.c | 23 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 D | ar-security.c | 167 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 D | ar-accept.c | 74 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 D | ar-input.c | 46 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 D | ar-call.c | 252 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 D | ar-connection.c | 69 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 D | ar-output.c | 27 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 D | af_rxrpc.c | 80 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 D | ar-key.c | 889 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 D | ccid.c | 144 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 D | proto.c | 431 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 D | feat.c | 41 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 D | wep.c | 275 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 D | key.h | 73 struct tkip_ctx rx[IEEE80211_NUM_TIDS]; member in struct:ieee80211_key::__anon77::__anon78
|
H A D | wpa.c | 85 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 D | driver-ops.h | 831 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 D | rx.c | 488 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 D | spi.c | 186 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 D | af_can.h | 49 /* 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 D | xfrm_state.c | 890 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 D | dev.c | 1264 /* 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;
|