#include "logqueue-disk.h"
#include "logpipe.h"
#include "messages.h"
#include "serialize.h"
#include "logmsg/logmsg-serialize.h"
#include "stats/stats-registry.h"
#include "stats/stats-cluster-single.h"
#include "reloc.h"
#include "qdisk.h"
#include "scratch-buffers.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/mman.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>

Include dependency graph for logqueue-disk.c:

Macros
#define	B_TO_KiB(x) ((x) / 1024)

Functions
gboolean	log_queue_disk_stop (LogQueue s, gboolean persistent)

gboolean	log_queue_disk_start (LogQueue *s)

const gchar *	log_queue_disk_get_filename (LogQueue *s)

void	log_queue_disk_free_method (LogQueueDisk *self)

void	log_queue_disk_update_disk_related_counters (LogQueueDisk *self)

LogMessage *	log_queue_disk_read_message (LogQueueDisk self, LogPathOptions path_options)

LogMessage *	log_queue_disk_peek_message (LogQueueDisk *self)

void	log_queue_disk_drop_message (LogQueueDisk self, LogMessage msg, const LogPathOptions *path_options)

void	log_queue_disk_restart_corrupted (LogQueueDisk *self)

void	log_queue_disk_init_instance (LogQueueDisk self, DiskQueueOptions options, const gchar qdisk_file_id, const gchar filename, const gchar persist_name, gint stats_level, StatsClusterKeyBuilder driver_sck_builder, StatsClusterKeyBuilder *queue_sck_builder)

gboolean	log_queue_disk_serialize_msg (LogQueueDisk self, LogMessage msg, GString *serialized)

gboolean	log_queue_disk_deserialize_msg (LogQueueDisk self, GString serialized, LogMessage **msg)

Variables
QueueType	log_queue_disk_type = "DISK"

Macro Definition Documentation

◆ B_TO_KiB

#define B_TO_KiB ( x ) ((x) / 1024)

Function Documentation

◆ log_queue_disk_deserialize_msg()

gboolean log_queue_disk_deserialize_msg	(	LogQueueDisk *	self,
		GString *	serialized,
		LogMessage **	msg
	)

◆ log_queue_disk_drop_message()

void log_queue_disk_drop_message	(	LogQueueDisk *	self,
		LogMessage *	msg,
		const LogPathOptions *	path_options
	)

◆ log_queue_disk_free_method()

void log_queue_disk_free_method ( LogQueueDisk * self )

◆ log_queue_disk_get_filename()

const gchar* log_queue_disk_get_filename ( LogQueue * s )

◆ log_queue_disk_init_instance()

void log_queue_disk_init_instance	(	LogQueueDisk *	self,
		DiskQueueOptions *	options,
		const gchar *	qdisk_file_id,
		const gchar *	filename,
		const gchar *	persist_name,
		gint	stats_level,
		StatsClusterKeyBuilder *	driver_sck_builder,
		StatsClusterKeyBuilder *	queue_sck_builder
	)

◆ log_queue_disk_peek_message()

LogMessage* log_queue_disk_peek_message ( LogQueueDisk * self )

◆ log_queue_disk_read_message()

LogMessage* log_queue_disk_read_message	(	LogQueueDisk *	self,
		LogPathOptions *	path_options
	)

◆ log_queue_disk_restart_corrupted()

void log_queue_disk_restart_corrupted ( LogQueueDisk * self )

◆ log_queue_disk_serialize_msg()

gboolean log_queue_disk_serialize_msg	(	LogQueueDisk *	self,
		LogMessage *	msg,
		GString *	serialized
	)

◆ log_queue_disk_start()

gboolean log_queue_disk_start ( LogQueue * s )

◆ log_queue_disk_stop()

gboolean log_queue_disk_stop	(	LogQueue *	s,
		gboolean *	persistent
	)

Macros

Functions

Variables