summaryrefslogtreecommitdiffstats
path: root/runtime/netstrm.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2011-01-31 13:13:00 +0100
committerRainer Gerhards <rgerhards@adiscon.com>2011-01-31 13:13:00 +0100
commit48ab717fedba586be5054320e32afc84afee9f52 (patch)
treeffd44239cfd9c51ef24a1fc4b3deab271ae73e4c /runtime/netstrm.c
parenta4a94ddfc0dc2256d7a3bc79ed8f9489de9f0f9b (diff)
downloadrsyslog-48ab717fedba586be5054320e32afc84afee9f52.tar.gz
rsyslog-48ab717fedba586be5054320e32afc84afee9f52.tar.xz
rsyslog-48ab717fedba586be5054320e32afc84afee9f52.zip
fixing regression: multi-threading had races
Diffstat (limited to 'runtime/netstrm.c')
-rw-r--r--runtime/netstrm.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/runtime/netstrm.c b/runtime/netstrm.c
index 3658006f..a6f840a5 100644
--- a/runtime/netstrm.c
+++ b/runtime/netstrm.c
@@ -64,6 +64,7 @@ ENDobjConstruct(netstrm)
/* destructor for the netstrm object */
BEGINobjDestruct(netstrm) /* be sure to specify the object type also in END and CODESTART macros! */
CODESTARTobjDestruct(netstrm)
+//printf("destruct driver data %p\n", pThis->pDrvrData);
if(pThis->pDrvrData != NULL)
iRet = pThis->Drvr.Destruct(&pThis->pDrvrData);
ENDobjDestruct(netstrm)
@@ -169,6 +170,7 @@ Rcv(netstrm_t *pThis, uchar *pBuf, ssize_t *pLenBuf)
{
DEFiRet;
ISOBJ_TYPE_assert(pThis, netstrm);
+//printf("Rcv %p\n", pThis);
iRet = pThis->Drvr.Rcv(pThis->pDrvrData, pBuf, pLenBuf);
RETiRet;
}