| /net/vmw_vsock/ |
| D | vmci_transport.c | 43 struct sock *pending,
484 struct sock *pending; in vmci_transport_get_pending() local
495 pending = sk_vsock(vpending); in vmci_transport_get_pending()
496 sock_hold(pending); in vmci_transport_get_pending()
501 pending = NULL; in vmci_transport_get_pending()
503 return pending; in vmci_transport_get_pending()
507 static void vmci_transport_release_pending(struct sock *pending) in vmci_transport_release_pending() argument
509 sock_put(pending); in vmci_transport_release_pending()
947 struct sock *pending; in vmci_transport_recv_listen() local
961 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()
790 struct sock *pending; in __vsock_release() local
794 pending = NULL; /* Compiler warning. */ in __vsock_release()
814 while ((pending = vsock_dequeue_accept(sk)) != NULL) { in __vsock_release()
815 __vsock_release(pending, SINGLE_DEPTH_NESTING); in __vsock_release()
[all …]
|
| /net/tipc/ |
| D | crypto.c | 107 u8 pending:2, member
115 pending:2;
1174 if (key.pending) { in tipc_crypto_key_attach()
1175 if (tipc_aead_users(c->aead[key.pending]) > 0) in tipc_crypto_key_attach()
1179 new_key = key.pending; in tipc_crypto_key_attach()
1187 key.pending = pos; in tipc_crypto_key_attach()
1192 key.pending = key_next(key.active ?: key.passive); in tipc_crypto_key_attach()
1193 new_key = key.pending; in tipc_crypto_key_attach()
1202 key.pending); in tipc_crypto_key_attach()
1269 if (key.pending == new_pending) { in tipc_crypto_key_try_align()
[all …]
|
| D | group.c | 83 struct list_head pending; member
178 INIT_LIST_HEAD(&grp->pending); in tipc_group_create()
613 list_add_tail(&m->list, &grp->pending); in tipc_group_update_rcv_win()
628 pm = list_first_entry(&grp->pending, struct tipc_member, list); in tipc_group_update_rcv_win()
650 if (list_empty(&grp->pending)) in tipc_group_update_rcv_win()
654 pm = list_first_entry(&grp->pending, struct tipc_member, list); in tipc_group_update_rcv_win()
839 if (list_empty(&grp->pending)) in tipc_group_proto_rcv()
841 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 | 121 case offsetof(struct inet_connection_sock, icsk_ack.pending): in bpf_tcp_ca_btf_struct_access()
123 icsk_ack.pending); in bpf_tcp_ca_btf_struct_access()
|
| D | udp.c | 823 if (up->pending) { in udp_flush_pending_frames()
825 up->pending = 0; in udp_flush_pending_frames()
1012 up->pending = 0; in udp_push_pending_frames()
1089 if (up->pending) { in udp_sendmsg()
1095 if (likely(up->pending)) { in udp_sendmsg()
1096 if (unlikely(up->pending != AF_INET)) { in udp_sendmsg()
1273 if (unlikely(up->pending)) { in udp_sendmsg()
1290 up->pending = AF_INET; in udp_sendmsg()
1302 up->pending = 0; in udp_sendmsg()
1345 if (!up->pending) { in udp_sendpage()
[all …]
|
| D | tcp_timer.c | 297 !(icsk->icsk_ack.pending & ICSK_ACK_TIMER)) in tcp_delack_timer_handler()
304 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER; in tcp_delack_timer_handler()
|
| /net/bluetooth/rfcomm/ |
| D | tty.c | 69 struct sk_buff_head pending; member
276 skb_queue_head_init(&dev->pending); in __rfcomm_dev_add()
290 skb_queue_tail(&dev->pending, skb); in __rfcomm_dev_add()
358 int pending = 40 - atomic_read(&dev->wmem_alloc); in rfcomm_room() local
360 return max(0, pending) * dlc->mtu; in rfcomm_room()
613 if (!skb_queue_empty(&dev->pending)) { in rfcomm_dev_data_ready()
614 skb_queue_tail(&dev->pending, skb); in rfcomm_dev_data_ready()
671 while ((skb = skb_dequeue(&dev->pending))) { in rfcomm_tty_copy_pending()
|
| /net/ipv6/ |
| D | udp.c | 1131 if (up->pending == AF_INET) in udp_v6_flush_pending_frames()
1133 else if (up->pending) { in udp_v6_flush_pending_frames()
1135 up->pending = 0; in udp_v6_flush_pending_frames()
1303 if (up->pending == AF_INET) in udp_v6_push_pending_frames()
1319 up->pending = 0; in udp_v6_push_pending_frames()
1375 } else if (!up->pending) { in udpv6_sendmsg()
1399 if (up->pending == AF_INET) in udpv6_sendmsg()
1409 if (up->pending) { in udpv6_sendmsg()
1415 if (likely(up->pending)) { in udpv6_sendmsg()
1416 if (unlikely(up->pending != AF_INET6)) { in udpv6_sendmsg()
[all …]
|
| /net/sunrpc/ |
| D | xprt.c | 596 rpc_wake_up_status(&xprt->pending, status); in xprt_wake_pending_tasks()
598 rpc_wake_up(&xprt->pending); in xprt_wake_pending_tasks()
775 rpc_wake_up_queued_task_set_status(&xprt->pending, in xprt_schedule_autoclose_locked()
934 rpc_sleep_on_timeout(&xprt->pending, task, NULL, in xprt_connect()
948 rpc_wake_up_queued_task(&xprt->pending, task); in xprt_connect()
1222 rpc_wake_up_queued_task(&xprt->pending, task); in xprt_complete_rqst()
1255 rpc_sleep_on_timeout(&req->rq_xprt->pending, task, xprt_timer, in xprt_wait_for_reply_request_def()
1280 rpc_sleep_on_timeout(&req->rq_xprt->pending, task, xprt_timer, in xprt_wait_for_reply_request_rtt()
1311 rpc_wake_up_queued_task_set_status(&xprt->pending, in xprt_request_wait_receive()
1566 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()
|
| D | sysfs.c | 142 xprt->sending.qlen, xprt->pending.qlen, in rpc_sysfs_xprt_info_show()
327 !xprt->pending.qlen && in rpc_sysfs_xprt_state_change()
|
| /net/tls/ |
| D | tls_sw.c | 177 int pending; in tls_decrypt_done() local
225 pending = atomic_dec_return(&ctx->decrypt_pending); in tls_decrypt_done()
227 if (!pending && ctx->async_notify) in tls_decrypt_done()
452 int pending; in tls_encrypt_done() local
488 pending = atomic_dec_return(&ctx->encrypt_pending); in tls_encrypt_done()
490 if (!pending && ctx->async_notify) in tls_encrypt_done()
952 int pending; in tls_sw_sendmsg() local
1125 pending = atomic_read(&ctx->encrypt_pending); in tls_sw_sendmsg()
1127 if (pending) in tls_sw_sendmsg()
1916 int 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 | 619 if (icsk->icsk_ack.pending & ICSK_ACK_TIMER) {
633 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()
1318 struct sk_buff_head pending; in ieee80211_sta_ps_deliver_wakeup() local
1350 skb_queue_head_init(&pending); in ieee80211_sta_ps_deliver_wakeup()
1356 int count = skb_queue_len(&pending), tmp; in ieee80211_sta_ps_deliver_wakeup()
1359 skb_queue_splice_tail_init(&sta->tx_filtered[ac], &pending); in ieee80211_sta_ps_deliver_wakeup()
1361 tmp = skb_queue_len(&pending); in ieee80211_sta_ps_deliver_wakeup()
1366 skb_queue_splice_tail_init(&sta->ps_tx_buf[ac], &pending); in ieee80211_sta_ps_deliver_wakeup()
1368 tmp = skb_queue_len(&pending); in ieee80211_sta_ps_deliver_wakeup()
1372 ieee80211_add_pending_skbs(local, &pending); in ieee80211_sta_ps_deliver_wakeup()
1634 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 | 1135 __skb_queue_tail(&tid_tx->pending, skb); in ieee80211_tx_prep_agg()
1136 if (skb_queue_len(&tid_tx->pending) > STA_MAX_TX_BUFFER) in ieee80211_tx_prep_agg()
1137 purge_skb = __skb_dequeue(&tid_tx->pending); in ieee80211_tx_prep_agg()
1672 (!txpending && !skb_queue_empty(&local->pending[q]))) { in ieee80211_tx_frags()
1699 &local->pending[q]); in ieee80211_tx_frags()
1702 &local->pending[q]); in ieee80211_tx_frags()
4417 (!txpending && !skb_queue_empty(&local->pending[q]))) { in ieee80211_tx_8023()
4419 skb_queue_head(&local->pending[q], skb); in ieee80211_tx_8023()
4421 skb_queue_tail(&local->pending[q], skb); in ieee80211_tx_8023()
4599 while ((skb = skb_dequeue(&local->pending[i])) != NULL) in ieee80211_clear_tx_pending()
[all …]
|
| D | debugfs.c | 561 ln = skb_queue_len(&local->pending[i]); in misc_read()
583 skb_queue_len(&local->pending[q])); in queues_read()
|
| D | iface.c | 560 skb_queue_walk_safe(&local->pending[i], skb, tmp) { in ieee80211_do_stop()
563 __skb_unlink(skb, &local->pending[i]); in ieee80211_do_stop()
1276 skb_queue_empty(&local->pending[sdata->vif.cab_queue]))) { in ieee80211_do_open()
1281 skb_queue_empty(&local->pending[ac_queue])) in ieee80211_do_open()
|
| /net/bluetooth/ |
| D | msft.c | 367 bool pending; in msft_le_cancel_monitor_advertisement_cb() local
398 pending = hci_remove_all_adv_monitor(hdev, &err); in msft_le_cancel_monitor_advertisement_cb()
399 if (pending) { in msft_le_cancel_monitor_advertisement_cb()
|
| D | hci_core.c | 3019 adv_instance->pending = true; in hci_add_adv_instance()
3223 bool pending; in hci_remove_single_adv_monitor() local
3230 pending = hci_remove_adv_monitor(hdev, monitor, handle, err); in hci_remove_single_adv_monitor()
3231 if (!*err && !pending) in hci_remove_single_adv_monitor()
3235 hdev->name, handle, *err, pending ? "" : "not "); in hci_remove_single_adv_monitor()
3237 return pending; in hci_remove_single_adv_monitor()
3247 bool pending = false; in hci_remove_all_adv_monitor() local
3252 while (!*err && !pending) { in hci_remove_all_adv_monitor()
3257 pending = hci_remove_adv_monitor(hdev, monitor, 0, err); in hci_remove_all_adv_monitor()
3259 if (!*err && !pending) in hci_remove_all_adv_monitor()
[all …]
|
| /net/qrtr/ |
| D | af_qrtr.c | 145 int pending; member
234 flow->pending = 0; in qrtr_tx_resume()
289 flow->pending < QRTR_TX_FLOW_HIGH || in qrtr_tx_wait()
300 flow->pending++; in qrtr_tx_wait()
301 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()
|