diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-11-05 17:04:30 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-11-05 17:04:30 +0100 |
| commit | 704bb9fc2165688ec23f9c7f1fe2776d2c2efa21 (patch) | |
| tree | 806e16cf6372e402f2b4b09b41cc808158b979af /runtime/queue.c | |
| parent | 6a61b91815b7be2320daa86b4392fda39aeb7be5 (diff) | |
| download | rsyslog-704bb9fc2165688ec23f9c7f1fe2776d2c2efa21.tar.gz rsyslog-704bb9fc2165688ec23f9c7f1fe2776d2c2efa21.tar.bz2 rsyslog-704bb9fc2165688ec23f9c7f1fe2776d2c2efa21.zip | |
queue: mini-improvement in deserializer (stage work)
Diffstat (limited to 'runtime/queue.c')
| -rw-r--r-- | runtime/queue.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index 306b88ed..9113ccb5 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -921,7 +921,7 @@ finalize_it: static rsRetVal qDeqDisk(qqueue_t *pThis, msg_t **ppMsg) { DEFiRet; - iRet = objDeserializeWithMethods(ppMsg, (uchar*) "msg", pThis->tVars.disk.pReadDeq, NULL, + iRet = objDeserializeWithMethods(ppMsg, (uchar*) "msg", 3, pThis->tVars.disk.pReadDeq, NULL, NULL, msgConstructForDeserializer, msgConstructFinalizer, MsgSetProperty); RETiRet; } @@ -947,7 +947,7 @@ static rsRetVal qDelDisk(qqueue_t *pThis) int64 offsOut; CHKiRet(strm.GetCurrOffset(pThis->tVars.disk.pReadDel, &offsIn)); - CHKiRet(objDeserializeWithMethods(&pDummyObj, (uchar*) "msg", pThis->tVars.disk.pReadDel, + CHKiRet(objDeserializeWithMethods(&pDummyObj, (uchar*) "msg", 3, pThis->tVars.disk.pReadDel, NULL, NULL, qDelDiskCallbackDummy, qDelDiskCallbackDummy, qDelDiskCallbackDummy)); CHKiRet(strm.GetCurrOffset(pThis->tVars.disk.pReadDel, &offsOut)); |