| /net/vmw_vsock/ |
| D | vmci_transport.c | 43 struct sock *pending,
482 struct sock *pending; in vmci_transport_get_pending() local
493 pending = sk_vsock(vpending); in vmci_transport_get_pending()
494 sock_hold(pending); in vmci_transport_get_pending()
499 pending = NULL; in vmci_transport_get_pending()
501 return pending; in vmci_transport_get_pending()
505 static void vmci_transport_release_pending(struct sock *pending) in vmci_transport_release_pending() argument
507 sock_put(pending); in vmci_transport_release_pending()
940 struct sock *pending; in vmci_transport_recv_listen() local
956 pending = vmci_transport_get_pending(sk, pkt); in vmci_transport_recv_listen()
[all …]
|
| D | af_vsock.c | 353 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
359 vpending = vsock_sk(pending); in vsock_add_pending()
361 sock_hold(pending); in vsock_add_pending()
367 void vsock_remove_pending(struct sock *listener, struct sock *pending) in vsock_remove_pending() argument
369 struct vsock_sock *vpending = vsock_sk(pending); in vsock_remove_pending()
373 sock_put(pending); in vsock_remove_pending()
757 struct sock *pending; in __vsock_release() local
761 pending = NULL; /* Compiler warning. */ in __vsock_release()
781 while ((pending = vsock_dequeue_accept(sk)) != NULL) { in __vsock_release()
782 __vsock_release(pending, SINGLE_DEPTH_NESTING); in __vsock_release()
[all …]
|
| /net/tipc/ |
| D | crypto.c | 107 u8 pending:2, member
115 pending:2;
1167 if (key.pending) { in tipc_crypto_key_attach()
1168 if (tipc_aead_users(c->aead[key.pending]) > 0) in tipc_crypto_key_attach()
1172 new_key = key.pending; in tipc_crypto_key_attach()
1180 key.pending = pos; in tipc_crypto_key_attach()
1185 key.pending = key_next(key.active ?: key.passive); in tipc_crypto_key_attach()
1186 new_key = key.pending; in tipc_crypto_key_attach()
1195 key.pending); in tipc_crypto_key_attach()
1262 if (key.pending == new_pending) { in tipc_crypto_key_try_align()
[all …]
|
| D | group.c | 82 struct list_head pending; member
177 INIT_LIST_HEAD(&grp->pending); in tipc_group_create()
612 list_add_tail(&m->list, &grp->pending); in tipc_group_update_rcv_win()
627 pm = list_first_entry(&grp->pending, struct tipc_member, list); in tipc_group_update_rcv_win()
649 if (list_empty(&grp->pending)) in tipc_group_update_rcv_win()
653 pm = list_first_entry(&grp->pending, struct tipc_member, list); in tipc_group_update_rcv_win()
838 if (list_empty(&grp->pending)) in tipc_group_proto_rcv()
840 pm = list_first_entry(&grp->pending, struct tipc_member, list); in tipc_group_proto_rcv()
|
| /net/ipv4/ |
| D | tcp_dctcp.h | 29 if (inet_csk(sk)->icsk_ack.pending & ICSK_ACK_TIMER) { in dctcp_ece_ack_update()
33 inet_csk(sk)->icsk_ack.pending |= ICSK_ACK_NOW; in dctcp_ece_ack_update()
|
| D | bpf_tcp_ca.c | 116 case offsetof(struct inet_connection_sock, icsk_ack.pending): in bpf_tcp_ca_btf_struct_access()
118 icsk_ack.pending); in bpf_tcp_ca_btf_struct_access()
|
| D | udp.c | 809 if (up->pending) { in udp_flush_pending_frames()
811 up->pending = 0; in udp_flush_pending_frames()
998 up->pending = 0; in udp_push_pending_frames()
1075 if (up->pending) { in udp_sendmsg()
1081 if (likely(up->pending)) { in udp_sendmsg()
1082 if (unlikely(up->pending != AF_INET)) { in udp_sendmsg()
1259 if (unlikely(up->pending)) { in udp_sendmsg()
1276 up->pending = AF_INET; in udp_sendmsg()
1288 up->pending = 0; in udp_sendmsg()
1331 if (!up->pending) { in udp_sendpage()
[all …]
|
| D | tcp_timer.c | 296 !(icsk->icsk_ack.pending & ICSK_ACK_TIMER)) in tcp_delack_timer_handler()
303 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER; in tcp_delack_timer_handler()
|
| D | inet_connection_sock.c | 567 icsk->icsk_pending = icsk->icsk_ack.pending = 0; in inet_csk_init_xmit_timers()
575 icsk->icsk_pending = icsk->icsk_ack.pending = 0; in inet_csk_clear_xmit_timers()
|
| /net/bluetooth/rfcomm/ |
| D | tty.c | 69 struct sk_buff_head pending; member
274 skb_queue_head_init(&dev->pending); in __rfcomm_dev_add()
288 skb_queue_tail(&dev->pending, skb); in __rfcomm_dev_add()
356 int pending = 40 - atomic_read(&dev->wmem_alloc); in rfcomm_room() local
358 return max(0, pending) * dlc->mtu; in rfcomm_room()
611 if (!skb_queue_empty(&dev->pending)) { in rfcomm_dev_data_ready()
612 skb_queue_tail(&dev->pending, skb); in rfcomm_dev_data_ready()
669 while ((skb = skb_dequeue(&dev->pending))) { in rfcomm_tty_copy_pending()
|
| /net/ipv6/ |
| D | udp.c | 1105 if (up->pending == AF_INET) in udp_v6_flush_pending_frames()
1107 else if (up->pending) { in udp_v6_flush_pending_frames()
1109 up->pending = 0; in udp_v6_flush_pending_frames()
1277 if (up->pending == AF_INET) in udp_v6_push_pending_frames()
1293 up->pending = 0; in udp_v6_push_pending_frames()
1349 } else if (!up->pending) { in udpv6_sendmsg()
1373 if (up->pending == AF_INET) in udpv6_sendmsg()
1383 if (up->pending) { in udpv6_sendmsg()
1389 if (likely(up->pending)) { in udpv6_sendmsg()
1390 if (unlikely(up->pending != AF_INET6)) { in udpv6_sendmsg()
[all …]
|
| /net/sunrpc/ |
| D | xprt.c | 566 rpc_wake_up_status(&xprt->pending, status); in xprt_wake_pending_tasks()
568 rpc_wake_up(&xprt->pending); in xprt_wake_pending_tasks()
745 rpc_wake_up_queued_task_set_status(&xprt->pending, in xprt_schedule_autoclose_locked()
891 rpc_sleep_on_timeout(&xprt->pending, task, NULL, in xprt_connect()
905 rpc_wake_up_queued_task(&xprt->pending, task); in xprt_connect()
1179 rpc_wake_up_queued_task(&xprt->pending, task); in xprt_complete_rqst()
1212 rpc_sleep_on_timeout(&req->rq_xprt->pending, task, xprt_timer, in xprt_wait_for_reply_request_def()
1237 rpc_sleep_on_timeout(&req->rq_xprt->pending, task, xprt_timer, in xprt_wait_for_reply_request_rtt()
1268 rpc_wake_up_queued_task_set_status(&xprt->pending, in xprt_request_wait_receive()
1519 xprt->stat.pending_u += xprt->pending.qlen; in xprt_request_transmit()
[all …]
|
| D | cache.c | 718 struct list_head pending; in cache_revisit_request() local
722 INIT_LIST_HEAD(&pending); in cache_revisit_request()
728 list_add(&dreq->recent, &pending); in cache_revisit_request()
733 while (!list_empty(&pending)) { in cache_revisit_request()
734 dreq = list_entry(pending.next, struct cache_deferred_req, recent); in cache_revisit_request()
743 struct list_head pending; in cache_clean_deferred() local
746 INIT_LIST_HEAD(&pending); in cache_clean_deferred()
752 list_add(&dreq->recent, &pending); in cache_clean_deferred()
757 while (!list_empty(&pending)) { in cache_clean_deferred()
758 dreq = list_entry(pending.next, struct cache_deferred_req, recent); in cache_clean_deferred()
|
| /net/tls/ |
| D | tls_sw.c | 172 int pending; in tls_decrypt_done() local
220 pending = atomic_dec_return(&ctx->decrypt_pending); in tls_decrypt_done()
222 if (!pending && ctx->async_notify) in tls_decrypt_done()
447 int pending; in tls_encrypt_done() local
483 pending = atomic_dec_return(&ctx->encrypt_pending); in tls_encrypt_done()
485 if (!pending && ctx->async_notify) in tls_encrypt_done()
946 int pending; in tls_sw_sendmsg() local
1119 pending = atomic_read(&ctx->encrypt_pending); in tls_sw_sendmsg()
1121 if (pending) in tls_sw_sendmsg()
1757 int num_async, pending; in tls_sw_recvmsg() local
[all …]
|
| /net/dccp/ |
| D | timer.c | 186 !(icsk->icsk_ack.pending & ICSK_ACK_TIMER)) in dccp_delack_timer()
194 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER; in dccp_delack_timer()
|
| D | output.c | 610 if (icsk->icsk_ack.pending & ICSK_ACK_TIMER) {
624 icsk->icsk_ack.pending |= ICSK_ACK_SCHED | ICSK_ACK_TIMER;
|
| /net/mac80211/ |
| D | sta_info.c | 145 ieee80211_purge_tx_queue(&local->hw, &tid_tx->pending); in __cleanup_single_sta()
1311 struct sk_buff_head pending; in ieee80211_sta_ps_deliver_wakeup() local
1343 skb_queue_head_init(&pending); in ieee80211_sta_ps_deliver_wakeup()
1349 int count = skb_queue_len(&pending), tmp; in ieee80211_sta_ps_deliver_wakeup()
1352 skb_queue_splice_tail_init(&sta->tx_filtered[ac], &pending); in ieee80211_sta_ps_deliver_wakeup()
1354 tmp = skb_queue_len(&pending); in ieee80211_sta_ps_deliver_wakeup()
1359 skb_queue_splice_tail_init(&sta->ps_tx_buf[ac], &pending); in ieee80211_sta_ps_deliver_wakeup()
1361 tmp = skb_queue_len(&pending); in ieee80211_sta_ps_deliver_wakeup()
1365 ieee80211_add_pending_skbs(local, &pending); in ieee80211_sta_ps_deliver_wakeup()
1627 struct sk_buff_head pending; in ieee80211_sta_ps_deliver_response() local
[all …]
|
| D | agg-tx.c | 255 if (!skb_queue_empty(&tid_tx->pending)) { in __acquires()
258 skb_queue_splice_tail_init(&tid_tx->pending, in __acquires()
259 &local->pending[queue]); in __acquires()
701 skb_queue_head_init(&tid_tx->pending); in ieee80211_start_tx_ba_session()
|
| D | tx.c | 1144 __skb_queue_tail(&tid_tx->pending, skb); in ieee80211_tx_prep_agg()
1145 if (skb_queue_len(&tid_tx->pending) > STA_MAX_TX_BUFFER) in ieee80211_tx_prep_agg()
1146 purge_skb = __skb_dequeue(&tid_tx->pending); in ieee80211_tx_prep_agg()
1656 (!txpending && !skb_queue_empty(&local->pending[q]))) { in ieee80211_tx_frags()
1683 &local->pending[q]); in ieee80211_tx_frags()
1686 &local->pending[q]); in ieee80211_tx_frags()
4222 (!txpending && !skb_queue_empty(&local->pending[q]))) { in ieee80211_tx_8023()
4224 skb_queue_head(&local->pending[q], skb); in ieee80211_tx_8023()
4226 skb_queue_tail(&local->pending[q], skb); in ieee80211_tx_8023()
4402 while ((skb = skb_dequeue(&local->pending[i])) != NULL) in ieee80211_clear_tx_pending()
[all …]
|
| D | debugfs.c | 462 ln = skb_queue_len(&local->pending[i]); in misc_read()
484 skb_queue_len(&local->pending[q])); in queues_read()
|
| D | iface.c | 569 skb_queue_walk_safe(&local->pending[i], skb, tmp) { in ieee80211_do_stop()
572 __skb_unlink(skb, &local->pending[i]); in ieee80211_do_stop()
1286 skb_queue_empty(&local->pending[sdata->vif.cab_queue]))) { in ieee80211_do_open()
1291 skb_queue_empty(&local->pending[ac_queue])) in ieee80211_do_open()
|
| D | sta_info.h | 184 struct sk_buff_head pending; member
|
| /net/qrtr/ |
| D | af_qrtr.c | 145 int pending; member
229 flow->pending = 0; in qrtr_tx_resume()
284 flow->pending < QRTR_TX_FLOW_HIGH || in qrtr_tx_wait()
295 flow->pending++; in qrtr_tx_wait()
296 confirm_rx = flow->pending == QRTR_TX_FLOW_LOW; in qrtr_tx_wait()
|
| /net/nfc/ |
| D | digital_core.c | 31 u8 pending; member
165 if (!cmd || cmd->pending) { in digital_wq_cmd()
170 cmd->pending = 1; in digital_wq_cmd()
|
| /net/mptcp/ |
| D | options.c | 377 WARN_ON_ONCE(icsk->icsk_ack.pending & ICSK_ACK_TIMER); in schedule_3rdack_retransmission()
378 icsk->icsk_ack.pending |= ICSK_ACK_SCHED | ICSK_ACK_TIMER; in schedule_3rdack_retransmission()
390 icsk->icsk_ack.pending &= ~(ICSK_ACK_SCHED | ICSK_ACK_TIMER); in clear_3rdack_retransmission()
|