Lines Matching refs:msg

93 	struct tipc_msg *msg;  in tipc_msg_create()  local
100 msg = buf_msg(buf); in tipc_msg_create()
101 tipc_msg_init(onode, msg, user, type, hdr_sz, dnode); in tipc_msg_create()
102 msg_set_size(msg, hdr_sz + data_sz); in tipc_msg_create()
103 msg_set_origport(msg, oport); in tipc_msg_create()
104 msg_set_destport(msg, dport); in tipc_msg_create()
105 msg_set_errcode(msg, errcode); in tipc_msg_create()
107 msg_set_orignode(msg, onode); in tipc_msg_create()
108 msg_set_destnode(msg, dnode); in tipc_msg_create()
125 struct tipc_msg *msg; in tipc_buf_append() local
133 msg = buf_msg(frag); in tipc_buf_append()
134 fragid = msg_type(msg); in tipc_buf_append()
136 skb_pull(frag, msg_hdr_sz(msg)); in tipc_buf_append()
204 struct tipc_msg *msg; in tipc_msg_validate() local
218 msg = buf_msg(skb); in tipc_msg_validate()
219 if (unlikely(msg_version(msg) != TIPC_VERSION)) in tipc_msg_validate()
222 msz = msg_size(msg); in tipc_msg_validate()
345 bool tipc_msg_bundle(struct sk_buff *skb, struct tipc_msg *msg, u32 mtu) in tipc_msg_bundle() argument
349 unsigned int msz = msg_size(msg); in tipc_msg_bundle()
353 if (likely(msg_user(msg) == MSG_FRAGMENTER)) in tipc_msg_bundle()
362 if (unlikely(msg_user(msg) == TUNNEL_PROTOCOL)) in tipc_msg_bundle()
364 if (unlikely(msg_user(msg) == BCAST_PROTOCOL)) in tipc_msg_bundle()
372 if ((msg_importance(msg) < TIPC_SYSTEM_IMPORTANCE) && in tipc_msg_bundle()
377 skb_copy_to_linear_data_offset(skb, start, msg, msz); in tipc_msg_bundle()
394 struct tipc_msg *msg; in tipc_msg_extract() local
401 msg = buf_msg(skb); in tipc_msg_extract()
402 offset = msg_hdr_sz(msg) + *pos; in tipc_msg_extract()
403 if (unlikely(offset > (msg_size(msg) - MIN_H_SIZE))) in tipc_msg_extract()
432 bool tipc_msg_make_bundle(struct sk_buff **skb, struct tipc_msg *msg, in tipc_msg_make_bundle() argument
437 u32 msz = msg_size(msg); in tipc_msg_make_bundle()
440 if (msg_user(msg) == MSG_FRAGMENTER) in tipc_msg_make_bundle()
442 if (msg_user(msg) == TUNNEL_PROTOCOL) in tipc_msg_make_bundle()
444 if (msg_user(msg) == BCAST_PROTOCOL) in tipc_msg_make_bundle()
455 tipc_msg_init(msg_prevnode(msg), bmsg, MSG_BUNDLER, 0, in tipc_msg_make_bundle()
457 if (msg_isdata(msg)) in tipc_msg_make_bundle()
461 msg_set_seqno(bmsg, msg_seqno(msg)); in tipc_msg_make_bundle()
462 msg_set_ack(bmsg, msg_ack(msg)); in tipc_msg_make_bundle()
463 msg_set_bcast_ack(bmsg, msg_bcast_ack(msg)); in tipc_msg_make_bundle()
464 tipc_msg_bundle(_skb, msg, mtu); in tipc_msg_make_bundle()
534 struct tipc_msg *msg = buf_msg(skb); in tipc_msg_lookup_dest() local
538 if (!msg_isdata(msg)) in tipc_msg_lookup_dest()
540 if (!msg_named(msg)) in tipc_msg_lookup_dest()
542 if (msg_errcode(msg)) in tipc_msg_lookup_dest()
547 msg = buf_msg(skb); in tipc_msg_lookup_dest()
548 if (msg_reroute_cnt(msg)) in tipc_msg_lookup_dest()
550 dnode = addr_domain(net, msg_lookup_scope(msg)); in tipc_msg_lookup_dest()
551 dport = tipc_nametbl_translate(net, msg_nametype(msg), in tipc_msg_lookup_dest()
552 msg_nameinst(msg), &dnode); in tipc_msg_lookup_dest()
555 msg_incr_reroute_cnt(msg); in tipc_msg_lookup_dest()
557 msg_set_prevnode(msg, onode); in tipc_msg_lookup_dest()
558 msg_set_destnode(msg, dnode); in tipc_msg_lookup_dest()
559 msg_set_destport(msg, dport); in tipc_msg_lookup_dest()