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()
205 struct tipc_msg *msg; in tipc_msg_validate() local
219 msg = buf_msg(skb); in tipc_msg_validate()
220 if (unlikely(msg_version(msg) != TIPC_VERSION)) in tipc_msg_validate()
223 msz = msg_size(msg); in tipc_msg_validate()
349 struct tipc_msg *msg = buf_msg(skb); in tipc_msg_bundle() local
351 unsigned int msz = msg_size(msg); in tipc_msg_bundle()
355 if (likely(msg_user(msg) == MSG_FRAGMENTER)) in tipc_msg_bundle()
364 if (unlikely(msg_user(msg) == TUNNEL_PROTOCOL)) in tipc_msg_bundle()
366 if (unlikely(msg_user(msg) == BCAST_PROTOCOL)) 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()
436 struct tipc_msg *msg = buf_msg(*skb); in tipc_msg_make_bundle() local
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 msg_set_seqno(bmsg, msg_seqno(msg)); in tipc_msg_make_bundle()
458 msg_set_ack(bmsg, msg_ack(msg)); in tipc_msg_make_bundle()
459 msg_set_bcast_ack(bmsg, msg_bcast_ack(msg)); in tipc_msg_make_bundle()
476 struct tipc_msg *msg = buf_msg(buf); in tipc_msg_reverse() local
478 uint rdsz = min_t(uint, msg_data_sz(msg), MAX_FORWARD_SIZE); in tipc_msg_reverse()
482 msg = buf_msg(buf); in tipc_msg_reverse()
483 if (msg_dest_droppable(msg)) in tipc_msg_reverse()
485 if (msg_errcode(msg)) in tipc_msg_reverse()
487 memcpy(&ohdr, msg, msg_hdr_sz(msg)); in tipc_msg_reverse()
488 msg_set_errcode(msg, err); in tipc_msg_reverse()
489 msg_set_origport(msg, msg_destport(&ohdr)); in tipc_msg_reverse()
490 msg_set_destport(msg, msg_origport(&ohdr)); in tipc_msg_reverse()
491 msg_set_prevnode(msg, own_addr); in tipc_msg_reverse()
492 if (!msg_short(msg)) { in tipc_msg_reverse()
493 msg_set_orignode(msg, msg_destnode(&ohdr)); in tipc_msg_reverse()
494 msg_set_destnode(msg, msg_orignode(&ohdr)); in tipc_msg_reverse()
496 msg_set_size(msg, msg_hdr_sz(msg) + rdsz); in tipc_msg_reverse()
497 skb_trim(buf, msg_size(msg)); in tipc_msg_reverse()
518 struct tipc_msg *msg = buf_msg(skb); in tipc_msg_lookup_dest() local
522 if (!msg_isdata(msg)) in tipc_msg_lookup_dest()
524 if (!msg_named(msg)) in tipc_msg_lookup_dest()
526 if (msg_errcode(msg)) in tipc_msg_lookup_dest()
531 if (msg_reroute_cnt(msg)) in tipc_msg_lookup_dest()
533 *dnode = addr_domain(net, msg_lookup_scope(msg)); in tipc_msg_lookup_dest()
534 dport = tipc_nametbl_translate(net, msg_nametype(msg), in tipc_msg_lookup_dest()
535 msg_nameinst(msg), dnode); in tipc_msg_lookup_dest()
538 msg_incr_reroute_cnt(msg); in tipc_msg_lookup_dest()
540 msg_set_prevnode(msg, own_addr); in tipc_msg_lookup_dest()
541 msg_set_destnode(msg, *dnode); in tipc_msg_lookup_dest()
542 msg_set_destport(msg, dport); in tipc_msg_lookup_dest()