diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-07-08 18:45:23 +0200 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-07-08 18:45:23 +0200 |
commit | 4b6e93d382a622bffedbbaa6b87f94124987e2fd (patch) | |
tree | 4e166dd1d6f1ec2b51fe2c70d2973448fa7f212d /runtime/wti.c | |
parent | 4cfbc7254a49503a3c980a1b20264915d6b3b807 (diff) | |
download | rsyslog-4b6e93d382a622bffedbbaa6b87f94124987e2fd.tar.gz rsyslog-4b6e93d382a622bffedbbaa6b87f94124987e2fd.tar.xz rsyslog-4b6e93d382a622bffedbbaa6b87f94124987e2fd.zip |
further reduction in code size/complexity due to design change
Diffstat (limited to 'runtime/wti.c')
-rw-r--r-- | runtime/wti.c | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/runtime/wti.c b/runtime/wti.c index f6a32c34..769575e1 100644 --- a/runtime/wti.c +++ b/runtime/wti.c @@ -162,7 +162,6 @@ wtiCancelThrd(wti_t *pThis) pthread_cancel(pThis->thrdID); /* TODO: check: the following check should automatically be done by cancel cleanup handler! 2009-07-08 rgerhards */ wtiSetState(pThis, eWRKTHRD_STOPPED, 0, MUTEX_ALREADY_LOCKED); - ATOMIC_STORE_1_TO_INT(pThis->pWtp->bThrdStateChanged); /* indicate change, so harverster will be called */ } d_pthread_mutex_unlock(&pThis->mut); @@ -244,7 +243,6 @@ wtiWorkerCancelCleanup(void *arg) d_pthread_mutex_lock(&pWtp->mut); wtiSetState(pThis, eWRKTHRD_STOPPED, 0, MUTEX_ALREADY_LOCKED); /* TODO: sync access? I currently think it is NOT needed -- rgerhards, 2008-01-28 */ - ATOMIC_STORE_1_TO_INT(pWtp->bThrdStateChanged); /* indicate change, so harverster will be called */ d_pthread_mutex_unlock(&pWtp->mut); pthread_setcancelstate(iCancelStateSave, NULL); @@ -307,8 +305,6 @@ wtiWorker(wti_t *pThis) /* now we have our identity, on to real processing */ while(1) { /* loop will be broken below - need to do mutex locks */ - /* process any pending thread requests */ - if(pWtp->pfRateLimiter != NULL) { /* call rate-limiter, if defined */ pWtp->pfRateLimiter(pWtp->pUsr); } @@ -364,7 +360,6 @@ RUNLOG_STR("XXX: Worker shutdown"); pWtp->pfOnWorkerShutdown(pWtp->pUsr); wtiSetState(pThis, eWRKTHRD_STOPPED, 0, MUTEX_ALREADY_LOCKED); - ATOMIC_STORE_1_TO_INT(pWtp->bThrdStateChanged); /* indicate change, so harverster will be called */ d_pthread_mutex_unlock(&pThis->mut); pthread_setcancelstate(iCancelStateSave, NULL); |