Home
last modified time | relevance | path

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

/Linux-v5.4/net/tipc/
Dmsg.c102 msg = buf_msg(buf); in tipc_msg_create()
135 msg = buf_msg(frag); in tipc_buf_append()
224 hsz = msg_hdr_sz(buf_msg(skb)); in tipc_msg_validate()
230 hdr = buf_msg(skb); in tipc_msg_validate()
270 dsz = msg_size(buf_msg(skb)); in tipc_msg_fragment()
292 _hdr = buf_msg(_skb); in tipc_msg_fragment()
413 msg_set_type(buf_msg(skb), LAST_FRAGMENT); in tipc_msg_build()
441 bmsg = buf_msg(skb); in tipc_msg_bundle()
485 hdr = buf_msg(skb); in tipc_msg_extract()
543 bmsg = buf_msg(_skb); in tipc_msg_make_bundle()
[all …]
Ddiscover.c87 hdr = buf_msg(skb); in tipc_disc_init_msg()
111 hdr = buf_msg(skb); in tipc_disc_msg_xmit()
162 msg_set_prevnode(buf_msg(d->skb), sugg_addr); in tipc_disc_addr_trial_msg()
170 msg_set_prevnode(buf_msg(d->skb), tn->trial_addr); in tipc_disc_addr_trial_msg()
171 msg_set_type(buf_msg(d->skb), DSC_REQ_MSG); in tipc_disc_addr_trial_msg()
195 struct tipc_msg *hdr = buf_msg(skb); in tipc_disc_rcv()
212 hdr = buf_msg(skb); in tipc_disc_rcv()
321 msg_set_type(buf_msg(d->skb), DSC_REQ_MSG); in tipc_disc_timeout()
322 msg_set_prevnode(buf_msg(d->skb), tn->trial_addr); in tipc_disc_timeout()
363 msg_set_type(buf_msg(d->skb), DSC_TRIAL_MSG); in tipc_disc_create()
Dname_distr.c76 msg = buf_msg(buf); in named_prepare_buf()
106 item = (struct distr_item *)msg_data(buf_msg(skb)); in tipc_named_publish()
132 item = (struct distr_item *)msg_data(buf_msg(buf)); in tipc_named_withdraw()
162 msg_set_bc_ack_invalid(buf_msg(skb), true); in named_distribute()
163 item = (struct distr_item *)msg_data(buf_msg(skb)); in named_distribute()
179 msg_set_size(buf_msg(skb), INT_H_SIZE + (msg_dsz - msg_rem)); in named_distribute()
314 msg = buf_msg(skb); in tipc_named_rcv()
Dlink.c727 msg = buf_msg(skb); in link_profile_stats()
838 msg_set_dest_droppable(buf_msg(skb), true); in link_schedule_user()
942 struct tipc_msg *hdr = buf_msg(skb_peek(list)); in tipc_link_xmit()
980 hdr = buf_msg(skb); in tipc_link_xmit()
1043 hdr = buf_msg(skb); in tipc_link_advance_backlog()
1090 hdr = buf_msg(skb); in link_retransmit_failure()
1145 hdr = buf_msg(skb); in tipc_link_bc_retrans()
1157 hdr = buf_msg(_skb); in tipc_link_bc_retrans()
1180 struct tipc_msg *hdr = buf_msg(skb); in tipc_data_input()
1222 struct tipc_msg *hdr = buf_msg(skb); in tipc_link_input()
[all …]
Dbcast.c288 selector = msg_link_selector(buf_msg(skb_peek(pkts))); in tipc_rcast_xmit()
324 hdr = buf_msg(skb); in tipc_mcast_send_sync()
343 _hdr = buf_msg(_skb); in tipc_mcast_send_sync()
393 hdr = buf_msg(skb); in tipc_mcast_xmit()
425 struct tipc_msg *hdr = buf_msg(skb); in tipc_bcast_rcv()
777 hdr = buf_msg(skb); in tipc_mcast_filter_msg()
790 _hdr = buf_msg(_skb); in tipc_mcast_filter_msg()
835 _hdr = buf_msg(_skb); in tipc_mcast_filter_msg()
Dgroup.c467 struct tipc_msg *_hdr, *hdr = buf_msg(skb); in tipc_group_sort_msg()
475 _hdr = buf_msg(_skb); in tipc_group_sort_msg()
503 hdr = buf_msg(skb); in tipc_group_filter_msg()
522 hdr = buf_msg(skb); in tipc_group_filter_msg()
686 hdr = buf_msg(skb); in tipc_group_create_event()
714 hdr = buf_msg(skb); in tipc_group_proto_xmit()
Dsocket.c253 dnode = msg_destnode(buf_msg(skb)); in tipc_sk_respond()
254 selector = msg_origport(buf_msg(skb)); in tipc_sk_respond()
1149 hdr = buf_msg(skb); in tipc_sk_mcast_rcv()
1192 msg_set_destport(buf_msg(_skb), portid); in tipc_sk_mcast_rcv()
1220 struct tipc_msg *hdr = buf_msg(skb); in tipc_sk_conn_proto_rcv()
1550 struct tipc_msg *hdr = buf_msg(skb); in tipc_sk_set_orig_addr()
1598 msg = buf_msg(skb); in tipc_sk_anc_data_recv()
1611 msg = buf_msg(skb); in tipc_sk_anc_data_recv()
1668 msg = buf_msg(skb); in tipc_sk_send_ack()
1762 hdr = buf_msg(skb); in tipc_recvmsg()
[all …]
Dmsg.h153 static inline struct tipc_msg *buf_msg(struct sk_buff *skb) in buf_msg() function
1079 return msg_seqno(buf_msg(skb)); in buf_seqno()
1120 dport = msg_destport(buf_msg(skb)); in tipc_skb_peek_port()
1143 if (msg_destport(buf_msg(_skb)) == dport) { in tipc_skb_dequeue()
Dtrace.h302 __entry->fseqno = msg_seqno(buf_msg(skb_peek(tq)));
303 __entry->lseqno = msg_seqno(buf_msg(skb_peek_tail(tq)));
Dtopsrv.c608 msg_set_dest_droppable(buf_msg(skb), true); in tipc_topsrv_kern_evt()
609 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.c502 struct tipc_msg *hdr = buf_msg(skb); in tipc_bearer_xmit_skb()
532 if (likely(test_bit(0, &b->up) || msg_is_reset(buf_msg(skb)))) in tipc_bearer_xmit()
556 hdr = buf_msg(skb); in tipc_bearer_bc_xmit()
Dnode.c1510 selector = msg_origport(buf_msg(skb)); in tipc_node_distr_xmit()
1511 dnode = msg_destnode(buf_msg(skb)); in tipc_node_distr_xmit()
1533 msg_set_destnode(buf_msg(txskb), dst); in tipc_node_broadcast()
1596 struct tipc_msg *hdr = buf_msg(skb); in tipc_node_bc_rcv()
1650 struct tipc_msg *hdr = buf_msg(skb); in tipc_node_check_state()
1817 hdr = buf_msg(skb); in tipc_rcv()
Dudp_media.c368 hdr = buf_msg(skb); in tipc_udp_recv()