summaryrefslogtreecommitdiffstats
path: root/tcps_sess.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 /tcps_sess.c
parenta4a94ddfc0dc2256d7a3bc79ed8f9489de9f0f9b (diff)
downloadrsyslog-48ab717fedba586be5054320e32afc84afee9f52.zip
rsyslog-48ab717fedba586be5054320e32afc84afee9f52.tar.gz
rsyslog-48ab717fedba586be5054320e32afc84afee9f52.tar.xz
fixing regression: multi-threading had races
Diffstat (limited to 'tcps_sess.c')
-rw-r--r--tcps_sess.c3
1 files changed, 3 insertions, 0 deletions
diff --git a/tcps_sess.c b/tcps_sess.c
index 99af0cb..8b94488 100644
--- a/tcps_sess.c
+++ b/tcps_sess.c
@@ -95,6 +95,7 @@ finalize_it:
/* destructor for the tcps_sess object */
BEGINobjDestruct(tcps_sess) /* be sure to specify the object type also in END and CODESTART macros! */
CODESTARTobjDestruct(tcps_sess)
+//printf("sess %p destruct, pStrm %p\n", pThis, pThis->pStrm);
if(pThis->pStrm != NULL)
netstrm.Destruct(&pThis->pStrm);
@@ -337,6 +338,7 @@ Close(tcps_sess_t *pThis)
{
DEFiRet;
+//printf("sess %p close\n", pThis);
ISOBJ_TYPE_assert(pThis, tcps_sess);
netstrm.Destruct(&pThis->pStrm);
if(pThis->fromHost != NULL) {
@@ -466,6 +468,7 @@ DataRcvd(tcps_sess_t *pThis, char *pData, size_t iLen)
char *pEnd;
DEFiRet;
+//printf("DataRcvd: %p\n", pThis);
ISOBJ_TYPE_assert(pThis, tcps_sess);
assert(pData != NULL);
assert(iLen > 0);