logreader.c File Reference

#include "logreader.h"
#include "stats/stats-cluster-single.h"
#include "mainloop-call.h"
#include "ack-tracker/ack_tracker.h"
#include "ack-tracker/ack_tracker_factory.h"
#include "str-format.h"

Include dependency graph for logreader.c:

Functions
void	log_reader_set_peer_addr (LogReader *s, GSockAddr *peer_addr)
void	log_reader_set_local_addr (LogReader *s, GSockAddr *local_addr)
void	log_reader_set_options (LogReader *s, LogPipe *control, LogReaderOptions *options, const gchar *stats_id, StatsClusterKeyBuilder *kb)
void	log_reader_set_name (LogReader *self, const gchar *name)
void	log_reader_disable_bookmark_saving (LogReader *s)
void	log_reader_close_proto_deferred (gpointer s)
void	log_reader_close_proto (LogReader *self)
void	log_reader_open (LogReader *self, LogProtoServer *proto, PollEvents *poll_events)
gboolean	log_reader_is_opened (LogReader *self)
void	log_reader_trigger_one_check (LogReader *self)
LogReader *	log_reader_new (GlobalConfig *cfg)
void	log_reader_options_defaults (LogReaderOptions *options)
void	log_reader_options_init (LogReaderOptions *options, GlobalConfig *cfg, const gchar *group_name)
void	log_reader_options_destroy (LogReaderOptions *options)
gboolean	log_reader_options_process_flag (LogReaderOptions *options, const gchar *flag)

Variables
CfgFlagHandler	log_reader_flag_handlers []

Function Documentation

log_reader_close_proto()

void log_reader_close_proto

(

LogReader *

self

)

log_reader_close_proto_deferred()

void log_reader_close_proto_deferred

(

gpointer

s

)

log_reader_disable_bookmark_saving()

void log_reader_disable_bookmark_saving

(

LogReader *

s

)

log_reader_is_opened()

gboolean log_reader_is_opened

(

LogReader *

self

)

log_reader_new()

LogReader* log_reader_new

(

GlobalConfig *

cfg

)

log_reader_open()

void log_reader_open	(	LogReader *	self,
		LogProtoServer *	proto,
		PollEvents *	poll_events
	)

log_reader_options_defaults()

void log_reader_options_defaults

(

LogReaderOptions *

options

)

log_reader_options_destroy()

void log_reader_options_destroy

(

LogReaderOptions *

options

)

log_reader_options_init()

void log_reader_options_init	(	LogReaderOptions *	options,
		GlobalConfig *	cfg,
		const gchar *	group_name
	)

log_reader_options_process_flag()

gboolean log_reader_options_process_flag	(	LogReaderOptions *	options,
		const gchar *	flag
	)

log_reader_set_local_addr()

void log_reader_set_local_addr	(	LogReader *	s,
		GSockAddr *	local_addr
	)

log_reader_set_name()

void log_reader_set_name	(	LogReader *	self,
		const gchar *	name
	)

log_reader_set_options()

void log_reader_set_options	(	LogReader *	s,
		LogPipe *	control,
		LogReaderOptions *	options,
		const gchar *	stats_id,
		StatsClusterKeyBuilder *	kb
	)

log_reader_set_peer_addr()

void log_reader_set_peer_addr	(	LogReader *	s,
		GSockAddr *	peer_addr
	)

log_reader_trigger_one_check()

void log_reader_trigger_one_check ( LogReader *  self )

inline

Variable Documentation

log_reader_flag_handlers

CfgFlagHandler log_reader_flag_handlers[]

Initial value:

=
{
  
 
  
  { "kernel",                     CFH_SET, offsetof(LogReaderOptions, flags),               LR_KERNEL },
  { "empty-lines",                CFH_SET, offsetof(LogReaderOptions, flags),               LR_EMPTY_LINES },
  { "threaded",                   CFH_SET, offsetof(LogReaderOptions, flags),               LR_THREADED },
  { "ignore-aux-data",            CFH_SET, offsetof(LogReaderOptions, flags),               LR_IGNORE_AUX_DATA },
  { "exit-on-eof",                CFH_SET, offsetof(LogReaderOptions, flags),               LR_EXIT_ON_EOF },
  { NULL },
}