#include "syslog-ng.h"
#include "driver.h"
#include "logsource.h"
#include "cfg.h"
#include "logpipe.h"
#include "logmsg/logmsg.h"
#include "msg-format.h"
#include "mainloop-threaded-worker.h"
#include "stats/stats-cluster-key-builder.h"

Include dependency graph for logthrsourcedrv.h:

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

Go to the source code of this file.

Classes
struct	LogThreadedSourceWorkerOptions

struct	WakeupCondition

struct	LogThreadedSourceWorker

struct	LogThreadedSourceDriver

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_driver_set_transport_name (LogThreadedSourceDriver self, const gchar transport_name)

void	log_threaded_source_driver_init_instance (LogThreadedSourceDriver self, GlobalConfig cfg)

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)

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

void	log_threaded_source_worker_free (LogPipe *s)

void	log_threaded_source_worker_close_batch (LogThreadedSourceWorker *self)

void	log_threaded_source_worker_blocking_post (LogThreadedSourceWorker self, LogMessage msg)

void	log_threaded_source_worker_post (LogThreadedSourceWorker self, LogMessage msg)

gboolean	log_threaded_source_worker_free_to_send (LogThreadedSourceWorker *self)

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

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

◆ 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
	)

Classes

Functions