logthrsourcedrv.c File Reference

#include "logthrsourcedrv.h"
#include "mainloop-threaded-worker.h"
#include "messages.h"
#include "apphook.h"
#include "ack-tracker/ack_tracker_factory.h"
#include "stats/stats-cluster-key-builder.h"
#include <iv.h>

Include dependency graph for logthrsourcedrv.c:

Functions
void	log_threaded_source_worker_options_defaults (LogThreadedSourceWorkerOptions *options)
void	log_threaded_source_worker_options_init (LogThreadedSourceWorkerOptions *options, GlobalConfig *cfg, const gchar *group_name, gint num_workers)
void	log_threaded_source_worker_options_destroy (LogThreadedSourceWorkerOptions *options)
void	log_threaded_source_worker_free (LogPipe *s)
void	log_threaded_source_worker_init_instance (LogThreadedSourceWorker *self, LogThreadedSourceDriver *driver, gint worker_index)
gboolean	log_threaded_source_driver_pre_config_init (LogPipe *s)
gboolean	log_threaded_source_driver_init_method (LogPipe *s)
gboolean	log_threaded_source_driver_deinit_method (LogPipe *s)
void	log_threaded_source_driver_free_method (LogPipe *s)
gboolean	log_threaded_source_driver_start_workers (LogPipe *s)
void	log_threaded_source_worker_close_batch (LogThreadedSourceWorker *self)
void	log_threaded_source_worker_post (LogThreadedSourceWorker *self, LogMessage *msg)
gboolean	log_threaded_source_worker_free_to_send (LogThreadedSourceWorker *self)
void	log_threaded_source_worker_blocking_post (LogThreadedSourceWorker *self, LogMessage *msg)
void	log_threaded_source_driver_set_transport_name (LogThreadedSourceDriver *self, const gchar *transport_name)
void	log_threaded_source_driver_init_instance (LogThreadedSourceDriver *self, GlobalConfig *cfg)

Function Documentation

log_threaded_source_driver_deinit_method()

gboolean log_threaded_source_driver_deinit_method

(

LogPipe *

s

)

log_threaded_source_driver_free_method()

void log_threaded_source_driver_free_method

(

LogPipe *

s

)

log_threaded_source_driver_init_instance()

void log_threaded_source_driver_init_instance	(	LogThreadedSourceDriver *	self,
		GlobalConfig *	cfg
	)

log_threaded_source_driver_init_method()

gboolean log_threaded_source_driver_init_method

(

LogPipe *

s

)

log_threaded_source_driver_pre_config_init()

gboolean log_threaded_source_driver_pre_config_init

(

LogPipe *

s

)

log_threaded_source_driver_set_transport_name()

void log_threaded_source_driver_set_transport_name	(	LogThreadedSourceDriver *	self,
		const gchar *	transport_name
	)

log_threaded_source_driver_start_workers()

gboolean log_threaded_source_driver_start_workers

(

LogPipe *

s

)

log_threaded_source_worker_blocking_post()

void log_threaded_source_worker_blocking_post	(	LogThreadedSourceWorker *	self,
		LogMessage *	msg
	)

log_threaded_source_worker_close_batch()

void log_threaded_source_worker_close_batch

(

LogThreadedSourceWorker *

self

)

log_threaded_source_worker_free()

void log_threaded_source_worker_free

(

LogPipe *

s

)

log_threaded_source_worker_free_to_send()

gboolean log_threaded_source_worker_free_to_send

(

LogThreadedSourceWorker *

self

)

log_threaded_source_worker_init_instance()

void log_threaded_source_worker_init_instance	(	LogThreadedSourceWorker *	self,
		LogThreadedSourceDriver *	driver,
		gint	worker_index
	)

log_threaded_source_worker_options_defaults()

void log_threaded_source_worker_options_defaults

(

LogThreadedSourceWorkerOptions *

options

)

log_threaded_source_worker_options_destroy()

void log_threaded_source_worker_options_destroy

(

LogThreadedSourceWorkerOptions *

options

)

log_threaded_source_worker_options_init()

void log_threaded_source_worker_options_init	(	LogThreadedSourceWorkerOptions *	options,
		GlobalConfig *	cfg,
		const gchar *	group_name,
		gint	num_workers
	)

log_threaded_source_worker_post()

void log_threaded_source_worker_post	(	LogThreadedSourceWorker *	self,
		LogMessage *	msg
	)