Lines Matching refs:msg
69 struct tipc_msg *msg; in tipc_msg_create() local
76 msg = buf_msg(buf); in tipc_msg_create()
77 tipc_msg_init(msg, user, type, hdr_sz, dnode); in tipc_msg_create()
78 msg_set_size(msg, hdr_sz + data_sz); in tipc_msg_create()
79 msg_set_prevnode(msg, onode); in tipc_msg_create()
80 msg_set_origport(msg, oport); in tipc_msg_create()
81 msg_set_destport(msg, dport); in tipc_msg_create()
82 msg_set_errcode(msg, errcode); in tipc_msg_create()
84 msg_set_orignode(msg, onode); in tipc_msg_create()
85 msg_set_destnode(msg, dnode); in tipc_msg_create()
102 struct tipc_msg *msg; in tipc_buf_append() local
110 msg = buf_msg(frag); in tipc_buf_append()
111 fragid = msg_type(msg); in tipc_buf_append()
113 skb_pull(frag, msg_hdr_sz(msg)); in tipc_buf_append()
277 struct tipc_msg *msg = buf_msg(buf); in tipc_msg_bundle() local
279 unsigned int msz = msg_size(msg); in tipc_msg_bundle()
284 if (likely(msg_user(msg) == MSG_FRAGMENTER)) in tipc_msg_bundle()
286 if (unlikely(msg_user(msg) == CHANGEOVER_PROTOCOL)) in tipc_msg_bundle()
288 if (unlikely(msg_user(msg) == BCAST_PROTOCOL)) in tipc_msg_bundle()
320 struct tipc_msg *msg = buf_msg(*buf); in tipc_msg_make_bundle() local
321 u32 msz = msg_size(msg); in tipc_msg_make_bundle()
324 if (msg_user(msg) == MSG_FRAGMENTER) in tipc_msg_make_bundle()
326 if (msg_user(msg) == CHANGEOVER_PROTOCOL) in tipc_msg_make_bundle()
328 if (msg_user(msg) == BCAST_PROTOCOL) in tipc_msg_make_bundle()
340 msg_set_seqno(bmsg, msg_seqno(msg)); in tipc_msg_make_bundle()
341 msg_set_ack(bmsg, msg_ack(msg)); in tipc_msg_make_bundle()
342 msg_set_bcast_ack(bmsg, msg_bcast_ack(msg)); in tipc_msg_make_bundle()
359 struct tipc_msg *msg = buf_msg(buf); in tipc_msg_reverse() local
360 uint imp = msg_importance(msg); in tipc_msg_reverse()
362 uint rdsz = min_t(uint, msg_data_sz(msg), MAX_FORWARD_SIZE); in tipc_msg_reverse()
366 if (msg_dest_droppable(msg)) in tipc_msg_reverse()
368 if (msg_errcode(msg)) in tipc_msg_reverse()
371 memcpy(&ohdr, msg, msg_hdr_sz(msg)); in tipc_msg_reverse()
373 if (msg_isdata(msg)) in tipc_msg_reverse()
374 msg_set_importance(msg, imp); in tipc_msg_reverse()
375 msg_set_errcode(msg, err); in tipc_msg_reverse()
376 msg_set_origport(msg, msg_destport(&ohdr)); in tipc_msg_reverse()
377 msg_set_destport(msg, msg_origport(&ohdr)); in tipc_msg_reverse()
378 msg_set_prevnode(msg, tipc_own_addr); in tipc_msg_reverse()
379 if (!msg_short(msg)) { in tipc_msg_reverse()
380 msg_set_orignode(msg, msg_destnode(&ohdr)); in tipc_msg_reverse()
381 msg_set_destnode(msg, msg_orignode(&ohdr)); in tipc_msg_reverse()
383 msg_set_size(msg, msg_hdr_sz(msg) + rdsz); in tipc_msg_reverse()
384 skb_trim(buf, msg_size(msg)); in tipc_msg_reverse()
405 struct tipc_msg *msg = buf_msg(buf); in tipc_msg_eval() local
408 if (msg_type(msg) != TIPC_NAMED_MSG) in tipc_msg_eval()
412 if (msg_data_sz(msg) > MAX_FORWARD_SIZE) in tipc_msg_eval()
414 if (msg_reroute_cnt(msg) > 0) in tipc_msg_eval()
417 *dnode = addr_domain(msg_lookup_scope(msg)); in tipc_msg_eval()
418 dport = tipc_nametbl_translate(msg_nametype(msg), in tipc_msg_eval()
419 msg_nameinst(msg), in tipc_msg_eval()
423 msg_incr_reroute_cnt(msg); in tipc_msg_eval()
424 msg_set_destnode(msg, *dnode); in tipc_msg_eval()
425 msg_set_destport(msg, dport); in tipc_msg_eval()