diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2011-01-31 13:13:00 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2011-01-31 13:13:00 +0100 |
commit | 48ab717fedba586be5054320e32afc84afee9f52 (patch) | |
tree | ffd44239cfd9c51ef24a1fc4b3deab271ae73e4c /tcps_sess.c | |
parent | a4a94ddfc0dc2256d7a3bc79ed8f9489de9f0f9b (diff) | |
download | rsyslog-48ab717fedba586be5054320e32afc84afee9f52.tar.gz rsyslog-48ab717fedba586be5054320e32afc84afee9f52.tar.xz rsyslog-48ab717fedba586be5054320e32afc84afee9f52.zip |
fixing regression: multi-threading had races
Diffstat (limited to 'tcps_sess.c')
-rw-r--r-- | tcps_sess.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/tcps_sess.c b/tcps_sess.c index 99af0cb8..8b944885 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); |