logsource.c File Reference

#include "logsource.h"
#include "messages.h"
#include "host-resolve.h"
#include "stats/stats-registry.h"
#include "stats/stats-cluster-logpipe.h"
#include "stats/stats-cluster-single.h"
#include "msg-stats.h"
#include "ack-tracker/ack_tracker.h"
#include "ack-tracker/ack_tracker_factory.h"
#include "timeutils/misc.h"
#include "compat/time.h"
#include "scratch-buffers.h"
#include <string.h>
#include <unistd.h>

Include dependency graph for logsource.c:

Macros
#define	MAX_PID_CHAR_COUNT   20 /* max PID on 64 bit systems is 2^64 - 1, which is 19 characters, +1 for terminating 0 */

Functions
void	log_source_wakeup (LogSource *self)
void	log_source_flow_control_adjust (LogSource *self, guint32 window_size_increment)
void	log_source_flow_control_adjust_when_suspended (LogSource *self, guint32 window_size_increment)
void	log_source_disable_bookmark_saving (LogSource *self)
void	log_source_flow_control_suspend (LogSource *self)
void	log_source_enable_dynamic_window (LogSource *self, DynamicWindowPool *window_pool)
gboolean	log_source_is_dynamic_window_enabled (LogSource *self)
void	log_source_dynamic_window_update_statistics (LogSource *self)
void	log_source_dynamic_window_realloc (LogSource *self)
void	log_source_mangle_hostname (LogSource *self, LogMessage *msg)
gboolean	log_source_init (LogPipe *s)
gboolean	log_source_deinit (LogPipe *s)
void	log_source_post (LogSource *self, LogMessage *msg)
void	log_source_set_options (LogSource *self, LogSourceOptions *options, const gchar *stats_id, StatsClusterKeyBuilder *kb, gboolean threaded, LogExprNode *expr_node)
void	log_source_set_ack_tracker_factory (LogSource *self, AckTrackerFactory *factory)
void	log_source_set_name (LogSource *self, const gchar *name)
void	log_source_init_instance (LogSource *self, GlobalConfig *cfg)
void	log_source_free (LogPipe *s)
void	log_source_options_defaults (LogSourceOptions *options)
void	log_source_options_init (LogSourceOptions *options, GlobalConfig *cfg, const gchar *group_name)
void	log_source_options_destroy (LogSourceOptions *options)
void	log_source_options_set_tags (LogSourceOptions *options, GList *tags)
void	log_source_global_init (void)

Variables
gboolean	accurate_nanosleep = FALSE

Macro Definition Documentation

MAX_PID_CHAR_COUNT

#define MAX_PID_CHAR_COUNT   20 /* max PID on 64 bit systems is 2^64 - 1, which is 19 characters, +1 for terminating 0 */

Function Documentation

log_source_deinit()

gboolean log_source_deinit

(

LogPipe *

s

)

log_source_disable_bookmark_saving()

void log_source_disable_bookmark_saving

(

LogSource *

self

)

log_source_dynamic_window_realloc()

void log_source_dynamic_window_realloc

(

LogSource *

self

)

log_source_dynamic_window_update_statistics()

void log_source_dynamic_window_update_statistics

(

LogSource *

self

)

log_source_enable_dynamic_window()

void log_source_enable_dynamic_window	(	LogSource *	self,
		DynamicWindowPool *	window_pool
	)

log_source_flow_control_adjust()

void log_source_flow_control_adjust	(	LogSource *	self,
		guint32	window_size_increment
	)

log_source_flow_control_adjust_when_suspended()

void log_source_flow_control_adjust_when_suspended	(	LogSource *	self,
		guint32	window_size_increment
	)

log_source_flow_control_suspend()

void log_source_flow_control_suspend

(

LogSource *

self

)

log_source_free()

void log_source_free

(

LogPipe *

s

)

log_source_global_init()

void log_source_global_init

(

void

)

log_source_init()

gboolean log_source_init

(

LogPipe *

s

)

log_source_init_instance()

void log_source_init_instance	(	LogSource *	self,
		GlobalConfig *	cfg
	)

log_source_is_dynamic_window_enabled()

gboolean log_source_is_dynamic_window_enabled

(

LogSource *

self

)

log_source_mangle_hostname()

void log_source_mangle_hostname	(	LogSource *	self,
		LogMessage *	msg
	)

log_source_options_defaults()

void log_source_options_defaults

(

LogSourceOptions *

options

)

log_source_options_destroy()

void log_source_options_destroy

(

LogSourceOptions *

options

)

log_source_options_init()

void log_source_options_init	(	LogSourceOptions *	options,
		GlobalConfig *	cfg,
		const gchar *	group_name
	)

log_source_options_set_tags()

void log_source_options_set_tags	(	LogSourceOptions *	options,
		GList *	tags
	)

log_source_post()

void log_source_post	(	LogSource *	self,
		LogMessage *	msg
	)

log_source_set_ack_tracker_factory()

void log_source_set_ack_tracker_factory	(	LogSource *	self,
		AckTrackerFactory *	factory
	)

log_source_set_name()

void log_source_set_name	(	LogSource *	self,
		const gchar *	name
	)

log_source_set_options()

void log_source_set_options	(	LogSource *	self,
		LogSourceOptions *	options,
		const gchar *	stats_id,
		StatsClusterKeyBuilder *	kb,
		gboolean	threaded,
		LogExprNode *	expr_node
	)

log_source_wakeup()

void log_source_wakeup

(

LogSource *

self

)

Variable Documentation

accurate_nanosleep

gboolean accurate_nanosleep = FALSE