Lines Matching refs:buf_msg
132 return msg_seqno(buf_msg(l_ptr->next_out)); in link_next_sent()
250 struct tipc_msg *msg = buf_msg(l_ptr->first_out); in link_timeout()
799 struct tipc_msg *bundler_msg = buf_msg(bundler); in link_bundle_buf()
800 struct tipc_msg *msg = buf_msg(buf); in link_bundle_buf()
853 struct tipc_msg *msg = buf_msg(buf); in tipc_link_send_buf()
925 msg = buf_msg(buf); in tipc_link_send_buf()
976 struct tipc_msg *msg = buf_msg(buf); in link_send_buf_fast()
1010 u32 selector = msg_origport(buf_msg(buf)) & 1; in tipc_send_buf_fast()
1030 res = msg_data_sz(buf_msg(buf)); in tipc_send_buf_fast()
1286 struct tipc_msg *msg = buf_msg(buf); in link_send_sections_long()
1316 u32 first = msg_seqno(buf_msg(buf)); in tipc_link_push_packet()
1329 msg_set_ack(buf_msg(buf), mod(l_ptr->next_in_no - 1)); in tipc_link_push_packet()
1330 msg_set_bcast_ack(buf_msg(buf), l_ptr->owner->bclink.last_in); in tipc_link_push_packet()
1346 msg_set_ack(buf_msg(buf), mod(l_ptr->next_in_no - 1)); in tipc_link_push_packet()
1347 msg_set_bcast_ack(buf_msg(buf), l_ptr->owner->bclink.last_in); in tipc_link_push_packet()
1363 struct tipc_msg *msg = buf_msg(buf); in tipc_link_push_packet()
1365 u32 first = msg_seqno(buf_msg(l_ptr->first_out)); in tipc_link_push_packet()
1434 struct tipc_msg *msg = buf_msg(buf); in link_retransmit_failure()
1484 msg = buf_msg(buf); in tipc_link_retransmit()
1510 msg = buf_msg(buf); in tipc_link_retransmit()
1520 l_ptr->retransm_queue_head = msg_seqno(buf_msg(buf)); in tipc_link_retransmit()
1541 seq_no = msg_seqno(buf_msg(l_ptr->oldest_deferred_in)); in link_insert_deferred_queue()
1643 msg = buf_msg(buf); in tipc_recv_msg()
1702 less_eq(msg_seqno(buf_msg(crs)), ackd)) { in tipc_recv_msg()
1768 msg = buf_msg(buf); in tipc_recv_msg()
1825 u32 seq_no = msg_seqno(buf_msg(buf)); in tipc_link_defer_pkt()
1836 if (less(msg_seqno(buf_msg(*tail)), seq_no)) { in tipc_link_defer_pkt()
1844 struct tipc_msg *msg = buf_msg(crs); in tipc_link_defer_pkt()
1873 u32 seq_no = msg_seqno(buf_msg(buf)); in link_handle_out_of_seq_msg()
1875 if (likely(msg_user(buf_msg(buf)) == LINK_PROTOCOL)) { in link_handle_out_of_seq_msg()
1929 next_sent = msg_seqno(buf_msg(l_ptr->next_out)); in tipc_link_send_proto_msg()
1932 u32 rec = msg_seqno(buf_msg(l_ptr->oldest_deferred_in)); in tipc_link_send_proto_msg()
2000 msg_set_size(buf_msg(buf), msg_size); in tipc_link_send_proto_msg()
2026 struct tipc_msg *msg = buf_msg(buf); in link_recv_proto_msg()
2218 struct tipc_msg *msg = buf_msg(crs); in tipc_link_changeover()
2252 struct tipc_msg *msg = buf_msg(iter); in tipc_link_send_duplicate()
2310 struct tipc_msg *tunnel_msg = buf_msg(tunnel_buf); in link_recv_changeover_msg()
2382 u32 msgcount = msg_msgcnt(buf_msg(buf)); in tipc_link_recv_bundle()
2392 pos += align(msg_size(buf_msg(obuf))); in tipc_link_recv_bundle()
2410 struct tipc_msg *inmsg = buf_msg(buf); in link_send_long_buf()
2479 msg_set_seqno(buf_msg(buf), seqno); in set_long_msg_seqno()
2484 return msg_ack(buf_msg(buf)); in get_fragm_size()
2489 msg_set_ack(buf_msg(buf), sz); in set_fragm_size()
2494 return msg_bcast_ack(buf_msg(buf)); in get_expected_frags()
2499 msg_set_bcast_ack(buf_msg(buf), exp); in set_expected_frags()
2504 return msg_reroute_cnt(buf_msg(buf)); in get_timer_cnt()
2509 msg_incr_reroute_cnt(buf_msg(buf)); in incr_timer_cnt()
2521 struct tipc_msg *fragm = buf_msg(fbuf); in tipc_link_recv_fragment()
2529 while (pbuf && ((msg_seqno(buf_msg(pbuf)) != long_msg_seq_no) || in tipc_link_recv_fragment()
2530 (msg_orignode(fragm) != msg_orignode(buf_msg(pbuf))))) { in tipc_link_recv_fragment()
2579 msg_reset_reroute_cnt(buf_msg(pbuf)); in tipc_link_recv_fragment()
2581 *m = buf_msg(pbuf); in tipc_link_recv_fragment()
2984 tipc_printf(buf, "[%u..", msg_seqno(buf_msg(l_ptr->first_out))); in link_print()
2987 msg_seqno(buf_msg(l_ptr->next_out))); in link_print()
2988 tipc_printf(buf, "%u]", msg_seqno(buf_msg(l_ptr->last_out))); in link_print()
2989 if ((mod(msg_seqno(buf_msg(l_ptr->last_out)) - in link_print()
2990 msg_seqno(buf_msg(l_ptr->first_out))) in link_print()
3002 u32 o = msg_seqno(buf_msg(l_ptr->oldest_deferred_in)); in link_print()
3003 u32 n = msg_seqno(buf_msg(l_ptr->newest_deferred_in)); in link_print()