#include "logqueue.h"
#include "logpipe.h"
#include "messages.h"
#include "serialize.h"
#include "stats/stats-registry.h"
#include "stats/stats-counter.h"
#include "stats/stats-cluster-single.h"
#include "mainloop-worker.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <iv_thread.h>

Include dependency graph for logqueue-fifo.c:

Classes
struct	InputQueue

struct	OverflowQueue

struct	LogQueueFifo

Functions
gboolean	log_queue_fifo_is_empty_racy (LogQueue *s)

LogQueue *	log_queue_fifo_new (gint log_fifo_size, const gchar persist_name, gint stats_level, StatsClusterKeyBuilder driver_sck_builder, StatsClusterKeyBuilder *queue_sck_builder)

QueueType	log_queue_fifo_get_type (void)

Variables
QueueType	log_queue_fifo_type = "FIFO"

Function Documentation

◆ log_queue_fifo_get_type()

QueueType log_queue_fifo_get_type ( void )

◆ log_queue_fifo_is_empty_racy()

gboolean log_queue_fifo_is_empty_racy ( LogQueue * s )

◆ log_queue_fifo_new()

LogQueue* log_queue_fifo_new	(	gint	log_fifo_size,
		const gchar *	persist_name,
		gint	stats_level,
		StatsClusterKeyBuilder *	driver_sck_builder,
		StatsClusterKeyBuilder *	queue_sck_builder
	)

Variable Documentation

◆ log_queue_fifo_type

QueueType log_queue_fifo_type = "FIFO"

Classes