qdisk.h File Reference

#include "syslog-ng.h"
#include "diskq-options.h"

Include dependency graph for qdisk.h:

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

Go to the source code of this file.

Classes
struct	QDiskQueuePosition

Macros
#define	LOG_PATH_OPTIONS_FOR_BACKLOG   GINT_TO_POINTER(0x80000000)
#define	QDISK_RESERVED_SPACE   4096
#define	LOG_PATH_OPTIONS_TO_POINTER(lpo)   GUINT_TO_POINTER(0x80000000 | (lpo)->ack_needed)
#define	POINTER_TO_LOG_PATH_OPTIONS(ptr, lpo)

Typedefs
typedef gboolean(*	QDiskSerializeFunc) (SerializeArchive *sa, gpointer user_data)
typedef gboolean(*	QDiskDeSerializeFunc) (SerializeArchive *sa, gpointer user_data)

Functions
QDisk *	qdisk_new (DiskQueueOptions *options, const gchar *file_id, const gchar *filename)
gboolean	qdisk_is_space_avail (QDisk *self, gint at_least)
gint64	qdisk_get_max_useful_space (QDisk *self)
gint64	qdisk_get_empty_space (QDisk *self)
gint64	qdisk_get_used_useful_space (QDisk *self)
gboolean	qdisk_push_tail (QDisk *self, GString *record)
gboolean	qdisk_pop_head (QDisk *self, GString *record)
gboolean	qdisk_peek_head (QDisk *self, GString *record)
gboolean	qdisk_remove_head (QDisk *self)
gboolean	qdisk_ack_backlog (QDisk *self)
gboolean	qdisk_rewind_backlog (QDisk *self, guint rewind_count)
void	qdisk_empty_backlog (QDisk *self)
gint64	qdisk_get_next_tail_position (QDisk *self)
gint64	qdisk_get_next_head_position (QDisk *self)
gboolean	qdisk_start (QDisk *self, GQueue *front_cache, GQueue *backlog, GQueue *flow_control_window)
gboolean	qdisk_stop (QDisk *self, GQueue *front_cache, GQueue *backlog, GQueue *flow_control_window)
void	qdisk_reset_file_if_empty (QDisk *self)
gboolean	qdisk_started (QDisk *self)
void	qdisk_free (QDisk *self)
DiskQueueOptions *	qdisk_get_options (QDisk *self)
gint64	qdisk_get_length (QDisk *self)
gint64	qdisk_get_maximum_size (QDisk *self)
gint64	qdisk_get_writer_head (QDisk *self)
gint64	qdisk_get_reader_head (QDisk *self)
gint64	qdisk_get_backlog_head (QDisk *self)
gint64	qdisk_get_backlog_count (QDisk *self)
gint	qdisk_get_flow_control_window_bytes (QDisk *self)
gboolean	qdisk_is_read_only (QDisk *self)
const gchar *	qdisk_get_filename (QDisk *self)
gint64	qdisk_get_file_size (QDisk *self)
gchar *	qdisk_get_next_filename (const gchar *dir, gboolean reliable)
gboolean	qdisk_is_file_a_disk_buffer_file (const gchar *filename)
gboolean	qdisk_is_disk_buffer_file_reliable (const gchar *filename, gboolean *reliable)
gboolean	qdisk_serialize (GString *serialized, QDiskSerializeFunc serialize_func, gpointer user_data, GError **error)
gboolean	qdisk_deserialize (GString *serialized, QDiskDeSerializeFunc deserialize_func, gpointer user_data, GError **error)

Macro Definition Documentation

LOG_PATH_OPTIONS_FOR_BACKLOG

#define LOG_PATH_OPTIONS_FOR_BACKLOG   GINT_TO_POINTER(0x80000000)

LOG_PATH_OPTIONS_TO_POINTER

#define LOG_PATH_OPTIONS_TO_POINTER

(

lpo

)

GUINT_TO_POINTER(0x80000000 | (lpo)->ack_needed)

POINTER_TO_LOG_PATH_OPTIONS

#define POINTER_TO_LOG_PATH_OPTIONS	(		ptr,
			lpo
	)

Value:

({ \
  gpointer p = ptr; \
  (lpo)->ack_needed = (GPOINTER_TO_INT(p) & ~0x80000000); \
})

QDISK_RESERVED_SPACE

#define QDISK_RESERVED_SPACE   4096

Typedef Documentation

QDiskDeSerializeFunc

typedef gboolean(* QDiskDeSerializeFunc) (SerializeArchive *sa, gpointer user_data)

QDiskSerializeFunc

typedef gboolean(* QDiskSerializeFunc) (SerializeArchive *sa, gpointer user_data)

Function Documentation

qdisk_ack_backlog()

gboolean qdisk_ack_backlog

(

QDisk *

self

)

qdisk_deserialize()

gboolean qdisk_deserialize	(	GString *	serialized,
		QDiskDeSerializeFunc	deserialize_func,
		gpointer	user_data,
		GError **	error
	)

qdisk_empty_backlog()

void qdisk_empty_backlog

(

QDisk *

self

)

qdisk_free()

void qdisk_free

(

QDisk *

self

)

qdisk_get_backlog_count()

gint64 qdisk_get_backlog_count

(

QDisk *

self

)

qdisk_get_backlog_head()

gint64 qdisk_get_backlog_head

(

QDisk *

self

)

qdisk_get_empty_space()

gint64 qdisk_get_empty_space

(

QDisk *

self

)

qdisk_get_file_size()

gint64 qdisk_get_file_size

(

QDisk *

self

)

qdisk_get_filename()

const gchar* qdisk_get_filename

(

QDisk *

self

)

qdisk_get_flow_control_window_bytes()

gint qdisk_get_flow_control_window_bytes

(

QDisk *

self

)

qdisk_get_length()

gint64 qdisk_get_length

(

QDisk *

self

)

qdisk_get_max_useful_space()

gint64 qdisk_get_max_useful_space

(

QDisk *

self

)

qdisk_get_maximum_size()

gint64 qdisk_get_maximum_size

(

QDisk *

self

)

qdisk_get_next_filename()

gchar* qdisk_get_next_filename	(	const gchar *	dir,
		gboolean	reliable
	)

qdisk_get_next_head_position()

gint64 qdisk_get_next_head_position

(

QDisk *

self

)

qdisk_get_next_tail_position()

gint64 qdisk_get_next_tail_position

(

QDisk *

self

)

qdisk_get_options()

DiskQueueOptions* qdisk_get_options

(

QDisk *

self

)

qdisk_get_reader_head()

gint64 qdisk_get_reader_head

(

QDisk *

self

)

qdisk_get_used_useful_space()

gint64 qdisk_get_used_useful_space

(

QDisk *

self

)

qdisk_get_writer_head()

gint64 qdisk_get_writer_head

(

QDisk *

self

)

qdisk_is_disk_buffer_file_reliable()

gboolean qdisk_is_disk_buffer_file_reliable	(	const gchar *	filename,
		gboolean *	reliable
	)

qdisk_is_file_a_disk_buffer_file()

gboolean qdisk_is_file_a_disk_buffer_file

(

const gchar *

filename

)

qdisk_is_read_only()

gboolean qdisk_is_read_only

(

QDisk *

self

)

qdisk_is_space_avail()

gboolean qdisk_is_space_avail	(	QDisk *	self,
		gint	at_least
	)

qdisk_new()

QDisk* qdisk_new	(	DiskQueueOptions *	options,
		const gchar *	file_id,
		const gchar *	filename
	)

qdisk_peek_head()

gboolean qdisk_peek_head	(	QDisk *	self,
		GString *	record
	)

qdisk_pop_head()

gboolean qdisk_pop_head	(	QDisk *	self,
		GString *	record
	)

qdisk_push_tail()

gboolean qdisk_push_tail	(	QDisk *	self,
		GString *	record
	)

qdisk_remove_head()

gboolean qdisk_remove_head

(

QDisk *

self

)

qdisk_reset_file_if_empty()

void qdisk_reset_file_if_empty

(

QDisk *

self

)

qdisk_rewind_backlog()

gboolean qdisk_rewind_backlog	(	QDisk *	self,
		guint	rewind_count
	)

qdisk_serialize()

gboolean qdisk_serialize	(	GString *	serialized,
		QDiskSerializeFunc	serialize_func,
		gpointer	user_data,
		GError **	error
	)

qdisk_start()

gboolean qdisk_start	(	QDisk *	self,
		GQueue *	front_cache,
		GQueue *	backlog,
		GQueue *	flow_control_window
	)

qdisk_started()

gboolean qdisk_started

(

QDisk *

self

)

qdisk_stop()

gboolean qdisk_stop	(	QDisk *	self,
		GQueue *	front_cache,
		GQueue *	backlog,
		GQueue *	flow_control_window
	)