diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-14 17:53:35 +0000 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-14 17:53:35 +0000 |
commit | ec27ea55f38d78fd97c80f8554870693a96be332 (patch) | |
tree | f1b13978cda52a0353d13fd3b4ac304407a659ba /queue.h | |
parent | 16eba18af23dad76e717ae9fde5dfea31ce6f2aa (diff) | |
download | rsyslog-ec27ea55f38d78fd97c80f8554870693a96be332.tar.gz rsyslog-ec27ea55f38d78fd97c80f8554870693a96be332.tar.xz rsyslog-ec27ea55f38d78fd97c80f8554870693a96be332.zip |
begin disk assisted queue memory queue modes (not fully implemented yet)
Diffstat (limited to 'queue.h')
-rw-r--r-- | queue.h | 13 |
1 files changed, 9 insertions, 4 deletions
@@ -61,10 +61,12 @@ typedef struct qLinkedList_S { } qLinkedList_t; typedef enum { - eWRKTHRDCMD_RUN, - eWRKTHRDCMD_SHUTDOWN, - eWRKTHRDCMD_SHUTDOWN_IMMEDIATE, - eWRKTHRDCMD_TERMINATED /* granted, that's more a state than a cmd - thread is dead... */ + eWRKTHRDCMD_NEVER_RAN = 0, /* granted, that's more a state than a cmd - thread is dead... */ + eWRKTHRDCMD_TERMINATED = 1, /* granted, that's more a state than a cmd - thread is dead... */ + /* ALL active states MUST be numerically higher than eWRKTHRDCMD_TERMINATED and NONE must be lower! */ + eWRKTHRDCMD_RUN = 2, + eWRKTHRDCMD_SHUTDOWN = 3, + eWRKTHRDCMD_SHUTDOWN_IMMEDIATE = 4 } qWrkCmd_t; /* commands for queue worker threads */ typedef struct qWrkThrd_s { @@ -114,6 +116,9 @@ typedef struct queue_s { size_t lenFilePrefix; int iNumberFiles; /* how many files make up the queue? */ size_t iMaxFileSize; /* max size for a single queue file */ + int bIsDA; /* is this queue disk assisted? */ + int bRunsDA; /* is this queue actually *running* disk assisted? */ + struct queue_s *pqDA; /* queue for disk-assisted modes */ /* now follow queueing mode specific data elements */ union { /* different data elements based on queue type (qType) */ struct { |