Searched refs:inputq (Results 1 – 9 of 9) sorted by relevance
| /linux-4.1.27/net/tipc/ |
| D | socket.h | 47 int tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq);
49 struct sk_buff_head *inputq);
|
| D | bcast.c | 73 tipc_sk_mcast_rcv(net, &tn->bclink->arrvq, &tn->bclink->inputq); in tipc_bclink_input()
356 struct sk_buff_head inputq; in tipc_bclink_xmit() local
390 skb_queue_head_init(&inputq); in tipc_bclink_xmit()
392 tipc_sk_mcast_rcv(net, &arrvq, &inputq); in tipc_bclink_xmit()
437 struct sk_buff_head *arrvq, *inputq; in tipc_bclink_rcv() local
476 inputq = &tn->bclink->inputq; in tipc_bclink_rcv()
484 spin_lock_bh(&inputq->lock); in tipc_bclink_rcv()
486 spin_unlock_bh(&inputq->lock); in tipc_bclink_rcv()
497 spin_lock_bh(&inputq->lock); in tipc_bclink_rcv()
499 spin_unlock_bh(&inputq->lock); in tipc_bclink_rcv()
[all …]
|
| D | node.c | 424 skb_queue_tail(n_ptr->inputq, skb); in node_lost_contact()
473 struct sk_buff_head *inputq = node->inputq; in tipc_node_unlock() local
480 tipc_sk_rcv(net, inputq); in tipc_node_unlock()
515 tipc_sk_rcv(net, inputq); in tipc_node_unlock()
|
| D | name_distr.c | 388 void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_named_rcv() argument
399 for (skb = skb_dequeue(inputq); skb; skb = skb_dequeue(inputq)) { in tipc_named_rcv()
|
| D | socket.c | 717 struct sk_buff_head *inputq) in tipc_sk_mcast_rcv() argument
730 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
731 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
753 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
755 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
758 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
762 tipc_sk_rcv(net, inputq); in tipc_sk_mcast_rcv()
1722 static int tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk, in tipc_sk_enqueue() argument
1731 while (skb_queue_len(inputq)) { in tipc_sk_enqueue()
1734 skb = tipc_skb_dequeue(inputq, dport); in tipc_sk_enqueue()
[all …]
|
| D | link.c | 288 skb_queue_head_init(&l_ptr->inputq); in tipc_link_create()
391 skb_queue_tail(&l->inputq, skb); in link_prepare_wakeup()
392 l->owner->inputq = &l->inputq; in link_prepare_wakeup()
464 if (!owner->inputq) in tipc_link_reset()
465 owner->inputq = &l_ptr->inputq; in tipc_link_reset()
466 skb_queue_splice_init(&l_ptr->wakeupq, owner->inputq); in tipc_link_reset()
467 if (!skb_queue_empty(owner->inputq)) in tipc_link_reset()
1009 if (skb_queue_len(&pl->inputq) > post_synch) in link_synch()
1186 if (tipc_skb_queue_tail(&link->inputq, skb, dport)) { in tipc_data_input()
1187 node->inputq = &link->inputq; in tipc_data_input()
|
| D | bcast.h | 98 struct sk_buff_head inputq; member
|
| D | node.h | 123 struct sk_buff_head *inputq; member
|
| D | link.h | 197 struct sk_buff_head inputq; member
|