#include "afsocket.h"
#include "socket-options.h"
#include "transport-mapper.h"
#include "driver.h"
#include "logreader.h"
#include "dynamic-window-pool.h"
#include "atomic-gssize.h"
#include "stats/stats-counter.h"
#include <iv.h>

Include dependency graph for afsocket-source.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	AFSocketSourceDriver

Functions
void	afsocket_sd_set_keep_alive (LogDriver *self, gint enable)

void	afsocket_sd_set_max_connections (LogDriver *self, gint max_connections)

void	afsocket_sd_set_listen_backlog (LogDriver *self, gint listen_backlog)

void	afsocket_sd_set_dynamic_window_size (LogDriver *self, gint dynamic_window_size)

void	afsocket_sd_set_dynamic_window_stats_freq (LogDriver *self, gdouble stats_freq)

void	afsocket_sd_set_dynamic_window_realloc_ticks (LogDriver *self, gint realloc_ticks)

gboolean	afsocket_sd_setup_addresses_method (AFSocketSourceDriver *self)

gboolean	afsocket_sd_init_method (LogPipe *s)

gboolean	afsocket_sd_deinit_method (LogPipe *s)

void	afsocket_sd_free_method (LogPipe *self)

void	afsocket_sd_init_instance (AFSocketSourceDriver self, SocketOptions socket_options, TransportMapper transport_mapper, GlobalConfig cfg)

Function Documentation

◆ afsocket_sd_deinit_method()

gboolean afsocket_sd_deinit_method ( LogPipe * s )

◆ afsocket_sd_free_method()

void afsocket_sd_free_method ( LogPipe * self )

◆ afsocket_sd_init_instance()

void afsocket_sd_init_instance	(	AFSocketSourceDriver *	self,
		SocketOptions *	socket_options,
		TransportMapper *	transport_mapper,
		GlobalConfig *	cfg
	)

◆ afsocket_sd_init_method()

gboolean afsocket_sd_init_method ( LogPipe * s )

◆ afsocket_sd_set_dynamic_window_realloc_ticks()

void afsocket_sd_set_dynamic_window_realloc_ticks	(	LogDriver *	self,
		gint	realloc_ticks
	)

◆ afsocket_sd_set_dynamic_window_size()

void afsocket_sd_set_dynamic_window_size	(	LogDriver *	self,
		gint	dynamic_window_size
	)

◆ afsocket_sd_set_dynamic_window_stats_freq()

void afsocket_sd_set_dynamic_window_stats_freq	(	LogDriver *	self,
		gdouble	stats_freq
	)

◆ afsocket_sd_set_keep_alive()

void afsocket_sd_set_keep_alive	(	LogDriver *	self,
		gint	enable
	)

◆ afsocket_sd_set_listen_backlog()

void afsocket_sd_set_listen_backlog	(	LogDriver *	self,
		gint	listen_backlog
	)

◆ afsocket_sd_set_max_connections()

void afsocket_sd_set_max_connections	(	LogDriver *	self,
		gint	max_connections
	)

◆ afsocket_sd_setup_addresses_method()

gboolean afsocket_sd_setup_addresses_method ( AFSocketSourceDriver * self )

Classes

Functions