file-reader.c File Reference

#include "file-reader.h"
#include "driver.h"
#include "messages.h"
#include "serialize.h"
#include "gprocess.h"
#include "stats/stats-registry.h"
#include "transport/transport-file.h"
#include "transport/transport-pipe.h"
#include "transport-prockmsg.h"
#include "logproto/logproto-buffered-server.h"
#include "file-monitor-factory.h"
#include "ack-tracker/ack_tracker_factory.h"
#include "stats/stats-cluster-key-builder.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <time.h>
#include <stdlib.h>
#include <glib/gprintf.h>
#include <iv.h>

Include dependency graph for file-reader.c:

Functions
gboolean	_iv_can_poll_fd (gint fd)
gint	file_reader_notify_method (LogPipe *s, gint notify_code, gpointer user_data)
void	file_reader_queue_method (LogPipe *s, LogMessage *msg, const LogPathOptions *path_options)
gboolean	file_reader_init_method (LogPipe *s)
gboolean	file_reader_deinit_method (LogPipe *s)
void	file_reader_free_method (LogPipe *s)
void	file_reader_remove_persist_state (FileReader *self)
void	file_reader_stop_follow_file (FileReader *self)
void	file_reader_cue_buffer_flush (FileReader *self)
void	file_reader_init_instance (FileReader *self, const gchar *filename, FileReaderOptions *options, FileOpener *opener, LogSrcDriver *owner, GlobalConfig *cfg, const gchar *persist_name_prefix)
FileReader *	file_reader_new (const gchar *filename, FileReaderOptions *options, FileOpener *opener, LogSrcDriver *owner, GlobalConfig *cfg)
void	file_reader_options_set_follow_freq (FileReaderOptions *options, gint follow_freq)
void	file_reader_options_set_follow_always_reads (FileReaderOptions *options, gboolean follow_always_reads)
gboolean	file_reader_options_set_follow_method (FileReaderOptions *options, const gchar *follow_method)
void	file_reader_options_set_multi_line_timeout (FileReaderOptions *options, gint multi_line_timeout)
void	file_reader_options_defaults (FileReaderOptions *options)
gboolean	file_reader_options_init (FileReaderOptions *options, GlobalConfig *cfg, const gchar *group)
void	file_reader_options_deinit (FileReaderOptions *options)

Function Documentation

_iv_can_poll_fd()

gboolean _iv_can_poll_fd

(

gint

fd

)

file_reader_cue_buffer_flush()

void file_reader_cue_buffer_flush

(

FileReader *

self

)

file_reader_deinit_method()

gboolean file_reader_deinit_method

(

LogPipe *

s

)

file_reader_free_method()

void file_reader_free_method

(

LogPipe *

s

)

file_reader_init_instance()

void file_reader_init_instance	(	FileReader *	self,
		const gchar *	filename,
		FileReaderOptions *	options,
		FileOpener *	opener,
		LogSrcDriver *	owner,
		GlobalConfig *	cfg,
		const gchar *	persist_name_prefix
	)

file_reader_init_method()

gboolean file_reader_init_method

(

LogPipe *

s

)

file_reader_new()

FileReader* file_reader_new	(	const gchar *	filename,
		FileReaderOptions *	options,
		FileOpener *	opener,
		LogSrcDriver *	owner,
		GlobalConfig *	cfg
	)

file_reader_notify_method()

gint file_reader_notify_method	(	LogPipe *	s,
		gint	notify_code,
		gpointer	user_data
	)

file_reader_options_defaults()

void file_reader_options_defaults

(

FileReaderOptions *

options

)

file_reader_options_deinit()

void file_reader_options_deinit

(

FileReaderOptions *

options

)

file_reader_options_init()

gboolean file_reader_options_init	(	FileReaderOptions *	options,
		GlobalConfig *	cfg,
		const gchar *	group
	)

file_reader_options_set_follow_always_reads()

void file_reader_options_set_follow_always_reads	(	FileReaderOptions *	options,
		gboolean	follow_always_reads
	)

file_reader_options_set_follow_freq()

void file_reader_options_set_follow_freq	(	FileReaderOptions *	options,
		gint	follow_freq
	)

file_reader_options_set_follow_method()

gboolean file_reader_options_set_follow_method	(	FileReaderOptions *	options,
		const gchar *	follow_method
	)

file_reader_options_set_multi_line_timeout()

void file_reader_options_set_multi_line_timeout	(	FileReaderOptions *	options,
		gint	multi_line_timeout
	)

file_reader_queue_method()

void file_reader_queue_method	(	LogPipe *	s,
		LogMessage *	msg,
		const LogPathOptions *	path_options
	)

file_reader_remove_persist_state()

void file_reader_remove_persist_state

(

FileReader *

self

)

file_reader_stop_follow_file()

void file_reader_stop_follow_file

(

FileReader *

self

)