• Home
  • Raw
  • Download

Lines Matching refs:msg

103 	struct tipc_msg *msg;  in tipc_msg_create()  local
110 msg = buf_msg(buf); in tipc_msg_create()
111 tipc_msg_init(onode, msg, user, type, hdr_sz, dnode); in tipc_msg_create()
112 msg_set_size(msg, hdr_sz + data_sz); in tipc_msg_create()
113 msg_set_origport(msg, oport); in tipc_msg_create()
114 msg_set_destport(msg, dport); in tipc_msg_create()
115 msg_set_errcode(msg, errcode); in tipc_msg_create()
117 msg_set_orignode(msg, onode); in tipc_msg_create()
118 msg_set_destnode(msg, dnode); in tipc_msg_create()
135 struct tipc_msg *msg; in tipc_buf_append() local
143 msg = buf_msg(frag); in tipc_buf_append()
144 fragid = msg_type(msg); in tipc_buf_append()
146 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 < 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()
702 struct tipc_msg *msg = buf_msg(skb); in tipc_msg_lookup_dest() local
706 if (!msg_isdata(msg)) in tipc_msg_lookup_dest()
708 if (!msg_named(msg)) in tipc_msg_lookup_dest()
710 if (msg_errcode(msg)) in tipc_msg_lookup_dest()
715 msg = buf_msg(skb); in tipc_msg_lookup_dest()
716 if (msg_reroute_cnt(msg)) in tipc_msg_lookup_dest()
718 dnode = tipc_scope2node(net, msg_lookup_scope(msg)); in tipc_msg_lookup_dest()
719 dport = tipc_nametbl_translate(net, msg_nametype(msg), in tipc_msg_lookup_dest()
720 msg_nameinst(msg), &dnode); in tipc_msg_lookup_dest()
723 msg_incr_reroute_cnt(msg); in tipc_msg_lookup_dest()
725 msg_set_prevnode(msg, onode); in tipc_msg_lookup_dest()
726 msg_set_destnode(msg, dnode); in tipc_msg_lookup_dest()
727 msg_set_destport(msg, dport); in tipc_msg_lookup_dest()
797 bool tipc_msg_pskb_copy(u32 dst, struct sk_buff_head *msg, in tipc_msg_pskb_copy() argument
802 skb_queue_walk(msg, skb) { in tipc_msg_pskb_copy()