summaryrefslogtreecommitdiffstats
path: root/wtp.c
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.c
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.c')
-rw-r--r--wtp.c1
1 files changed, 1 insertions, 0 deletions
diff --git a/wtp.c b/wtp.c
index 1c2ea30f..d6192bc0 100644
--- a/wtp.c
+++ b/wtp.c
@@ -545,6 +545,7 @@ DEFpropSetMeth(wtp, pUsr, void*);
DEFpropSetMethPTR(wtp, pmutUsr, pthread_mutex_t);
DEFpropSetMethPTR(wtp, pcondBusy, pthread_cond_t);
DEFpropSetMethFP(wtp, pfChkStopWrkr, rsRetVal(*pVal)(void*, int));
+DEFpropSetMethFP(wtp, pfRateLimiter, rsRetVal(*pVal)(void*));
DEFpropSetMethFP(wtp, pfIsIdle, rsRetVal(*pVal)(void*, int));
DEFpropSetMethFP(wtp, pfDoWork, rsRetVal(*pVal)(void*, void*, int));
DEFpropSetMethFP(wtp, pfOnIdle, rsRetVal(*pVal)(void*, int));