#include <ulogd/ulogd.h>
Data Structures | |
struct | db_driver |
struct | db_stmt_ring |
struct | db_stmt |
struct | db_instance |
Macros | |
#define | TIME_ERR ((time_t)-1) /* Be paranoid */ |
#define | RECONNECT_DEFAULT 2 |
#define | MAX_ONESHOT_REQUEST 10 |
#define | RING_BUFFER_DEFAULT_SIZE 0 |
#define | DB_CES |
#define | DB_CE_NUM 7 |
#define | table_ce(x) (x->ces[0]) |
#define | reconnect_ce(x) (x->ces[1]) |
#define | timeout_ce(x) (x->ces[2]) |
#define | procedure_ce(x) (x->ces[3]) |
#define | backlog_memcap_ce(x) (x->ces[4]) |
#define | backlog_oneshot_ce(x) (x->ces[5]) |
#define | ringsize_ce(x) (x->ces[6]) |
Enumerations | |
enum | { RING_NO_QUERY, RING_QUERY_READY } |
Functions | |
void | ulogd_db_signal (struct ulogd_pluginstance *upi, int signal) |
int | ulogd_db_start (struct ulogd_pluginstance *upi) |
int | ulogd_db_stop (struct ulogd_pluginstance *upi) |
int | ulogd_db_interp (struct ulogd_pluginstance *upi) |
int | ulogd_db_configure (struct ulogd_pluginstance *upi, struct ulogd_pluginstance_stack *stack) |
#define backlog_memcap_ce | ( | x | ) | (x->ces[4]) |
Referenced by ulogd_db_configure().
#define backlog_oneshot_ce | ( | x | ) | (x->ces[5]) |
Referenced by ulogd_db_configure().
#define DB_CE_NUM 7 |
#define DB_CES |
#define MAX_ONESHOT_REQUEST 10 |
#define procedure_ce | ( | x | ) | (x->ces[3]) |
#define reconnect_ce | ( | x | ) | (x->ces[1]) |
#define RECONNECT_DEFAULT 2 |
#define RING_BUFFER_DEFAULT_SIZE 0 |
#define ringsize_ce | ( | x | ) | (x->ces[6]) |
Referenced by ulogd_db_configure().
#define table_ce | ( | x | ) | (x->ces[0]) |
#define TIME_ERR ((time_t)-1) /* Be paranoid */ |
#define timeout_ce | ( | x | ) | (x->ces[2]) |
int ulogd_db_configure | ( | struct ulogd_pluginstance * | upi, |
struct ulogd_pluginstance_stack * | stack | ||
) |
References db_instance::backlog, db_instance::backlog_full, db_instance::backlog_memcap, backlog_memcap_ce, db_instance::backlog_memusage, db_instance::backlog_oneshot, backlog_oneshot_ce, db_driver::close_db, ulogd_pluginstance::config_kset, config_parse_file(), db_instance::driver, db_driver::get_columns, ulogd_pluginstance::id, INIT_LLIST_HEAD, db_driver::open_db, ulogd_pluginstance::private, db_instance::ring, ringsize_ce, db_stmt_ring::size, ULOGD_ERROR, ulogd_log, and ULOGD_NOTICE.
int ulogd_db_interp | ( | struct ulogd_pluginstance * | upi | ) |
References db_instance::interp, and ulogd_pluginstance::private.
void ulogd_db_signal | ( | struct ulogd_pluginstance * | upi, |
int | signal | ||
) |
References db_instance::db_thread_id, NULL, ulogd_pluginstance::private, db_instance::ring, s, db_stmt_ring::size, ulogd_db_start(), ULOGD_ERROR, and ulogd_log.
int ulogd_db_start | ( | struct ulogd_pluginstance * | upi | ) |
References db_driver::close_db, db_stmt_ring::cond, db_instance::db_thread_id, db_instance::driver, db_instance::interp, db_stmt_ring::length, db_stmt_ring::mutex, NULL, db_driver::open_db, ulogd_pluginstance::private, db_stmt_ring::ring, db_instance::ring, db_stmt_ring::size, db_instance::stmt, ulogd_log, ULOGD_NOTICE, and db_stmt_ring::wr_place.
Referenced by ulogd_db_signal().
int ulogd_db_stop | ( | struct ulogd_pluginstance * | upi | ) |
References ulogd_pluginstance::input, ulogd_keyset::keys, and NULL.