#include "syslog-ng.h"
#include "driver.h"
#include "stats/stats-registry.h"
#include "stats/aggregator/stats-aggregator.h"
#include "stats/stats-compat.h"
#include "stats/stats-cluster-key-builder.h"
#include "logqueue.h"
#include "seqnum.h"
#include "mainloop-threaded-worker.h"
#include "timeutils/misc.h"
#include "template/templates.h"
#include <iv.h>
#include <iv_event.h>

Include dependency graph for logthrdestdrv.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	LogThreadedDestWorker

struct	LogThreadedDestDriver

Enumerations
enum	LogThreadedFlushMode { LTF_FLUSH_NORMAL , LTF_FLUSH_EXPEDITE }

enum	LogThreadedResult { LTR_DROP , LTR_ERROR , LTR_EXPLICIT_ACK_MGMT , LTR_SUCCESS , LTR_QUEUED , LTR_NOT_CONNECTED , LTR_RETRY , LTR_MAX }

enum	{ LTDF_SEQNUM_ALL = 0x0001 , LTDF_SEQNUM = 0x0002 }

Functions
const gchar *	log_threaded_result_to_str (LogThreadedResult self)

void	log_threaded_dest_worker_ack_messages (LogThreadedDestWorker *self, gint batch_size)

void	log_threaded_dest_worker_drop_messages (LogThreadedDestWorker *self, gint batch_size)

void	log_threaded_dest_worker_rewind_messages (LogThreadedDestWorker *self, gint batch_size)

void	log_threaded_dest_worker_wakeup_when_suspended (LogThreadedDestWorker *self)

gboolean	log_threaded_dest_worker_init_method (LogThreadedDestWorker *self)

void	log_threaded_dest_worker_deinit_method (LogThreadedDestWorker *self)

void	log_threaded_dest_worker_init_instance (LogThreadedDestWorker self, LogThreadedDestDriver owner, gint worker_index)

void	log_threaded_dest_worker_free_method (LogThreadedDestWorker *self)

void	log_threaded_dest_worker_free (LogThreadedDestWorker *self)

void	log_threaded_dest_worker_written_bytes_add (LogThreadedDestWorker *self, gsize b)

void	log_threaded_dest_driver_insert_msg_length_stats (LogThreadedDestDriver *self, gsize len)

void	log_threaded_dest_driver_insert_batch_length_stats (LogThreadedDestDriver *self, gsize len)

void	log_threaded_dest_driver_register_aggregated_stats (LogThreadedDestDriver *self)

void	log_threaded_dest_driver_unregister_aggregated_stats (LogThreadedDestDriver *self)

gboolean	log_threaded_dest_driver_deinit_method (LogPipe *s)

gboolean	log_threaded_dest_driver_init_method (LogPipe *s)

gboolean	log_threaded_dest_driver_start_workers (LogPipe *s)

void	log_threaded_dest_driver_init_instance (LogThreadedDestDriver self, GlobalConfig cfg)

void	log_threaded_dest_driver_free (LogPipe *s)

void	log_threaded_dest_driver_set_max_retries_on_error (LogDriver *s, gint max_retries)

void	log_threaded_dest_driver_set_num_workers (LogDriver *s, gint num_workers)

void	log_threaded_dest_driver_set_worker_partition_key_ref (LogDriver s, LogTemplate key)

void	log_threaded_dest_driver_set_flush_on_worker_key_change (LogDriver *s, gboolean f)

void	log_threaded_dest_driver_set_batch_lines (LogDriver *s, gint batch_lines)

void	log_threaded_dest_driver_set_batch_timeout (LogDriver *s, gint batch_timeout)

void	log_threaded_dest_driver_set_time_reopen (LogDriver *s, time_t time_reopen)

gboolean	log_threaded_dest_driver_process_flag (LogDriver driver, const gchar flag)

Enumeration Type Documentation

◆ anonymous enum

anonymous enum

Enumerator
LTDF_SEQNUM_ALL
LTDF_SEQNUM

◆ LogThreadedFlushMode

enum LogThreadedFlushMode

Enumerator
LTF_FLUSH_NORMAL
LTF_FLUSH_EXPEDITE

◆ LogThreadedResult

enum LogThreadedResult

Enumerator
LTR_DROP
LTR_ERROR
LTR_EXPLICIT_ACK_MGMT
LTR_SUCCESS
LTR_QUEUED
LTR_NOT_CONNECTED
LTR_RETRY
LTR_MAX

Function Documentation

◆ log_threaded_dest_driver_deinit_method()

gboolean log_threaded_dest_driver_deinit_method ( LogPipe * s )

◆ log_threaded_dest_driver_free()

void log_threaded_dest_driver_free ( LogPipe * s )

◆ log_threaded_dest_driver_init_instance()

void log_threaded_dest_driver_init_instance	(	LogThreadedDestDriver *	self,
		GlobalConfig *	cfg
	)

◆ log_threaded_dest_driver_init_method()

gboolean log_threaded_dest_driver_init_method ( LogPipe * s )

◆ log_threaded_dest_driver_insert_batch_length_stats()

void log_threaded_dest_driver_insert_batch_length_stats	(	LogThreadedDestDriver *	self,
		gsize	len
	)

◆ log_threaded_dest_driver_insert_msg_length_stats()

void log_threaded_dest_driver_insert_msg_length_stats	(	LogThreadedDestDriver *	self,
		gsize	len
	)

◆ log_threaded_dest_driver_process_flag()

gboolean log_threaded_dest_driver_process_flag	(	LogDriver *	driver,
		const gchar *	flag
	)

◆ log_threaded_dest_driver_register_aggregated_stats()

void log_threaded_dest_driver_register_aggregated_stats ( LogThreadedDestDriver * self )

◆ log_threaded_dest_driver_set_batch_lines()

void log_threaded_dest_driver_set_batch_lines	(	LogDriver *	s,
		gint	batch_lines
	)

◆ log_threaded_dest_driver_set_batch_timeout()

void log_threaded_dest_driver_set_batch_timeout	(	LogDriver *	s,
		gint	batch_timeout
	)

◆ log_threaded_dest_driver_set_flush_on_worker_key_change()

void log_threaded_dest_driver_set_flush_on_worker_key_change	(	LogDriver *	s,
		gboolean	f
	)

◆ log_threaded_dest_driver_set_max_retries_on_error()

void log_threaded_dest_driver_set_max_retries_on_error	(	LogDriver *	s,
		gint	max_retries
	)

◆ log_threaded_dest_driver_set_num_workers()

void log_threaded_dest_driver_set_num_workers	(	LogDriver *	s,
		gint	num_workers
	)

◆ log_threaded_dest_driver_set_time_reopen()

void log_threaded_dest_driver_set_time_reopen	(	LogDriver *	s,
		time_t	time_reopen
	)

◆ log_threaded_dest_driver_set_worker_partition_key_ref()

void log_threaded_dest_driver_set_worker_partition_key_ref	(	LogDriver *	s,
		LogTemplate *	key
	)

◆ log_threaded_dest_driver_start_workers()

gboolean log_threaded_dest_driver_start_workers ( LogPipe * s )

◆ log_threaded_dest_driver_unregister_aggregated_stats()

void log_threaded_dest_driver_unregister_aggregated_stats ( LogThreadedDestDriver * self )

◆ log_threaded_dest_worker_ack_messages()

void log_threaded_dest_worker_ack_messages	(	LogThreadedDestWorker *	self,
		gint	batch_size
	)

◆ log_threaded_dest_worker_deinit_method()

void log_threaded_dest_worker_deinit_method ( LogThreadedDestWorker * self )

◆ log_threaded_dest_worker_drop_messages()

void log_threaded_dest_worker_drop_messages	(	LogThreadedDestWorker *	self,
		gint	batch_size
	)

◆ log_threaded_dest_worker_free()

void log_threaded_dest_worker_free ( LogThreadedDestWorker * self )

◆ log_threaded_dest_worker_free_method()

void log_threaded_dest_worker_free_method ( LogThreadedDestWorker * self )

◆ log_threaded_dest_worker_init_instance()

void log_threaded_dest_worker_init_instance	(	LogThreadedDestWorker *	self,
		LogThreadedDestDriver *	owner,
		gint	worker_index
	)

◆ log_threaded_dest_worker_init_method()

gboolean log_threaded_dest_worker_init_method ( LogThreadedDestWorker * self )

◆ log_threaded_dest_worker_rewind_messages()

void log_threaded_dest_worker_rewind_messages	(	LogThreadedDestWorker *	self,
		gint	batch_size
	)

◆ log_threaded_dest_worker_wakeup_when_suspended()

void log_threaded_dest_worker_wakeup_when_suspended ( LogThreadedDestWorker * self )

◆ log_threaded_dest_worker_written_bytes_add()

void log_threaded_dest_worker_written_bytes_add	(	LogThreadedDestWorker *	self,
		gsize	b
	)

◆ log_threaded_result_to_str()

const gchar* log_threaded_result_to_str ( LogThreadedResult self )

Classes

Enumerations

Functions