#include "afsocket-dest.h"
#include "messages.h"
#include "logwriter.h"
#include "gsocket.h"
#include "stats/stats-registry.h"
#include "mainloop.h"
#include "timeutils/misc.h"
#include "hostname.h"
#include "persist-state.h"
#include "stats/stats-cluster-single.h"
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>

Include dependency graph for afsocket-dest.c:

Functions
void	afsocket_kept_alive_connection_init_instance (AFSocketDestKeptAliveConnection s, const gchar transport, const gchar proto, GSockAddr dest_addr, LogWriter *writer)

void	afsocket_kept_alive_connection_free_method (AFSocketDestKeptAliveConnection *self)

gboolean	afsocket_dd_should_restore_connection_method (AFSocketDestDriver self, AFSocketDestKeptAliveConnection c)

void	afsocket_dd_set_keep_alive (LogDriver *s, gboolean enable)

void	afsocket_dd_stop_watches (AFSocketDestDriver *self)

void	afsocket_dd_connected_with_fd (gpointer s, gint fd, GSockAddr *saddr)

void	afsocket_dd_reconnect (AFSocketDestDriver *self)

gboolean	afsocket_dd_setup_addresses_method (AFSocketDestDriver *self)

void	afsocket_dd_restore_connection_method (AFSocketDestDriver self, AFSocketDestKeptAliveConnection item)

LogWriter *	afsocket_dd_construct_writer_method (AFSocketDestDriver *self)

gboolean	afsocket_dd_init (LogPipe *s)

void	afsocket_dd_save_connection (AFSocketDestDriver self, AFSocketDestKeptAliveConnection c)

gboolean	afsocket_dd_deinit (LogPipe *s)

void	afsocket_dd_free (LogPipe *s)

void	afsocket_dd_init_instance (AFSocketDestDriver self, SocketOptions socket_options, TransportMapper transport_mapper, GlobalConfig cfg)

Function Documentation

◆ afsocket_dd_connected_with_fd()

void afsocket_dd_connected_with_fd	(	gpointer	s,
		gint	fd,
		GSockAddr *	saddr
	)

◆ afsocket_dd_construct_writer_method()

LogWriter* afsocket_dd_construct_writer_method ( AFSocketDestDriver * self )

◆ afsocket_dd_deinit()

gboolean afsocket_dd_deinit ( LogPipe * s )

◆ afsocket_dd_free()

void afsocket_dd_free ( LogPipe * s )

◆ afsocket_dd_init()

gboolean afsocket_dd_init ( LogPipe * s )

◆ afsocket_dd_init_instance()

void afsocket_dd_init_instance	(	AFSocketDestDriver *	self,
		SocketOptions *	socket_options,
		TransportMapper *	transport_mapper,
		GlobalConfig *	cfg
	)

◆ afsocket_dd_reconnect()

void afsocket_dd_reconnect ( AFSocketDestDriver * self )

◆ afsocket_dd_restore_connection_method()

void afsocket_dd_restore_connection_method	(	AFSocketDestDriver *	self,
		AFSocketDestKeptAliveConnection *	item
	)

◆ afsocket_dd_save_connection()

void afsocket_dd_save_connection	(	AFSocketDestDriver *	self,
		AFSocketDestKeptAliveConnection *	c
	)

◆ afsocket_dd_set_keep_alive()

void afsocket_dd_set_keep_alive	(	LogDriver *	s,
		gboolean	enable
	)

◆ afsocket_dd_setup_addresses_method()

gboolean afsocket_dd_setup_addresses_method ( AFSocketDestDriver * self )

◆ afsocket_dd_should_restore_connection_method()

gboolean afsocket_dd_should_restore_connection_method	(	AFSocketDestDriver *	self,
		AFSocketDestKeptAliveConnection *	c
	)

◆ afsocket_dd_stop_watches()

void afsocket_dd_stop_watches ( AFSocketDestDriver * self )

◆ afsocket_kept_alive_connection_free_method()

void afsocket_kept_alive_connection_free_method ( AFSocketDestKeptAliveConnection * self )

◆ afsocket_kept_alive_connection_init_instance()

void afsocket_kept_alive_connection_init_instance	(	AFSocketDestKeptAliveConnection *	s,
		const gchar *	transport,
		const gchar *	proto,
		GSockAddr *	dest_addr,
		LogWriter *	writer
	)

Functions