Home
last modified time | relevance | path

Searched refs:buf_msg (Results 1 – 15 of 15) sorted by relevance

/Linux-v5.10/net/tipc/
Dmsg.c112 msg = buf_msg(buf); in tipc_msg_create()
145 msg = buf_msg(frag); in tipc_buf_append()
222 accounted = skb ? msg_blocks(buf_msg(skb)) : 0; in tipc_msg_append()
232 hdr = buf_msg(skb); in tipc_msg_append()
239 hdr = buf_msg(skb); in tipc_msg_append()
285 hsz = msg_hdr_sz(buf_msg(skb)); in tipc_msg_validate()
291 hdr = buf_msg(skb); in tipc_msg_validate()
331 dsz = msg_size(buf_msg(skb)); in tipc_msg_fragment()
353 _hdr = buf_msg(_skb); in tipc_msg_fragment()
474 msg_set_type(buf_msg(skb), LAST_FRAGMENT); in tipc_msg_build()
[all …]
Dname_distr.c76 msg = buf_msg(buf); in named_prepare_buf()
105 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_publish()
106 msg_set_non_legacy(buf_msg(skb)); in tipc_named_publish()
107 item = (struct distr_item *)msg_data(buf_msg(skb)); in tipc_named_publish()
132 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_withdraw()
133 msg_set_non_legacy(buf_msg(skb)); in tipc_named_withdraw()
134 item = (struct distr_item *)msg_data(buf_msg(skb)); in tipc_named_withdraw()
165 hdr = buf_msg(skb); in named_distribute()
185 hdr = buf_msg(skb); in named_distribute()
190 hdr = buf_msg(skb_peek_tail(list)); in named_distribute()
[all …]
Ddiscover.c87 hdr = buf_msg(skb); in tipc_disc_init_msg()
112 hdr = buf_msg(skb); in tipc_disc_msg_xmit()
163 msg_set_prevnode(buf_msg(d->skb), sugg_addr); in tipc_disc_addr_trial_msg()
171 msg_set_prevnode(buf_msg(d->skb), tn->trial_addr); in tipc_disc_addr_trial_msg()
172 msg_set_type(buf_msg(d->skb), DSC_REQ_MSG); in tipc_disc_addr_trial_msg()
196 struct tipc_msg *hdr = buf_msg(skb); in tipc_disc_rcv()
214 hdr = buf_msg(skb); in tipc_disc_rcv()
323 msg_set_type(buf_msg(d->skb), DSC_REQ_MSG); in tipc_disc_timeout()
324 msg_set_prevnode(buf_msg(d->skb), tn->trial_addr); in tipc_disc_timeout()
365 msg_set_type(buf_msg(d->skb), DSC_TRIAL_MSG); in tipc_disc_create()
Dlink.c761 msg = buf_msg(skb); in link_profile_stats()
877 msg_set_dest_droppable(buf_msg(skb), true); in link_schedule_user()
999 struct tipc_msg *hdr = buf_msg(skb_peek(list)); in tipc_link_xmit()
1039 hdr = buf_msg(skb); in tipc_link_xmit()
1145 hdr = buf_msg(skb); in tipc_link_advance_backlog()
1190 hdr = buf_msg(skb); in link_retransmit_failure()
1227 struct tipc_msg *hdr = buf_msg(skb); in tipc_data_input()
1274 struct tipc_msg *hdr = buf_msg(skb); in tipc_link_input()
1321 struct tipc_msg *hdr = buf_msg(skb); in tipc_link_tnl_rcv()
1603 hdr = buf_msg(_skb); in tipc_link_advance_transmq()
[all …]
Dbcast.c295 selector = msg_link_selector(buf_msg(skb_peek(pkts))); in tipc_rcast_xmit()
331 hdr = buf_msg(skb); in tipc_mcast_send_sync()
350 _hdr = buf_msg(_skb); in tipc_mcast_send_sync()
401 hdr = buf_msg(skb); in tipc_mcast_xmit()
438 struct tipc_msg *hdr = buf_msg(skb); in tipc_bcast_rcv()
796 hdr = buf_msg(skb); in tipc_mcast_filter_msg()
809 _hdr = buf_msg(_skb); in tipc_mcast_filter_msg()
854 _hdr = buf_msg(_skb); in tipc_mcast_filter_msg()
Dsocket.c284 dnode = msg_destnode(buf_msg(skb)); in tipc_sk_respond()
285 selector = msg_origport(buf_msg(skb)); in tipc_sk_respond()
1194 hdr = buf_msg(skb); in tipc_sk_mcast_rcv()
1237 msg_set_destport(buf_msg(_skb), portid); in tipc_sk_mcast_rcv()
1280 msg_set_ack_required(buf_msg(skb)); in tipc_sk_push_backlog()
1294 if (msg_is_syn(buf_msg(skb))) in tipc_sk_push_backlog()
1315 struct tipc_msg *hdr = buf_msg(skb); in tipc_sk_conn_proto_rcv()
1591 msg_set_ack_required(buf_msg(skb)); in __tipc_sendstream()
1681 struct tipc_msg *hdr = buf_msg(skb); in tipc_sk_set_orig_addr()
1729 msg = buf_msg(skb); in tipc_sk_anc_data_recv()
[all …]
Dgroup.c473 struct tipc_msg *_hdr, *hdr = buf_msg(skb); in tipc_group_sort_msg()
481 _hdr = buf_msg(_skb); in tipc_group_sort_msg()
509 hdr = buf_msg(skb); in tipc_group_filter_msg()
528 hdr = buf_msg(skb); in tipc_group_filter_msg()
692 hdr = buf_msg(skb); in tipc_group_create_event()
720 hdr = buf_msg(skb); in tipc_group_proto_xmit()
Dmsg.h199 static inline struct tipc_msg *buf_msg(struct sk_buff *skb) in buf_msg() function
1208 return msg_seqno(buf_msg(skb)); in buf_seqno()
1249 dport = msg_destport(buf_msg(skb)); in tipc_skb_peek_port()
1272 if (msg_destport(buf_msg(_skb)) == dport) { in tipc_skb_dequeue()
Dtrace.h303 msg_seqno(buf_msg(skb_peek(tq))) : 0;
305 msg_seqno(buf_msg(skb_peek_tail(tq))) : 0;
Dnode.c1595 struct tipc_msg *hdr = buf_msg(skb_peek(list)); in tipc_lxc_xmit()
1739 selector = msg_origport(buf_msg(skb)); in tipc_node_distr_xmit()
1740 dnode = msg_destnode(buf_msg(skb)); in tipc_node_distr_xmit()
1773 msg_set_destnode(buf_msg(txskb), dst); in tipc_node_broadcast()
1835 struct tipc_msg *hdr = buf_msg(skb); in tipc_node_bc_rcv()
1891 struct tipc_msg *hdr = buf_msg(skb); in tipc_node_check_state()
2076 hdr = buf_msg(skb); in tipc_rcv()
2104 hdr = buf_msg(skb); in tipc_rcv()
Dtopsrv.c611 msg_set_dest_droppable(buf_msg(skb), true); in tipc_topsrv_kern_evt()
612 memcpy(msg_data(buf_msg(skb)), evt, sizeof(*evt)); in tipc_topsrv_kern_evt()
Dtrace.c65 hdr = buf_msg(skb); in tipc_skb_dump()
Dbearer.c516 struct tipc_msg *hdr = buf_msg(skb); in tipc_bearer_xmit_skb()
552 if (likely(test_bit(0, &b->up) || msg_is_reset(buf_msg(skb)))) { in tipc_bearer_xmit()
582 hdr = buf_msg(skb); in tipc_bearer_bc_xmit()
Dcrypto.c1040 struct tipc_msg *hdr = buf_msg(skb); in tipc_ehdr_build()
1391 struct tipc_msg *hdr = buf_msg(skb); in tipc_crypto_key_synch()
1691 struct tipc_msg *hdr = buf_msg(*skb); in tipc_crypto_xmit()
2162 hdr = buf_msg(skb); in tipc_crypto_msg_rcv()
2243 hdr = buf_msg(skb); in tipc_crypto_key_xmit()
Dudp_media.c376 hdr = buf_msg(skb); in tipc_udp_recv()