logthrdestdrv.c File Reference

#include "stats/stats-cluster-logpipe.h"
#include "stats/stats-cluster-single.h"
#include "stats/aggregator/stats-aggregator-registry.h"
#include "logthrdestdrv.h"
#include "seqnum.h"
#include "scratch-buffers.h"
#include "template/eval.h"
#include "mainloop-threaded-worker.h"
#include <string.h>

Include dependency graph for logthrdestdrv.c:

Macros
#define	MAX_RETRIES_ON_ERROR_DEFAULT   3
#define	MAX_RETRIES_BEFORE_SUSPEND_DEFAULT   3

Functions
const gchar *	log_threaded_result_to_str (LogThreadedResult self)
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 *s, const gchar *flag)
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_free_method (LogThreadedDestWorker *self)
void	log_threaded_dest_worker_init_instance (LogThreadedDestWorker *self, LogThreadedDestDriver *owner, gint worker_index)
void	log_threaded_dest_worker_free (LogThreadedDestWorker *self)
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_max_retries_on_error (LogDriver *s, gint max_retries)
LogThreadedDestWorker *	_lookup_worker (LogThreadedDestDriver *self, LogMessage *msg)
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_pre_config_init (LogPipe *s)
gboolean	log_threaded_dest_driver_init_method (LogPipe *s)
gboolean	log_threaded_dest_driver_start_workers (LogPipe *s)
gboolean	log_threaded_dest_driver_deinit_method (LogPipe *s)
void	log_threaded_dest_driver_free (LogPipe *s)
void	log_threaded_dest_driver_init_instance (LogThreadedDestDriver *self, GlobalConfig *cfg)

Variables
CfgFlagHandler	log_threaded_dest_driver_flag_handlers []

Macro Definition Documentation

MAX_RETRIES_BEFORE_SUSPEND_DEFAULT

#define MAX_RETRIES_BEFORE_SUSPEND_DEFAULT   3

MAX_RETRIES_ON_ERROR_DEFAULT

#define MAX_RETRIES_ON_ERROR_DEFAULT   3

Function Documentation

_lookup_worker()

LogThreadedDestWorker* _lookup_worker	(	LogThreadedDestDriver *	self,
		LogMessage *	msg
	)

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_pre_config_init()

gboolean log_threaded_dest_driver_pre_config_init

(

LogPipe *

s

)

log_threaded_dest_driver_process_flag()

gboolean log_threaded_dest_driver_process_flag	(	LogDriver *	s,
		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

)

Variable Documentation

log_threaded_dest_driver_flag_handlers

CfgFlagHandler log_threaded_dest_driver_flag_handlers[]

Initial value:

=
{
  
  { "seqnum-all",      CFH_SET, offsetof(LogThreadedDestDriver, flags), LTDF_SEQNUM_ALL + LTDF_SEQNUM },
  { "no-seqnum-all",   CFH_CLEAR, offsetof(LogThreadedDestDriver, flags), LTDF_SEQNUM_ALL },
  { "seqnum",          CFH_SET, offsetof(LogThreadedDestDriver, flags), LTDF_SEQNUM },
  { "no-seqnum",       CFH_CLEAR, offsetof(LogThreadedDestDriver, flags), LTDF_SEQNUM },
  { NULL },
}