Searched refs:inputq (Results 1 – 9 of 9) sorted by relevance
| /net/tipc/ |
| A D | bcast.c | 66 struct sk_buff_head inputq; member
439 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_rcv() local
473 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_ack_rcv() local
502 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_sync_rcv() local
554 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_remove_peer() local
706 &bb->inputq, in tipc_bcast_init()
792 skb = skb_peek(inputq); in tipc_mcast_filter_msg()
821 __skb_dequeue(inputq); in tipc_mcast_filter_msg()
830 __skb_dequeue(inputq); in tipc_mcast_filter_msg()
837 __skb_dequeue(inputq); in tipc_mcast_filter_msg()
[all …]
|
| A D | group.h | 58 struct sk_buff_head *inputq,
62 struct sk_buff_head *inputq,
66 struct sk_buff_head *inputq,
|
| A D | link.c | 185 struct sk_buff_head *inputq; member
345 return l->inputq; in tipc_link_inputq()
526 l->inputq = inputq; in tipc_link_create()
534 skb_queue_head_init(l->inputq); in tipc_link_create()
557 struct sk_buff_head *inputq, in tipc_link_bc_create() argument
912 struct sk_buff_head *inputq = l->inputq; in link_prepare_wakeup() local
932 spin_lock_bh(&inputq->lock); in link_prepare_wakeup()
934 spin_unlock_bh(&inputq->lock); in link_prepare_wakeup()
970 spin_lock_bh(&l->inputq->lock); in tipc_link_reset()
1264 skb_queue_tail(inputq, skb); in tipc_data_input()
[all …]
|
| A D | group.c | 496 void tipc_group_filter_msg(struct tipc_group *grp, struct sk_buff_head *inputq, in tipc_group_filter_msg() argument
499 struct sk_buff *skb = __skb_dequeue(inputq); in tipc_group_filter_msg()
566 __skb_queue_tail(inputq, skb); in tipc_group_filter_msg()
671 struct sk_buff_head *inputq) in tipc_group_create_event() argument
700 __skb_queue_tail(inputq, skb); in tipc_group_create_event()
742 struct tipc_msg *hdr, struct sk_buff_head *inputq, in tipc_group_proto_rcv() argument
779 m->bc_syncpt, inputq); in tipc_group_proto_rcv()
790 m->bc_syncpt, inputq); in tipc_group_proto_rcv()
859 struct sk_buff_head *inputq, in tipc_group_member_evt() argument
904 m->bc_syncpt, inputq); in tipc_group_member_evt()
[all …]
|
| A D | socket.c | 1223 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1254 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1260 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1264 tipc_sk_rcv(net, inputq); in tipc_sk_mcast_rcv()
1353 __skb_queue_tail(inputq, skb); in tipc_sk_conn_proto_rcv()
2171 hdr, inputq, xmitq); in tipc_sk_proto_rcv()
2340 struct sk_buff_head inputq; in tipc_sk_filter_rcv() local
2346 __skb_queue_head_init(&inputq); in tipc_sk_filter_rcv()
2347 __skb_queue_tail(&inputq, skb); in tipc_sk_filter_rcv()
2433 while (skb_queue_len(inputq)) { in tipc_sk_enqueue()
[all …]
|
| A D | socket.h | 56 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq);
58 struct sk_buff_head *inputq);
|
| A D | node.c | 68 struct sk_buff_head inputq; member
1094 tipc_sk_rcv(n->net, &le->inputq); in tipc_node_link_down()
1285 &le->inputq, in tipc_node_check_dest()
1551 skb_queue_tail(inputq, skb); in node_lost_contact()
1630 struct sk_buff_head inputq; in tipc_lxc_xmit() local
1646 skb_queue_head_init(&inputq); in tipc_lxc_xmit()
1649 skb_queue_purge(&inputq); in tipc_lxc_xmit()
1656 skb_queue_head_init(&inputq); in tipc_lxc_xmit()
1659 skb_queue_purge(&inputq); in tipc_lxc_xmit()
2193 if (!skb_queue_empty(&le->inputq)) in tipc_rcv()
[all …]
|
| A D | link.h | 80 struct sk_buff_head *inputq,
85 struct sk_buff_head *inputq,
|
| A D | bcast.h | 110 struct sk_buff_head *inputq);
|
Completed in 26 milliseconds