Searched refs:inputq (Results 1 – 10 of 10) sorted by relevance
| /net/tipc/ |
| D | bcast.c | 65 struct sk_buff_head inputq; member
375 struct sk_buff_head inputq, localq; in tipc_mcast_xmit() local
381 skb_queue_head_init(&inputq); in tipc_mcast_xmit()
417 tipc_sk_mcast_rcv(net, &localq, &inputq); in tipc_mcast_xmit()
432 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_rcv() local
453 if (!skb_queue_empty(inputq)) in tipc_bcast_rcv()
454 tipc_sk_rcv(net, inputq); in tipc_bcast_rcv()
466 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_ack_rcv() local
483 if (!skb_queue_empty(inputq)) in tipc_bcast_ack_rcv()
484 tipc_sk_rcv(net, inputq); in tipc_bcast_ack_rcv()
[all …]
|
| D | group.h | 57 struct sk_buff_head *inputq,
61 struct sk_buff_head *inputq,
65 struct sk_buff_head *inputq,
|
| D | link.c | 172 struct sk_buff_head *inputq; member
327 return l->inputq; in tipc_link_inputq()
448 struct sk_buff_head *inputq, in tipc_link_create() argument
492 l->inputq = inputq; in tipc_link_create()
500 skb_queue_head_init(l->inputq); in tipc_link_create()
517 struct sk_buff_head *inputq, in tipc_link_bc_create() argument
526 NULL, inputq, namedq, link)) in tipc_link_bc_create()
855 struct sk_buff_head *inputq = l->inputq; in link_prepare_wakeup() local
875 spin_lock_bh(&inputq->lock); in link_prepare_wakeup()
876 skb_queue_splice_tail(&tmpq, inputq); in link_prepare_wakeup()
[all …]
|
| D | group.c | 489 void tipc_group_filter_msg(struct tipc_group *grp, struct sk_buff_head *inputq, in tipc_group_filter_msg() argument
492 struct sk_buff *skb = __skb_dequeue(inputq); in tipc_group_filter_msg()
559 __skb_queue_tail(inputq, skb); in tipc_group_filter_msg()
664 struct sk_buff_head *inputq) in tipc_group_create_event() argument
693 __skb_queue_tail(inputq, skb); in tipc_group_create_event()
735 struct tipc_msg *hdr, struct sk_buff_head *inputq, in tipc_group_proto_rcv() argument
772 m->bc_syncpt, inputq); in tipc_group_proto_rcv()
783 m->bc_syncpt, inputq); in tipc_group_proto_rcv()
852 struct sk_buff_head *inputq, in tipc_group_member_evt() argument
897 m->bc_syncpt, inputq); in tipc_group_member_evt()
[all …]
|
| D | socket.c | 1132 struct sk_buff_head *inputq) in tipc_sk_mcast_rcv() argument
1147 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1148 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1157 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1160 __skb_queue_tail(inputq, skb); in tipc_sk_mcast_rcv()
1163 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1199 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1201 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
1204 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1208 tipc_sk_rcv(net, inputq); in tipc_sk_mcast_rcv()
[all …]
|
| D | socket.h | 56 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq);
58 struct sk_buff_head *inputq);
|
| D | name_distr.c | 301 void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_named_rcv() argument
312 for (skb = skb_dequeue(inputq); skb; skb = skb_dequeue(inputq)) { in tipc_named_rcv()
|
| D | link.h | 80 struct sk_buff_head *inputq,
85 struct sk_buff_head *inputq,
|
| D | node.c | 67 struct sk_buff_head inputq; member
160 static void node_lost_contact(struct tipc_node *n, struct sk_buff_head *inputq);
857 node_lost_contact(n, &le->inputq); in __tipc_node_link_down()
910 tipc_sk_rcv(n->net, &le->inputq); in tipc_node_link_down()
1090 &le->inputq, in tipc_node_check_dest()
1321 struct sk_buff_head *inputq) in node_lost_contact() argument
1353 skb_queue_tail(inputq, skb); in node_lost_contact()
1883 if (!skb_queue_empty(&le->inputq)) in tipc_rcv()
1884 tipc_sk_rcv(net, &le->inputq); in tipc_rcv()
2578 i += tipc_list_dump(&n->links[0].inputq, false, buf + i); in tipc_node_dump()
[all …]
|
| D | bcast.h | 105 struct sk_buff_head *inputq);
|