Lines Matching refs:msg

101 	struct tipc_msg *msg;  in tipc_msg_create()  local
108 msg = buf_msg(buf); in tipc_msg_create()
109 tipc_msg_init(onode, msg, user, type, hdr_sz, dnode); in tipc_msg_create()
110 msg_set_size(msg, hdr_sz + data_sz); in tipc_msg_create()
111 msg_set_origport(msg, oport); in tipc_msg_create()
112 msg_set_destport(msg, dport); in tipc_msg_create()
113 msg_set_errcode(msg, errcode); in tipc_msg_create()
129 struct tipc_msg *msg; in tipc_buf_append() local
137 msg = buf_msg(frag); in tipc_buf_append()
138 fragid = msg_type(msg); in tipc_buf_append()
140 skb_pull(frag, msg_hdr_sz(msg)); in tipc_buf_append()
484 static bool tipc_msg_bundle(struct sk_buff *bskb, struct tipc_msg *msg, in tipc_msg_bundle() argument
490 msz = msg_size(msg); in tipc_msg_bundle()
501 skb_copy_to_linear_data_offset(bskb, offset, msg, msz); in tipc_msg_bundle()
523 struct tipc_msg *msg, *inner, *outer; in tipc_msg_try_bundle() local
527 msg = buf_msg(*skb); in tipc_msg_try_bundle()
528 if (msg_user(msg) == MSG_FRAGMENTER) in tipc_msg_try_bundle()
530 if (msg_user(msg) == TUNNEL_PROTOCOL) in tipc_msg_try_bundle()
532 if (msg_user(msg) == BCAST_PROTOCOL) in tipc_msg_try_bundle()
534 if (mss <= INT_H_SIZE + msg_size(msg)) in tipc_msg_try_bundle()
549 if (unlikely(mss < BUF_ALIGN(INT_H_SIZE + tsz) + msg_size(msg))) in tipc_msg_try_bundle()
565 if (likely(tipc_msg_bundle(tskb, msg, mss))) { in tipc_msg_try_bundle()
677 bool tipc_msg_skb_clone(struct sk_buff_head *msg, struct sk_buff_head *cpy) in tipc_msg_skb_clone() argument
681 skb_queue_walk(msg, skb) { in tipc_msg_skb_clone()
703 struct tipc_msg *msg = buf_msg(skb); in tipc_msg_lookup_dest() local
704 u32 scope = msg_lookup_scope(msg); in tipc_msg_lookup_dest()
706 u32 inst = msg_nameinst(msg); in tipc_msg_lookup_dest()
710 if (!msg_isdata(msg)) in tipc_msg_lookup_dest()
712 if (!msg_named(msg)) in tipc_msg_lookup_dest()
714 if (msg_errcode(msg)) in tipc_msg_lookup_dest()
719 msg = buf_msg(skb); in tipc_msg_lookup_dest()
720 if (msg_reroute_cnt(msg)) in tipc_msg_lookup_dest()
723 msg_nametype(msg), inst, inst); in tipc_msg_lookup_dest()
727 msg_incr_reroute_cnt(msg); in tipc_msg_lookup_dest()
729 msg_set_prevnode(msg, self); in tipc_msg_lookup_dest()
730 msg_set_destnode(msg, sk.node); in tipc_msg_lookup_dest()
731 msg_set_destport(msg, sk.ref); in tipc_msg_lookup_dest()
801 bool tipc_msg_pskb_copy(u32 dst, struct sk_buff_head *msg, in tipc_msg_pskb_copy() argument
806 skb_queue_walk(msg, skb) { in tipc_msg_pskb_copy()