/net/vmw_vsock/ |
H A D | vmci_transport.c | 54 struct sock *pending, 474 struct sock *pending; local 485 pending = sk_vsock(vpending); 486 sock_hold(pending); 491 pending = NULL; 493 return pending; 497 static void vmci_transport_release_pending(struct sock *pending) argument 499 sock_put(pending); 926 /* Processing of pending connections for servers goes through 957 struct sock *pending; local 1138 vmci_transport_recv_connecting_server(struct sock *listener, struct sock *pending, struct vmci_transport_packet *pkt) argument [all...] |
H A D | af_vsock.c | 41 * new socket and refer to it as a pending socket. These pending sockets are 42 * placed on the pending connection list of the listener socket. When future 44 * check if the source of the packet is from one that has an existing pending 45 * connection. If it does, we process the packet for the pending socket. When 47 * socket's pending list and enqueued in the listener socket's accept queue. 53 * - It is possible that these pending sockets will never reach the connected 71 * and the listener socket's pending list and connected queue) ensures a 357 void vsock_add_pending(struct sock *listener, struct sock *pending) argument 363 vpending = vsock_sk(pending); 371 vsock_remove_pending(struct sock *listener, struct sock *pending) argument 649 struct sock *pending; local [all...] |
/net/netlink/ |
H A D | af_netlink.h | 21 atomic_t pending; member in struct:netlink_ring
|
H A D | af_netlink.c | 385 if (atomic_read(&ring->pending)) 739 atomic_read(&nlk->tx_ring.pending)) 761 atomic_inc(&ring->pending); 798 atomic_read(&nlk->tx_ring.pending))); 886 WARN_ON(atomic_read(&ring->pending) == 0); 887 atomic_dec(&ring->pending); 1841 atomic_inc(&ring->pending); 2717 * on the pending state in netlink_mmap_sendmsg() while the CB hold
|
/net/batman-adv/ |
H A D | send.c | 583 bool pending; local 609 pending = cancel_delayed_work_sync(&forw_packet->delayed_work); 612 if (pending) { 636 pending = cancel_delayed_work_sync(&forw_packet->delayed_work); 639 if (pending) {
|
/net/sunrpc/ |
H A D | xprt.c | 19 * pending requests for that transport. If a matching XID is found, the 466 * xprt_wake_pending_tasks - wake all tasks on a transport's pending queue 474 rpc_wake_up_status(&xprt->pending, status); 476 rpc_wake_up(&xprt->pending); 495 rpc_sleep_on(&xprt->pending, task, action); 511 rpc_wake_up_queued_task(&xprt->pending, xprt->snd_task); 718 rpc_sleep_on(&xprt->pending, task, xprt_connect_status); 825 rpc_wake_up_queued_task(&xprt->pending, task); 875 rpc_sleep_on(&xprt->pending, task, xprt_timer); 947 xprt->stat.pending_u += xprt->pending [all...] |
H A D | cache.c | 243 * -EAGAIN if upcall is pending and request has been queued 505 * If a cache lookup finds a pending entry, we 662 struct list_head pending; local 666 INIT_LIST_HEAD(&pending); 672 list_add(&dreq->recent, &pending); 677 while (!list_empty(&pending)) { 678 dreq = list_entry(pending.next, struct cache_deferred_req, recent); 687 struct list_head pending; local 690 INIT_LIST_HEAD(&pending); 696 list_add(&dreq->recent, &pending); [all...] |
H A D | clnt.c | 1880 rpc_wake_up_queued_task(&task->tk_rqstp->rq_xprt->pending, task); 1994 rpc_wake_up_queued_task(&req->rq_xprt->pending, task);
|
/net/bluetooth/rfcomm/ |
H A D | tty.c | 69 struct sk_buff_head pending; member in struct:rfcomm_dev 274 skb_queue_head_init(&dev->pending); 288 skb_queue_tail(&dev->pending, skb); 356 int pending = 40 - atomic_read(&dev->wmem_alloc); local 358 return max(0, pending) * dlc->mtu; 613 if (!skb_queue_empty(&dev->pending)) { 614 skb_queue_tail(&dev->pending, skb); 671 while ((skb = skb_dequeue(&dev->pending))) {
|
/net/dccp/ |
H A D | timer.c | 211 !(icsk->icsk_ack.pending & ICSK_ACK_TIMER)) 219 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER;
|
H A D | output.c | 294 * currently pending header options, thus clearing the backlog. 608 if (icsk->icsk_ack.pending & ICSK_ACK_TIMER) { 622 icsk->icsk_ack.pending |= ICSK_ACK_SCHED | ICSK_ACK_TIMER;
|
/net/ipv6/ |
H A D | udp.c | 951 * Throw away all pending data and cancel the corking. Socket is locked. 957 if (up->pending == AF_INET) 959 else if (up->pending) { 961 up->pending = 0; 1022 if (up->pending == AF_INET) 1071 up->pending = 0; 1120 } else if (!up->pending) { 1142 if (up->pending == AF_INET) 1151 if (up->pending) { 1153 * There are pending frame [all...] |
/net/mac80211/ |
H A D | sta_info.c | 144 ieee80211_purge_tx_queue(&local->hw, &tid_tx->pending); 1093 struct sk_buff_head pending; local 1117 skb_queue_head_init(&pending); 1123 int count = skb_queue_len(&pending), tmp; 1126 skb_queue_splice_tail_init(&sta->tx_filtered[ac], &pending); 1128 tmp = skb_queue_len(&pending); 1133 skb_queue_splice_tail_init(&sta->ps_tx_buf[ac], &pending); 1135 tmp = skb_queue_len(&pending); 1139 ieee80211_add_pending_skbs(local, &pending); 1365 struct sk_buff_head pending; local [all...] |
H A D | tx.c | 98 * RTS: time needed to transmit pending data/mgmt frame plus 498 * been queued to pending queue. No reordering can happen, go 940 * but store it away as pending. 1071 * packets are spliced over to the driver pending 1096 __skb_queue_tail(&tid_tx->pending, skb); 1097 if (skb_queue_len(&tid_tx->pending) > STA_MAX_TX_BUFFER) 1098 purge_skb = __skb_dequeue(&tid_tx->pending); 1222 (!txpending && !skb_queue_empty(&local->pending[q]))) { 1244 * later transmission from the tx-pending 1249 &local->pending[ [all...] |
H A D | agg-tx.c | 197 * splice packets from the STA's pending to the local pending, 211 "TID %d gone but expected when splicing aggregates from the pending queue\n", 215 if (!skb_queue_empty(&tid_tx->pending)) { 218 skb_queue_splice_tail_init(&tid_tx->pending, 219 &local->pending[queue]); 245 * guaranteeing that no packets go to the tid_tx pending queue any 326 * to the driver but are put onto tid_tx->pending instead, 356 * We may have pending packets get stuck in this case... 364 * seem like we can leave the tid_tx data pending foreve [all...] |
H A D | sta_info.h | 64 * until pending frames are delivered 117 * @pending: pending frames queue -- use sta's spinlock to protect 141 struct sk_buff_head pending; member in struct:tid_ampdu_tx
|
H A D | iface.c | 713 skb_queue_empty(&local->pending[sdata->vif.cab_queue]))) { 718 skb_queue_empty(&local->pending[ac_queue])) 947 skb_queue_walk_safe(&local->pending[i], skb, tmp) { 950 __skb_unlink(skb, &local->pending[i]);
|
H A D | debugfs.c | 337 skb_queue_len(&local->pending[q]));
|
H A D | util.c | 314 skb_queue_empty(&local->pending[ac_queue]))) 346 if (skb_queue_empty(&local->pending[queue])) { 450 __skb_queue_tail(&local->pending[queue], skb); 479 __skb_queue_tail(&local->pending[queue], skb);
|
H A D | debugfs_sta.c | 189 tid_tx ? skb_queue_len(&tid_tx->pending) : 0);
|
/net/ipv4/ |
H A D | udp.c | 686 * Throw away all pending data and cancel the corking. Socket is locked. 692 if (up->pending) { 694 up->pending = 0; 840 * Push out all pending data as one UDP datagram. Socket is locked. 858 up->pending = 0; 902 if (up->pending) { 904 * There are pending frames. 908 if (likely(up->pending)) { 909 if (unlikely(up->pending != AF_INET)) { 1050 if (unlikely(up->pending)) { [all...] |
H A D | tcp_timer.c | 210 if (sk->sk_state == TCP_CLOSE || !(icsk->icsk_ack.pending & ICSK_ACK_TIMER)) 217 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER;
|
H A D | inet_connection_sock.c | 303 * and that it has something pending. 370 icsk->icsk_pending = icsk->icsk_ack.pending = 0; 378 icsk->icsk_pending = icsk->icsk_ack.pending = icsk->icsk_ack.blocked = 0;
|
H A D | tcp.c | 1429 ((icsk->icsk_ack.pending & ICSK_ACK_PUSHED2) || 1430 ((icsk->icsk_ack.pending & ICSK_ACK_PUSHED) && 1655 /* Are we at urgent data? Stop if we have read anything or have SIGURG pending. */ 2488 * any pending partial frames in the queue. This is 2579 icsk->icsk_ack.pending |= ICSK_ACK_PUSHED;
|
/net/nfc/ |
H A D | digital_core.c | 36 u8 pending; member in struct:digital_cmd 170 if (!cmd || cmd->pending) {
|