| /kernel/linux/linux-5.10/net/tipc/ |
| H A D | bcast.c | 54 * @inputq: data input queue; will only carry SOCK_WAKEUP messages
66 struct sk_buff_head inputq; member
382 struct sk_buff_head inputq, localq; in tipc_mcast_xmit() local
388 skb_queue_head_init(&inputq); in tipc_mcast_xmit()
424 tipc_sk_mcast_rcv(net, &localq, &inputq); in tipc_mcast_xmit()
439 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_rcv() local
460 if (!skb_queue_empty(inputq)) in tipc_bcast_rcv()
461 tipc_sk_rcv(net, inputq); in tipc_bcast_rcv()
473 struct sk_buff_head *inputq in tipc_bcast_ack_rcv() local
502 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; tipc_bcast_sync_rcv() local
554 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; tipc_bcast_remove_peer() local
784 tipc_mcast_filter_msg(struct net *net, struct sk_buff_head *defq, struct sk_buff_head *inputq) tipc_mcast_filter_msg() argument
[all...] |
| H A D | group.h | 57 struct sk_buff_head *inputq,
61 struct sk_buff_head *inputq,
65 struct sk_buff_head *inputq,
|
| H A D | socket.h | 56 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq);
58 struct sk_buff_head *inputq);
|
| H A D | link.c | 115 * @inputq: buffer queue for messages to be delivered upwards
172 struct sk_buff_head *inputq; member
339 return l->inputq; in tipc_link_inputq()
463 * @inputq: queue to put messages ready for delivery
475 struct sk_buff_head *inputq, in tipc_link_create()
519 l->inputq = inputq; in tipc_link_create()
527 skb_queue_head_init(l->inputq); in tipc_link_create()
537 * @inputq: queue to put messages ready for delivery
545 struct sk_buff_head *inputq, in tipc_link_bc_create()
469 tipc_link_create(struct net *net, char *if_name, int bearer_id, int tolerance, char net_plane, u32 mtu, int priority, u32 min_win, u32 max_win, u32 session, u32 self, u32 peer, u8 *peer_id, u16 peer_caps, struct tipc_link *bc_sndlink, struct tipc_link *bc_rcvlink, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link **link) tipc_link_create() argument
543 tipc_link_bc_create(struct net *net, u32 ownnode, u32 peer, u8 *peer_id, int mtu, u32 min_win, u32 max_win, u16 peer_caps, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link *bc_sndlink, struct tipc_link **link) tipc_link_bc_create() argument
899 struct sk_buff_head *inputq = l->inputq; link_prepare_wakeup() local
1233 tipc_data_input(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *inputq) tipc_data_input() argument
1283 tipc_link_input(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *inputq, struct sk_buff **reasm_skb) tipc_link_input() argument
1328 tipc_link_tnl_rcv(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *inputq) tipc_link_tnl_rcv() argument
[all...] |
| H A D | group.c | 495 void tipc_group_filter_msg(struct tipc_group *grp, struct sk_buff_head *inputq, in tipc_group_filter_msg() argument
498 struct sk_buff *skb = __skb_dequeue(inputq); in tipc_group_filter_msg()
565 __skb_queue_tail(inputq, skb); in tipc_group_filter_msg()
670 struct sk_buff_head *inputq) in tipc_group_create_event()
699 __skb_queue_tail(inputq, skb); in tipc_group_create_event()
741 struct tipc_msg *hdr, struct sk_buff_head *inputq, in tipc_group_proto_rcv()
778 m->bc_syncpt, inputq); in tipc_group_proto_rcv()
789 m->bc_syncpt, inputq); in tipc_group_proto_rcv()
858 struct sk_buff_head *inputq, in tipc_group_member_evt()
903 m->bc_syncpt, inputq); in tipc_group_member_evt()
667 tipc_group_create_event(struct tipc_group *grp, struct tipc_member *m, u32 event, u16 seqno, struct sk_buff_head *inputq) tipc_group_create_event() argument
740 tipc_group_proto_rcv(struct tipc_group *grp, bool *usr_wakeup, struct tipc_msg *hdr, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_group_proto_rcv() argument
854 tipc_group_member_evt(struct tipc_group *grp, bool *usr_wakeup, int *sk_rcvbuf, struct tipc_msg *hdr, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_group_member_evt() argument
[all...] |
| H A D | socket.c | 1174 * @inputq: queue with cloned messages, delivered to socket after dest lookup
1179 struct sk_buff_head *inputq) in tipc_sk_mcast_rcv()
1194 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1195 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1204 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1207 __skb_queue_tail(inputq, skb); in tipc_sk_mcast_rcv()
1210 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1245 /* Append to inputq if not already done by other thread */ in tipc_sk_mcast_rcv()
1246 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1248 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
1178 tipc_sk_mcast_rcv(struct net *net, struct sk_buff_head *arrvq, struct sk_buff_head *inputq) tipc_sk_mcast_rcv() argument
1316 tipc_sk_conn_proto_rcv(struct tipc_sock *tsk, struct sk_buff *skb, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_sk_conn_proto_rcv() argument
2144 tipc_sk_proto_rcv(struct sock *sk, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_sk_proto_rcv() argument
2340 struct sk_buff_head inputq; tipc_sk_filter_rcv() local
2423 tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk, u32 dport, struct sk_buff_head *xmitq) tipc_sk_enqueue() argument
2476 tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq) tipc_sk_rcv() argument
[all...] |
| H A D | node.c | 68 struct sk_buff_head inputq; member
89 * @inputq: pointer to input queue containing messages for msg event
172 static void node_lost_contact(struct tipc_node *n, struct sk_buff_head *inputq);
1016 node_lost_contact(n, &le->inputq); in __tipc_node_link_down()
1069 tipc_sk_rcv(n->net, &le->inputq); in tipc_node_link_down()
1260 &le->inputq, in tipc_node_check_dest()
1492 struct sk_buff_head *inputq) in node_lost_contact()
1526 skb_queue_tail(inputq, skb); in node_lost_contact()
1603 struct sk_buff_head inputq; in tipc_lxc_xmit() local
1619 skb_queue_head_init(&inputq); in tipc_lxc_xmit()
1491 node_lost_contact(struct tipc_node *n, struct sk_buff_head *inputq) node_lost_contact() argument
[all...] |
| H A D | link.h | 80 struct sk_buff_head *inputq,
85 struct sk_buff_head *inputq,
|
| H A D | bcast.h | 110 struct sk_buff_head *inputq);
|
| /kernel/linux/linux-6.6/net/tipc/ |
| H A D | bcast.c | 54 * @inputq: data input queue; will only carry SOCK_WAKEUP messages
66 struct sk_buff_head inputq; member
382 struct sk_buff_head inputq, localq; in tipc_mcast_xmit() local
388 skb_queue_head_init(&inputq); in tipc_mcast_xmit()
424 tipc_sk_mcast_rcv(net, &localq, &inputq); in tipc_mcast_xmit()
439 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_rcv() local
460 if (!skb_queue_empty(inputq)) in tipc_bcast_rcv()
461 tipc_sk_rcv(net, inputq); in tipc_bcast_rcv()
473 struct sk_buff_head *inputq in tipc_bcast_ack_rcv() local
502 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; tipc_bcast_sync_rcv() local
554 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; tipc_bcast_remove_peer() local
784 tipc_mcast_filter_msg(struct net *net, struct sk_buff_head *defq, struct sk_buff_head *inputq) tipc_mcast_filter_msg() argument
[all...] |
| H A D | group.h | 58 struct sk_buff_head *inputq,
62 struct sk_buff_head *inputq,
66 struct sk_buff_head *inputq,
|
| H A D | link.c | 115 * @inputq: buffer queue for messages to be delivered upwards
200 struct sk_buff_head *inputq; member
367 return l->inputq; in tipc_link_inputq()
490 * @inputq: queue to put messages ready for delivery
504 struct sk_buff_head *inputq, in tipc_link_create()
548 l->inputq = inputq; in tipc_link_create()
556 skb_queue_head_init(l->inputq); in tipc_link_create()
566 * @inputq: queue to put messages ready for delivery
579 struct sk_buff_head *inputq, in tipc_link_bc_create()
498 tipc_link_create(struct net *net, char *if_name, int bearer_id, int tolerance, char net_plane, u32 mtu, int priority, u32 min_win, u32 max_win, u32 session, u32 self, u32 peer, u8 *peer_id, u16 peer_caps, struct tipc_link *bc_sndlink, struct tipc_link *bc_rcvlink, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link **link) tipc_link_create() argument
577 tipc_link_bc_create(struct net *net, u32 ownnode, u32 peer, u8 *peer_id, int mtu, u32 min_win, u32 max_win, u16 peer_caps, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link *bc_sndlink, struct tipc_link **link) tipc_link_bc_create() argument
934 struct sk_buff_head *inputq = l->inputq; link_prepare_wakeup() local
1268 tipc_data_input(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *inputq) tipc_data_input() argument
1319 tipc_link_input(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *inputq, struct sk_buff **reasm_skb) tipc_link_input() argument
1364 tipc_link_tnl_rcv(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *inputq) tipc_link_tnl_rcv() argument
[all...] |
| H 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()
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()
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()
904 m->bc_syncpt, inputq); in tipc_group_member_evt()
668 tipc_group_create_event(struct tipc_group *grp, struct tipc_member *m, u32 event, u16 seqno, struct sk_buff_head *inputq) tipc_group_create_event() argument
741 tipc_group_proto_rcv(struct tipc_group *grp, bool *usr_wakeup, struct tipc_msg *hdr, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_group_proto_rcv() argument
855 tipc_group_member_evt(struct tipc_group *grp, bool *usr_wakeup, int *sk_rcvbuf, struct tipc_msg *hdr, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_group_member_evt() argument
[all...] |
| H A D | socket.h | 56 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq);
58 struct sk_buff_head *inputq);
|
| H A D | socket.c | 1191 * @inputq: queue with cloned messages, delivered to socket after dest lookup
1196 struct sk_buff_head *inputq) in tipc_sk_mcast_rcv()
1212 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1213 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1228 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1231 __skb_queue_tail(inputq, skb); in tipc_sk_mcast_rcv()
1234 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1258 /* Append clones to inputq only if skb is still head of arrvq */ in tipc_sk_mcast_rcv()
1259 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1261 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
1195 tipc_sk_mcast_rcv(struct net *net, struct sk_buff_head *arrvq, struct sk_buff_head *inputq) tipc_sk_mcast_rcv() argument
1329 tipc_sk_conn_proto_rcv(struct tipc_sock *tsk, struct sk_buff *skb, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_sk_conn_proto_rcv() argument
2149 tipc_sk_proto_rcv(struct sock *sk, struct sk_buff_head *inputq, struct sk_buff_head *xmitq) tipc_sk_proto_rcv() argument
2345 struct sk_buff_head inputq; tipc_sk_filter_rcv() local
2429 tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk, u32 dport, struct sk_buff_head *xmitq) tipc_sk_enqueue() argument
2483 tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq) tipc_sk_rcv() argument
[all...] |
| H A D | link.h | 80 struct sk_buff_head *inputq,
85 struct sk_buff_head *inputq,
|
| H A D | node.c | 68 struct sk_buff_head inputq; member
89 * @inputq: pointer to input queue containing messages for msg event
181 static void node_lost_contact(struct tipc_node *n, struct sk_buff_head *inputq);
1043 node_lost_contact(n, &le->inputq); in __tipc_node_link_down()
1096 tipc_sk_rcv(n->net, &le->inputq); in tipc_node_link_down()
1287 &le->inputq, in tipc_node_check_dest()
1519 struct sk_buff_head *inputq) in node_lost_contact()
1553 skb_queue_tail(inputq, skb); in node_lost_contact()
1632 struct sk_buff_head inputq; in tipc_lxc_xmit() local
1648 skb_queue_head_init(&inputq); in tipc_lxc_xmit()
1518 node_lost_contact(struct tipc_node *n, struct sk_buff_head *inputq) node_lost_contact() argument
[all...] |
| H A D | bcast.h | 110 struct sk_buff_head *inputq);
|