From 3f704d2ff49cd4316514a98f69ae5e6488722272 Mon Sep 17 00:00:00 2001 From: Georg Hopp Date: Sat, 4 Oct 2014 10:44:14 +0100 Subject: [PATCH] Revert "It seems that I have it right now" This reverts commit c0ce13990ad2273e794bddda413360a9f11a9c9d. --- src/i_comm_manager.c | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/i_comm_manager.c b/src/i_comm_manager.c index e4ad878..4c120d5 100644 --- a/src/i_comm_manager.c +++ b/src/i_comm_manager.c @@ -102,18 +102,17 @@ TR_commManagerSelect(void * _this, TR_Event event) if (! this->io_triggered) { printf("[DEBUG] [%s] io triggerd was empty\n", buffer); fflush(stdout); - pthread_mutex_lock(&this->io_triggered_lock); this->io_triggered = TR_hashEach(this->write, this, commManagerIssueWriteEvents); this->io_triggered += TR_hashEach(this->accept, this, commManagerIssueAcceptEvents); this->io_triggered += TR_hashEach(this->read, this, commManagerIssueReadEvents); + pthread_mutex_unlock(&this->io_triggered_lock); } printf("[DEBUG] [%s] io triggerd: %lu\n", buffer, this->io_triggered); fflush(stdout); if (! this->io_triggered) { - pthread_mutex_unlock(&this->io_triggered_lock); if (NULL == timer) { timeout = TR_eventDispatcherGetDataWaitTime(dispatcher); } else { @@ -124,8 +123,6 @@ TR_commManagerSelect(void * _this, TR_Event event) fflush(stdout); TR_CALL(_this, TR_CommManager, select, event, timeout); - } else { - pthread_mutex_unlock(&this->io_triggered_lock); } return TR_EVENT_DONE;