Searched refs:buf_msg (Results 1 – 16 of 16) sorted by relevance
100 msg = buf_msg(buf); in tipc_msg_create()133 msg = buf_msg(frag); in tipc_buf_append()212 hsz = msg_hdr_sz(buf_msg(skb)); in tipc_msg_validate()218 msg = buf_msg(skb); in tipc_msg_validate()329 msg_set_type(buf_msg(skb), LAST_FRAGMENT); in tipc_msg_build()357 bmsg = buf_msg(skb); in tipc_msg_bundle()401 msg = buf_msg(skb); in tipc_msg_extract()410 imsz = msg_size(buf_msg(*iskb)); in tipc_msg_extract()454 bmsg = buf_msg(_skb); in tipc_msg_make_bundle()480 struct tipc_msg *hdr = buf_msg(_skb); in tipc_msg_reverse()[all …]
79 msg = buf_msg(buf); in named_prepare_buf()104 msg_set_destnode(buf_msg(oskb), dnode); in named_cluster_distribute()133 item = (struct distr_item *)msg_data(buf_msg(buf)); in tipc_named_publish()157 item = (struct distr_item *)msg_data(buf_msg(buf)); in tipc_named_withdraw()187 item = (struct distr_item *)msg_data(buf_msg(skb)); in named_distribute()203 msg_set_size(buf_msg(skb), INT_H_SIZE + (msg_dsz - msg_rem)); in named_distribute()400 msg = buf_msg(skb); in tipc_named_rcv()
527 msg = buf_msg(skb); in link_profile_stats()614 struct tipc_msg *msg = buf_msg(skb_peek(list)); in link_schedule_user()714 struct tipc_msg *hdr = buf_msg(skb_peek(list)); in tipc_link_xmit()736 hdr = buf_msg(skb); in tipc_link_xmit()761 l->backlog[msg_importance(buf_msg(bskb))].len++; in tipc_link_xmit()789 hdr = buf_msg(skb); in tipc_link_advance_backlog()805 struct tipc_msg *hdr = buf_msg(skb); in link_retransmit_failure()844 hdr = buf_msg(skb); in tipc_link_retrans()848 hdr = buf_msg(_skb); in tipc_link_retrans()866 switch (msg_user(buf_msg(skb))) { in tipc_data_input()[all …]
124 static inline struct tipc_msg *buf_msg(struct sk_buff *skb) in buf_msg() function804 return msg_seqno(buf_msg(skb)); in buf_seqno()840 dport = msg_destport(buf_msg(skb)); in tipc_skb_peek_port()863 if (msg_destport(buf_msg(_skb)) == dport) { in tipc_skb_dequeue()
87 msg = buf_msg(buf); in tipc_disc_init_msg()129 struct tipc_msg *hdr = buf_msg(skb); in tipc_disc_rcv()
263 dnode = msg_destnode(buf_msg(skb)); in tipc_sk_respond()264 selector = msg_origport(buf_msg(skb)); in tipc_sk_respond()742 msg = buf_msg(skb); in tipc_sk_mcast_rcv()756 msg_set_destport(buf_msg(_skb), portid); in tipc_sk_mcast_rcv()783 struct tipc_msg *hdr = buf_msg(skb); in tipc_sk_proto_rcv()1239 msg = buf_msg(skb); in tipc_sk_send_ack()1321 msg = buf_msg(buf); in tipc_recvmsg()1418 msg = buf_msg(buf); in tipc_recv_stream()1539 struct tipc_msg *hdr = buf_msg(skb); in filter_connect()1629 struct tipc_msg *msg = buf_msg(buf); in rcvbuf_limit()[all …]
1092 struct tipc_msg *hdr = buf_msg(skb); in tipc_node_bc_rcv()1148 struct tipc_msg *hdr = buf_msg(skb); in tipc_node_check_state()1277 struct tipc_msg *hdr = buf_msg(skb); in tipc_rcv()
218 struct tipc_msg *hdr = buf_msg(skb); in tipc_bcast_rcv()
227 int usr = msg_user(buf_msg(skb)); in tipc_udp_recv()
511 hdr = buf_msg(skb); in tipc_bearer_bc_xmit()
475 struct srpc_msg *msg = &buf->buf_msg; in srpc_service_post_buffer()873 __u64 id = rpc->srpc_reqstbuf->buf_msg.msg_body.reqst.bulkid; in srpc_do_bulk()995 msg = &rpc->srpc_reqstbuf->buf_msg; in srpc_handle_rpc()1369 rpyid = buffer->buf_msg.msg_body.reqst.rpyid; in srpc_send_reply()1474 buffer = container_of(ev->md.start, srpc_buffer_t, buf_msg); in srpc_lnet_ev_handler()1504 msg = &buffer->buf_msg; in srpc_lnet_ev_handler()
391 reqstmsg = &rpc->srpc_reqstbuf->buf_msg; in brw_bulk_ready()421 srpc_msg_t *reqstmsg = &rpc->srpc_reqstbuf->buf_msg; in brw_server_handle()
175 srpc_msg_t *reqstmsg = &rpc->srpc_reqstbuf->buf_msg; in ping_server_handle()
727 srpc_msg_t *msg = &rpc->srpc_reqstbuf->buf_msg; in sfw_add_test_instance()1123 request = &rpc->srpc_reqstbuf->buf_msg.msg_body.tes_reqst; in sfw_add_test()1230 srpc_msg_t *request = &rpc->srpc_reqstbuf->buf_msg; in sfw_handle_server_rpc()1339 LASSERT(rpc->srpc_reqstbuf->buf_msg.msg_body.tes_reqst.tsr_is_client); in sfw_bulk_ready()
168 srpc_msg_t buf_msg; member
1897 srpc_msg_t *req = &rpc->srpc_reqstbuf->buf_msg; in lstcon_acceptor_handle()