#include "logproto-buffered-server.h"
#include "logproto.h"
#include "messages.h"
#include "serialize.h"
#include "compat/string.h"
#include <errno.h>
#include <unistd.h>
#include <sys/stat.h>
#include <stdlib.h>

Include dependency graph for logproto-buffered-server.c:

Classes
struct	BufferedServerBookmarkData

Functions
LogProtoBufferedServerState *	log_proto_buffered_server_get_state (LogProtoBufferedServer *self)

void	log_proto_buffered_server_put_state (LogProtoBufferedServer *self)

gboolean	log_proto_buffered_server_restart_with_state (LogProtoServer s, PersistState persist_state, const gchar *persist_name)

LogProtoPrepareAction	log_proto_buffered_server_poll_prepare (LogProtoServer s, GIOCondition cond, gint *timeout G_GNUC_UNUSED)

LogProtoStatus	log_proto_buffered_server_fetch (LogProtoServer s, const guchar msg, gsize msg_len, gboolean may_read, LogTransportAuxData aux, Bookmark *bookmark)

gboolean	log_proto_buffered_server_validate_options_method (LogProtoServer *s)

void	log_proto_buffered_server_free_method (LogProtoServer *s)

void	log_proto_buffered_server_init (LogProtoBufferedServer self, LogTransport transport, const LogProtoServerOptionsStorage *options)

Function Documentation

◆ log_proto_buffered_server_fetch()

LogProtoStatus log_proto_buffered_server_fetch	(	LogProtoServer *	s,
		const guchar **	msg,
		gsize *	msg_len,
		gboolean *	may_read,
		LogTransportAuxData *	aux,
		Bookmark *	bookmark
	)

Returns: TRUE to indicate success, FALSE otherwise. The returned msg can be NULL even if no failure occurred.

◆ log_proto_buffered_server_free_method()

void log_proto_buffered_server_free_method ( LogProtoServer * s )

◆ log_proto_buffered_server_get_state()

LogProtoBufferedServerState* log_proto_buffered_server_get_state ( LogProtoBufferedServer * self )

◆ log_proto_buffered_server_init()

void log_proto_buffered_server_init	(	LogProtoBufferedServer *	self,
		LogTransport *	transport,
		const LogProtoServerOptionsStorage *	options
	)

◆ log_proto_buffered_server_poll_prepare()

LogProtoPrepareAction log_proto_buffered_server_poll_prepare	(	LogProtoServer *	s,
		GIOCondition *	cond,
		gint *timeout	G_GNUC_UNUSED
	)

◆ log_proto_buffered_server_put_state()

void log_proto_buffered_server_put_state ( LogProtoBufferedServer * self )

◆ log_proto_buffered_server_restart_with_state()

gboolean log_proto_buffered_server_restart_with_state	(	LogProtoServer *	s,
		PersistState *	persist_state,
		const gchar *	persist_name
	)

◆ log_proto_buffered_server_validate_options_method()

gboolean log_proto_buffered_server_validate_options_method ( LogProtoServer * s )

Classes

Functions