Searched refs:buf_msg (Results 1 – 15 of 15) sorted by relevance
100 msg = buf_msg(buf); in tipc_msg_create()133 msg = buf_msg(frag); in tipc_buf_append()213 hsz = msg_hdr_sz(buf_msg(skb)); in tipc_msg_validate()219 msg = buf_msg(skb); in tipc_msg_validate()330 msg_set_type(buf_msg(skb), LAST_FRAGMENT); in tipc_msg_build()349 struct tipc_msg *msg = buf_msg(skb); in tipc_msg_bundle()359 bmsg = buf_msg(bskb); in tipc_msg_bundle()401 msg = buf_msg(skb); in tipc_msg_extract()410 imsz = msg_size(buf_msg(*iskb)); in tipc_msg_extract()436 struct tipc_msg *msg = buf_msg(*skb); in tipc_msg_make_bundle()[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()
172 struct tipc_msg *msg = buf_msg(skb); in link_timeout()341 struct tipc_msg *msg = buf_msg(skb_peek(list)); in link_schedule_user()702 struct tipc_msg *msg = buf_msg(skb_peek(list)); in __tipc_link_xmit()725 msg = buf_msg(skb); in __tipc_link_xmit()744 imp = msg_importance(buf_msg(skb)); in __tipc_link_xmit()844 msg = buf_msg(skb); in tipc_link_sync_xmit()861 struct tipc_msg *msg = buf_msg(buf); in tipc_link_sync_rcv()886 msg = buf_msg(skb); in tipc_link_push_packets()920 struct tipc_msg *msg = buf_msg(buf); in link_retransmit_failure()964 msg = buf_msg(skb); in tipc_link_retransmit()[all …]
123 static inline struct tipc_msg *buf_msg(struct sk_buff *skb) in buf_msg() function818 dport = msg_destport(buf_msg(skb)); in tipc_skb_peek_port()841 if (msg_destport(buf_msg(_skb)) == dport) { in tipc_skb_dequeue()865 if (!_skb || (msg_destport(buf_msg(_skb)) != dport) || in tipc_skb_queue_tail()
296 struct tipc_msg *msg = buf_msg(buf); in tipc_bclink_update_link_state()430 struct tipc_msg *msg = buf_msg(buf); in tipc_bclink_rcv()515 msg = buf_msg(buf); in tipc_bclink_rcv()543 msg = buf_msg(skb_peek(&node->bclink.deferdq)); in tipc_bclink_rcv()599 struct tipc_msg *msg = buf_msg(buf); in tipc_bcbearer_send()609 if (likely(!msg_non_seq(buf_msg(buf)))) { in tipc_bcbearer_send()
87 msg = buf_msg(buf); in tipc_disc_init_msg()131 struct tipc_msg *msg = buf_msg(buf); in tipc_disc_rcv()
732 msg = buf_msg(skb); in tipc_sk_mcast_rcv()746 msg_set_destport(buf_msg(_skb), portid); in tipc_sk_mcast_rcv()772 struct tipc_msg *msg = buf_msg(*skb); in tipc_sk_proto_rcv()1224 msg = buf_msg(skb); in tipc_sk_send_ack()1306 msg = buf_msg(buf); in tipc_recvmsg()1403 msg = buf_msg(buf); in tipc_recv_stream()1519 struct tipc_msg *msg = buf_msg(*skb); in filter_connect()1610 struct tipc_msg *msg = buf_msg(buf); in rcvbuf_limit()1635 struct tipc_msg *msg = buf_msg(*skb); in filter_rcv()1794 dnode = msg_destnode(buf_msg(skb)); in tipc_sk_rcv()[all …]
255 return msg_seqno(buf_msg(buf)); in buf_seqno()
220 int usr = msg_user(buf_msg(skb)); in tipc_udp_recv()
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()1371 rpyid = buffer->buf_msg.msg_body.reqst.rpyid; in srpc_send_reply()1476 buffer = container_of(ev->md.start, srpc_buffer_t, buf_msg); in srpc_lnet_ev_handler()1506 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()
731 srpc_msg_t *msg = &rpc->srpc_reqstbuf->buf_msg; in sfw_add_test_instance()1127 request = &rpc->srpc_reqstbuf->buf_msg.msg_body.tes_reqst; in sfw_add_test()1234 srpc_msg_t *request = &rpc->srpc_reqstbuf->buf_msg; in sfw_handle_server_rpc()1343 LASSERT(rpc->srpc_reqstbuf->buf_msg.msg_body.tes_reqst.tsr_is_client); in sfw_bulk_ready()
168 srpc_msg_t buf_msg; member
1898 srpc_msg_t *req = &rpc->srpc_reqstbuf->buf_msg; in lstcon_acceptor_handle()