logqueue.c File Reference

#include "logqueue.h"
#include "stats/stats-registry.h"
#include "stats/stats-cluster-single.h"
#include "messages.h"
#include "timeutils/misc.h"

Include dependency graph for logqueue.c:

Functions
void	log_queue_memory_usage_add (LogQueue *self, gsize value)
void	log_queue_memory_usage_sub (LogQueue *self, gsize value)
void	log_queue_queued_messages_add (LogQueue *self, gsize value)
void	log_queue_queued_messages_sub (LogQueue *self, gsize value)
void	log_queue_queued_messages_inc (LogQueue *self)
void	log_queue_queued_messages_dec (LogQueue *self)
void	log_queue_queued_messages_reset (LogQueue *self)
void	log_queue_dropped_messages_inc (LogQueue *self)
void	log_queue_push_notify (LogQueue *self)
void	log_queue_reset_parallel_push (LogQueue *self)
void	log_queue_set_parallel_push (LogQueue *self, LogQueuePushNotifyFunc parallel_push_notify, gpointer user_data, GDestroyNotify user_data_destroy)
gboolean	log_queue_check_items (LogQueue *self, gint *timeout, LogQueuePushNotifyFunc parallel_push_notify, gpointer user_data, GDestroyNotify user_data_destroy)
void	log_queue_mark_as_abandoned (LogQueue *self)
void	log_queue_init_instance (LogQueue *self, const gchar *persist_name, gint stats_level, StatsClusterKeyBuilder *driver_sck_builder, StatsClusterKeyBuilder *queue_sck_builder)
void	log_queue_free_method (LogQueue *self)

Function Documentation

log_queue_check_items()

gboolean log_queue_check_items	(	LogQueue *	self,
		gint *	timeout,
		LogQueuePushNotifyFunc	parallel_push_notify,
		gpointer	user_data,
		GDestroyNotify	user_data_destroy
	)

log_queue_dropped_messages_inc()

void log_queue_dropped_messages_inc

(

LogQueue *

self

)

log_queue_free_method()

void log_queue_free_method

(

LogQueue *

self

)

log_queue_init_instance()

void log_queue_init_instance	(	LogQueue *	self,
		const gchar *	persist_name,
		gint	stats_level,
		StatsClusterKeyBuilder *	driver_sck_builder,
		StatsClusterKeyBuilder *	queue_sck_builder
	)

log_queue_mark_as_abandoned()

void log_queue_mark_as_abandoned ( LogQueue *  self )

inline

log_queue_memory_usage_add()

void log_queue_memory_usage_add	(	LogQueue *	self,
		gsize	value
	)

log_queue_memory_usage_sub()

void log_queue_memory_usage_sub	(	LogQueue *	self,
		gsize	value
	)

log_queue_push_notify()

void log_queue_push_notify

(

LogQueue *

self

)

log_queue_queued_messages_add()

void log_queue_queued_messages_add	(	LogQueue *	self,
		gsize	value
	)

log_queue_queued_messages_dec()

void log_queue_queued_messages_dec

(

LogQueue *

self

)

log_queue_queued_messages_inc()

void log_queue_queued_messages_inc

(

LogQueue *

self

)

log_queue_queued_messages_reset()

void log_queue_queued_messages_reset

(

LogQueue *

self

)

log_queue_queued_messages_sub()

void log_queue_queued_messages_sub	(	LogQueue *	self,
		gsize	value
	)

log_queue_reset_parallel_push()

void log_queue_reset_parallel_push

(

LogQueue *

self

)

log_queue_set_parallel_push()

void log_queue_set_parallel_push	(	LogQueue *	self,
		LogQueuePushNotifyFunc	parallel_push_notify,
		gpointer	user_data,
		GDestroyNotify	user_data_destroy
	)