remove the debug counts

src/comm_manager_epoll.c

@@ -38,8 +38,6 @@
 
 struct epoll_event events[MAXEVENTS];
 
-extern int count_write_ready;
-
 static
 int
 commManagerEpollCtor(void * _this, va_list * params)
@@ -124,7 +122,6 @@ TR_commManagerEpollSelect(void * _this, TR_Event event, int timeout)
 
 			TR_eventHandlerIssueEvent((TR_EventHandler)this, _event);
 			this->events[i].events &= ~EPOLLOUT;
-			count_write_ready++;
 		}
 	}
 }

src/i_comm_manager.c

@@ -65,7 +65,6 @@ TR_commManagerSelect(void * _this, TR_Event event)
 	}
 
 	TR_CALL(_this, TR_CommManager, select, event, timeout);
-	TR_eventDispatcherUpdateNextPoll(dispatcher);
 
 	return TR_EVENT_DONE;
 }

src/io_handler.c

@@ -29,9 +29,6 @@
 #include "tr/comm_end_point.h"
 #include "tr/interface/comm_end_point.h"
 
-extern int count_write_ready;
-int count_write_ready_handle = 0;
-
 static
 int
 ioHandlerCtor(void * _this, va_list * params)
@@ -93,8 +90,6 @@ ioHandlerWrite(void * _this, TR_Event event)
 {
 	TR_Event        revent, close_event = NULL;
 
-	count_write_ready_handle++;
-
 	switch (TR_cepWriteBuffered((TR_CommEndPoint)event->subject)) {
 		case FALSE: // EAGAIN
 			revent = TR_eventSubjectEmit(

src/protocol_handler.c

@@ -32,8 +32,6 @@
 #include "tr/comm_end_point.h"
 #include "tr/interface/comm_end_point.h"
 
-int count_write_ready = 0;
-
 static
 int
 protocolHandlerCtor(void * _this, va_list * params)
@@ -93,8 +91,6 @@ protocolHandlerCompose(void * _this, TR_Event event)
 				NULL);
 
 		TR_eventHandlerIssueEvent((TR_EventHandler)_this, _event);
-
-		count_write_ready++;
 	} else {
 		//printf("%s: compose failed\n", __func__);
 	}

testers/testclient.sh

@@ -2,9 +2,9 @@
 
 pids=""
 i=0
-while [ $i -lt 20 ]
+while [ $i -lt 100 ]
 do
-	dd if=/dev/zero bs=8192 count=25000 | nc localhost 5678 &
+	dd if=/dev/zero bs=8192 count=25000 | nc 192.168.2.13 5678 &
 	pids="${pids} $!"
 	i=$((i + 1))
 done