summaryrefslogtreecommitdiffstats
path: root/wtp.h
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2008-04-02 16:53:29 +0000
committerRainer Gerhards <rgerhards@adiscon.com>2008-04-02 16:53:29 +0000
commit9b48c4a481c64503605f25e1d0648d24f43437f1 (patch)
tree017325a20b756a2047cb3eb7d9aacdf19a52d964 /wtp.h
parent38f0cd67626ce56b0014b05b513e2e573da25e6f (diff)
downloadrsyslog-9b48c4a481c64503605f25e1d0648d24f43437f1.tar.gz
rsyslog-9b48c4a481c64503605f25e1d0648d24f43437f1.tar.xz
rsyslog-9b48c4a481c64503605f25e1d0648d24f43437f1.zip
begun working on time-window based dequeueing (and rate limiting in
general)
Diffstat (limited to 'wtp.h')
-rw-r--r--wtp.h1
1 files changed, 1 insertions, 0 deletions
diff --git a/wtp.h b/wtp.h
index 6100fe52..b928b149 100644
--- a/wtp.h
+++ b/wtp.h
@@ -68,6 +68,7 @@ typedef struct wtp_s {
pthread_mutex_t *pmutUsr;
pthread_cond_t *pcondBusy; /* condition the user will signal "busy again, keep runing" on (awakes worker) */
rsRetVal (*pfChkStopWrkr)(void *pUsr, int);
+ rsRetVal (*pfRateLimiter)(void *pUsr);
rsRetVal (*pfIsIdle)(void *pUsr, int);
rsRetVal (*pfDoWork)(void *pUsr, void *pWti, int);
rsRetVal (*pfOnIdle)(void *pUsr, int);