diff options
Diffstat (limited to 'runtime/ratelimit.c')
| -rw-r--r-- | runtime/ratelimit.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/runtime/ratelimit.c b/runtime/ratelimit.c index 2df5f78a..d3d32b58 100644 --- a/runtime/ratelimit.c +++ b/runtime/ratelimit.c @@ -147,9 +147,11 @@ ratelimitAddMsg(ratelimit_t *ratelimit, multi_submit_t *pMultiSub, msg_t *pMsg) DEFiRet; if(pMultiSub == NULL) { -dbgprintf("DDDDD: multiSubmitAddMsg, not checking ratelimiter for single submit!\n"); -#warning missing multisub Implementation? - CHKiRet(submitMsg(pMsg)); + localRet = ratelimitMsg(ratelimit, pMsg, &repMsg); + if(repMsg != NULL) + CHKiRet(submitMsg2(repMsg)); + if(localRet == RS_RET_OK) + CHKiRet(submitMsg2(pMsg)); } else { localRet = ratelimitMsg(ratelimit, pMsg, &repMsg); if(repMsg != NULL) { |