Searched refs:ack_record (Results 1 – 12 of 12) sorted by relevance
59 msg->ack_record = (AckRecord *) self->pending_ack_record; in _track_msg()66 bookmark_save(&msg->ack_record->bookmark); in _save_bookmark()83 _ack_record_free(msg->ack_record); in _manage_msg_ack()
88 msg->ack_record = (AckRecord *) self->pending_ack_record; in _ack_records_track_msg()116 _ack_record_save_bookmark(ConsecutiveAckRecord *ack_record) in _ack_record_save_bookmark() argument118 Bookmark *bookmark = &(ack_record->super.bookmark); in _ack_record_save_bookmark()143 ConsecutiveAckRecord *ack_rec = (ConsecutiveAckRecord *)msg->ack_record; in consecutive_ack_tracker_manage_msg_ack()
95 msg->ack_record = (AckRecord *) self->pending_ack_record; in _assign_pending_ack_record_to_msg()107 _append_ack_record_to_batch(BatchedAckTracker *self, AckRecord *ack_record) in _append_ack_record_to_batch() argument112 self->acked_records = g_list_prepend(self->acked_records, ack_record); in _append_ack_record_to_batch()279 GList *full_batch = _append_ack_record_to_batch(self, msg->ack_record); in _manage_msg_ack()288 _ack_record_free(msg->ack_record); in _manage_msg_ack()
55 msg->ack_record = (AckRecord *)(&self->ack_record_storage); in _track_msg()
61 AckRecord *self = msg->ack_record; in _ack_message()81 self->original->ack_record = self; in ack_record_new()
105 AckRecord *ack_record = l->data; in _invoke_batched_ack_callback() local106 Bookmark *bookmark = &ack_record->bookmark; in _invoke_batched_ack_callback()
202 cr_assert_eq(msg1->ack_record->tracker, ack_tracker); in Test()261 cr_assert_eq(msg1->ack_record->tracker, ack_tracker); in Test()301 cr_assert_eq(msg1->ack_record->tracker, ack_tracker); in Test()
158 cr_assert_eq(msg->ack_record->tracker, ack_tracker); in Test()222 cr_assert_eq(msg->ack_record->tracker, ack_tracker); in Test()
180 AckRecord *ack_record; member
187 } ack_record; typedef
498 ack_record *ack_list_head = NULL; // Head of linked list storing most recent ack's520 ack_record *p; in store_most_recent_ack()573 p = (ack_record *)malloc(sizeof(ack_record)); in store_most_recent_ack()590 ack_record *p; in get_most_recent_ack()
185 AckTracker *ack_tracker = msg->ack_record->tracker; in log_source_msg_ack()