afsocket-source.c File Reference

#include "afsocket-source.h"
#include "messages.h"
#include "fdhelpers.h"
#include "gsocket.h"
#include "stats/stats-registry.h"
#include "stats/stats-cluster-single.h"
#include "stats/stats-cluster-key-builder.h"
#include "mainloop.h"
#include "poll-fd-events.h"
#include "timeutils/misc.h"
#include "afsocket-signals.h"
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>

Include dependency graph for afsocket-source.c:

Classes
struct	AFSocketSourceConnection

Macros
#define	MAX_ACCEPTS_AT_A_TIME   30
#define	_packet_stats_timer_init(s)
#define	_packet_stats_timer_start(s)
#define	_packet_stats_timer_stop(s)
#define	_register_packet_stats(s, l, ll)
#define	_unregister_packet_stats(s, l, ll)

Functions
AFSocketSourceConnection *	afsocket_sc_new (GSockAddr *peer_addr, GSockAddr *local_addr, int fd, GlobalConfig *cfg)
void	afsocket_sd_add_connection (AFSocketSourceDriver *self, AFSocketSourceConnection *connection)
void	afsocket_sd_set_keep_alive (LogDriver *s, gint enable)
void	afsocket_sd_set_max_connections (LogDriver *s, gint max_connections)
void	afsocket_sd_set_listen_backlog (LogDriver *s, gint listen_backlog)
void	afsocket_sd_set_dynamic_window_size (LogDriver *s, gint dynamic_window_size)
void	afsocket_sd_set_dynamic_window_stats_freq (LogDriver *s, gdouble stats_freq)
void	afsocket_sd_set_dynamic_window_realloc_ticks (LogDriver *s, 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 *s)
void	afsocket_sd_init_instance (AFSocketSourceDriver *self, SocketOptions *socket_options, TransportMapper *transport_mapper, GlobalConfig *cfg)

Macro Definition Documentation

_packet_stats_timer_init

#define _packet_stats_timer_init

(

s

)

_packet_stats_timer_start

#define _packet_stats_timer_start

(

s

)

_packet_stats_timer_stop

#define _packet_stats_timer_stop

(

s

)

_register_packet_stats

#define _register_packet_stats	(		s,
			l,
			ll
	)

_unregister_packet_stats

#define _unregister_packet_stats	(		s,
			l,
			ll
	)

MAX_ACCEPTS_AT_A_TIME

#define MAX_ACCEPTS_AT_A_TIME   30

Function Documentation

afsocket_sc_new()

AFSocketSourceConnection* afsocket_sc_new	(	GSockAddr *	peer_addr,
		GSockAddr *	local_addr,
		int	fd,
		GlobalConfig *	cfg
	)

afsocket_sd_add_connection()

void afsocket_sd_add_connection	(	AFSocketSourceDriver *	self,
		AFSocketSourceConnection *	connection
	)

afsocket_sd_deinit_method()

gboolean afsocket_sd_deinit_method

(

LogPipe *

s

)

afsocket_sd_free_method()

void afsocket_sd_free_method

(

LogPipe *

s

)

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 *	s,
		gint	realloc_ticks
	)

afsocket_sd_set_dynamic_window_size()

void afsocket_sd_set_dynamic_window_size	(	LogDriver *	s,
		gint	dynamic_window_size
	)

afsocket_sd_set_dynamic_window_stats_freq()

void afsocket_sd_set_dynamic_window_stats_freq	(	LogDriver *	s,
		gdouble	stats_freq
	)

afsocket_sd_set_keep_alive()

void afsocket_sd_set_keep_alive	(	LogDriver *	s,
		gint	enable
	)

afsocket_sd_set_listen_backlog()

void afsocket_sd_set_listen_backlog	(	LogDriver *	s,
		gint	listen_backlog
	)

afsocket_sd_set_max_connections()

void afsocket_sd_set_max_connections	(	LogDriver *	s,
		gint	max_connections
	)

afsocket_sd_setup_addresses_method()

gboolean afsocket_sd_setup_addresses_method

(

AFSocketSourceDriver *

self

)