Searched refs:log_threaded_dest_worker_ack_messages (Results 1 – 3 of 3) sorted by relevance
223 void log_threaded_dest_worker_ack_messages(LogThreadedDestWorker *self, gint batch_size);
84 log_threaded_dest_worker_ack_messages(LogThreadedDestWorker *self, gint batch_size) in log_threaded_dest_worker_ack_messages() function238 log_threaded_dest_worker_ack_messages(self, self->batch_size); in _accept_batch()
742 log_threaded_dest_worker_ack_messages(&s->worker.instance, 1); in _insert_explicit_acks_message_success()752 log_threaded_dest_worker_ack_messages(&s->worker.instance, 1); in _flush_explicit_acks_message_success()