Lines Matching refs:seq
204 uint32_t seq; member
375 static int dlm_send_ack(int nodeid, uint32_t seq) in dlm_send_ack() argument
392 m_header->u.h_seq = cpu_to_le32(seq); in dlm_send_ack()
450 static void dlm_receive_ack(struct midcomms_node *node, uint32_t seq) in dlm_receive_ack() argument
456 if (before(mh->seq, seq)) { in dlm_receive_ack()
467 if (before(mh->seq, seq)) { in dlm_receive_ack()
503 static void dlm_receive_buffer_3_2_trace(uint32_t seq, in dlm_receive_buffer_3_2_trace() argument
508 trace_dlm_recv_message(dlm_our_nodeid(), seq, &p->message); in dlm_receive_buffer_3_2_trace()
511 trace_dlm_recv_rcom(dlm_our_nodeid(), seq, &p->rcom); in dlm_receive_buffer_3_2_trace()
520 uint32_t seq) in dlm_midcomms_receive_buffer() argument
527 is_expected_seq = (oval == seq); in dlm_midcomms_receive_buffer()
588 dlm_receive_buffer_3_2_trace(seq, p); in dlm_midcomms_receive_buffer()
599 if (seq < oval) in dlm_midcomms_receive_buffer()
603 seq, oval, node->nodeid); in dlm_midcomms_receive_buffer()
661 uint32_t seq; in dlm_midcomms_receive_buffer_3_2() local
724 seq = le32_to_cpu(p->header.u.h_seq); in dlm_midcomms_receive_buffer_3_2()
769 dlm_midcomms_receive_buffer(p, node, seq); in dlm_midcomms_receive_buffer_3_2()
772 seq = le32_to_cpu(p->header.u.h_seq); in dlm_midcomms_receive_buffer_3_2()
773 dlm_receive_ack(node, seq); in dlm_midcomms_receive_buffer_3_2()
948 mh->seq, node->nodeid); in dlm_midcomms_unack_msg_resend()
955 uint32_t seq) in dlm_fill_opts_header() argument
961 opts->o_header.u.h_seq = cpu_to_le32(seq); in dlm_fill_opts_header()
974 mh->seq = atomic_fetch_inc(&mh->node->seq_send); in midcomms_new_msg_cb()
992 dlm_fill_opts_header(opts, len, mh->seq); in dlm_midcomms_get_msg_3_2()
1072 trace_dlm_send_message(mh->node->nodeid, mh->seq, in dlm_midcomms_commit_msg_3_2_trace()
1077 trace_dlm_send_rcom(mh->node->nodeid, mh->seq, in dlm_midcomms_commit_msg_3_2_trace()