Searched refs:pending (Results 1 - 25 of 30) sorted by relevance

12

/net/vmw_vsock/
H A Dvmci_transport.c54 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 Daf_vsock.c41 * 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 Daf_netlink.h21 atomic_t pending; member in struct:netlink_ring
H A Daf_netlink.c385 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 Dsend.c583 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 Dxprt.c19 * 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 Dcache.c243 * -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 Dclnt.c1880 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 Dtty.c69 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 Dtimer.c211 !(icsk->icsk_ack.pending & ICSK_ACK_TIMER))
219 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER;
H A Doutput.c294 * 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 Dudp.c951 * 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 Dsta_info.c144 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 Dtx.c98 * 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 Dagg-tx.c197 * 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 Dsta_info.h64 * 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 Diface.c713 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 Ddebugfs.c337 skb_queue_len(&local->pending[q]));
H A Dutil.c314 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 Ddebugfs_sta.c189 tid_tx ? skb_queue_len(&tid_tx->pending) : 0);
/net/ipv4/
H A Dudp.c686 * 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 Dtcp_timer.c210 if (sk->sk_state == TCP_CLOSE || !(icsk->icsk_ack.pending & ICSK_ACK_TIMER))
217 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER;
H A Dinet_connection_sock.c303 * 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 Dtcp.c1429 ((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 Ddigital_core.c36 u8 pending; member in struct:digital_cmd
170 if (!cmd || cmd->pending) {

Completed in 1018 milliseconds

12