use explicit event done return type in all handler methods

@@ -42,8 +42,8 @@ TR_CLASSVARS_DECL(TR_CommManager) {
 	TR_CV_EXTENDS(TR_EventHandler);
 	TR_CV_EXTENDS(TR_EventHandler);
 };
 };
 
 
-void TR_commManagerAddEndpoint(void *, TR_CommEndPoint);
-int  TR_commManagerShutdown(void * _this, TR_Event event);
+void         TR_commManagerAddEndpoint(void *, TR_CommEndPoint);
+TR_EventDone TR_commManagerShutdown(void * _this, TR_Event event);
 
 
 #endif // __TR_COMM_MANAGER_H__
 #endif // __TR_COMM_MANAGER_H__
 
 

@@ -59,21 +59,22 @@ commManagerDtor(void * _this)
 }
 }
 
 
 static
 static
-int
+TR_EventDone
 TR__commManagerAddEndpoint(void * _this, TR_Event event)
 TR__commManagerAddEndpoint(void * _this, TR_Event event)
 {
 {
 	TR_commManagerAddEndpoint(
 	TR_commManagerAddEndpoint(
 			(TR_CommManager)_this,
 			(TR_CommManager)_this,
 			(TR_CommEndPoint)event->subject);
 			(TR_CommEndPoint)event->subject);
-	return 1;
+
+	return TR_EVENT_DONE;
 }
 }
 
 
-void TR_commManagerSelect(void *, TR_Event, int);
-void TR_commManagerEnableWrite(void *, TR_Event);
-void TR_commManagerDisableWrite(void *, TR_Event);
-void TR_commManagerClose(void *, TR_Event);
-void TR_commManagerShutdownRead(void *, TR_Event);
-void TR_commManagerShutdownWrite(void *, TR_Event);
+TR_EventDone TR_commManagerSelect(void *, TR_Event, int);
+TR_EventDone TR_commManagerEnableWrite(void *, TR_Event);
+TR_EventDone TR_commManagerDisableWrite(void *, TR_Event);
+TR_EventDone TR_commManagerClose(void *, TR_Event);
+TR_EventDone TR_commManagerShutdownRead(void *, TR_Event);
+TR_EventDone TR_commManagerShutdownWrite(void *, TR_Event);
 
 
 static
 static
 void
 void

@@ -28,7 +28,7 @@
 
 
 #include "tr/comm_manager.h"
 #include "tr/comm_manager.h"
 
 
-int
+TR_EventDone
 TR_commManagerShutdown(void * _this, TR_Event event)
 TR_commManagerShutdown(void * _this, TR_Event event)
 {
 {
     TR_CommManager this = _this;
     TR_CommManager this = _this;
@@ -45,7 +45,7 @@ TR_commManagerShutdown(void * _this, TR_Event event)
         }
         }
     }
     }
 
 
-    return 0;
+    return TR_EVENT_DONE;
 }
 }
 
 
 // vim: set ts=4 sw=4:
 // vim: set ts=4 sw=4:

@@ -50,7 +50,7 @@ connectorDtor(void * _this)
 }
 }
 
 
 static
 static
-int
+TR_EventDone
 connectorAccept(void * _this, TR_Event event)
 connectorAccept(void * _this, TR_Event event)
 {
 {
 	TR_Connector    this       = _this;
 	TR_Connector    this       = _this;
@@ -78,7 +78,7 @@ connectorAccept(void * _this, TR_Event event)
 	 * TODO we need to identify socket failures and close socket then.
 	 * TODO we need to identify socket failures and close socket then.
 	 */
 	 */
 
 
-	return 1;
+	return TR_EVENT_DONE;
 }
 }
 
 
 static
 static

@@ -47,7 +47,7 @@ TR_commManagerAddEndpoint(void * _this, TR_CommEndPoint endpoint)
 	TR_CALL(_this, TR_CommManager, addEndpoint, endpoint);
 	TR_CALL(_this, TR_CommManager, addEndpoint, endpoint);
 }
 }
 
 
-int
+TR_EventDone
 TR_commManagerSelect(void * _this, TR_Event event)
 TR_commManagerSelect(void * _this, TR_Event event)
 {
 {
 	int                  timeout;  // milliseconds
 	int                  timeout;  // milliseconds
@@ -62,17 +62,19 @@ TR_commManagerSelect(void * _this, TR_Event event)
 	}
 	}
 
 
 	TR_CALL(_this, TR_CommManager, select, event, timeout);
 	TR_CALL(_this, TR_CommManager, select, event, timeout);
-	return 1;
+
+	return TR_EVENT_DONE;
 }
 }
 
 
-int
+TR_EventDone
 TR_commManagerEnableWrite(void * _this, TR_Event event)
 TR_commManagerEnableWrite(void * _this, TR_Event event)
 {
 {
 	TR_CALL(_this, TR_CommManager, enableWrite, event);
 	TR_CALL(_this, TR_CommManager, enableWrite, event);
-	return 1;
+
+	return TR_EVENT_DONE;
 }
 }
 
 
-int
+TR_EventDone
 TR_commManagerDisableWrite(void * _this, TR_Event event)
 TR_commManagerDisableWrite(void * _this, TR_Event event)
 {
 {
 	TR_EventHandler this     = _this;
 	TR_EventHandler this     = _this;
@@ -89,10 +91,10 @@ TR_commManagerDisableWrite(void * _this, TR_Event event)
 					NULL));
 					NULL));
 	}
 	}
 
 
-	return 1;
+	return TR_EVENT_DONE;
 }
 }
 
 
-int
+TR_EventDone
 TR_commManagerClose(void * _this, TR_Event event)
 TR_commManagerClose(void * _this, TR_Event event)
 {
 {
 	TR_CommManager  this     = _this;
 	TR_CommManager  this     = _this;
@@ -102,10 +104,10 @@ TR_commManagerClose(void * _this, TR_Event event)
 	TR_CALL(_this, TR_CommManager, close, event);
 	TR_CALL(_this, TR_CommManager, close, event);
 	TR_delete(this->endpoints[endpoint->transport->handle]);
 	TR_delete(this->endpoints[endpoint->transport->handle]);
 
 
-	return 0;
+	return TR_EVENT_DONE;
 }
 }
 
 
-int
+TR_EventDone
 TR_commManagerShutdownRead(void * _this, TR_Event event)
 TR_commManagerShutdownRead(void * _this, TR_Event event)
 {
 {
 	TR_CALL(_this, TR_CommManager, shutdownRead, event);
 	TR_CALL(_this, TR_CommManager, shutdownRead, event);
@@ -130,10 +132,10 @@ TR_commManagerShutdownRead(void * _this, TR_Event event)
 		TR_cepSetClose((TR_CommEndPoint)event->subject);
 		TR_cepSetClose((TR_CommEndPoint)event->subject);
 	}
 	}
 
 
-	return 0;
+	return TR_EVENT_DONE;
 }
 }
 
 
-int
+TR_EventDone
 TR_commManagerShutdownWrite(void * _this, TR_Event event)
 TR_commManagerShutdownWrite(void * _this, TR_Event event)
 {
 {
 	TR_CALL(_this, TR_CommManager, shutdownWrite, event);
 	TR_CALL(_this, TR_CommManager, shutdownWrite, event);
@@ -147,8 +149,7 @@ TR_commManagerShutdownWrite(void * _this, TR_Event event)
 					NULL));
 					NULL));
 	}
 	}
 
 
-	return 0;
+	return TR_EVENT_DONE;
 }
 }
 
 
-
 // vim: set ts=4 sw=4:
 // vim: set ts=4 sw=4:

@@ -41,7 +41,7 @@ ioHandlerCtor(void * _this, va_list * params)
 static void ioHandlerDtor(void * _this) {}
 static void ioHandlerDtor(void * _this) {}
 
 
 static
 static
-int
+TR_EventDone
 ioHandlerRead(void * _this, TR_Event event)
 ioHandlerRead(void * _this, TR_Event event)
 {
 {
 	TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject;
 	TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject;
@@ -79,11 +79,11 @@ ioHandlerRead(void * _this, TR_Event event)
 			break;
 			break;
 	}
 	}
 
 
-	return TRUE;
+	return TR_EVENT_DONE;
 }
 }
 
 
 static
 static
-int
+TR_EventDone
 ioHandlerWrite(void * _this, TR_Event event)
 ioHandlerWrite(void * _this, TR_Event event)
 {
 {
 	TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject;
 	TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject;
@@ -106,7 +106,7 @@ ioHandlerWrite(void * _this, TR_Event event)
 		TR_eventHandlerIssueEvent((TR_EventHandler)_this, event);
 		TR_eventHandlerIssueEvent((TR_EventHandler)_this, event);
 	}
 	}
 
 
-	return TRUE;
+	return TR_EVENT_DONE;
 }
 }
 
 
 static
 static

@@ -44,7 +44,7 @@ protocolHandlerCtor(void * _this, va_list * params)
 static void protocolHandlerDtor(void * _this) {}
 static void protocolHandlerDtor(void * _this) {}
 
 
 static
 static
-int
+TR_EventDone
 protocolHandlerParse(void * _this, TR_Event event)
 protocolHandlerParse(void * _this, TR_Event event)
 {
 {
 	/**
 	/**
@@ -68,11 +68,11 @@ protocolHandlerParse(void * _this, TR_Event event)
 		}
 		}
 	}
 	}
 
 
-	return TRUE;
+	return TR_EVENT_DONE;
 }
 }
 
 
 static
 static
-int
+TR_EventDone
 protocolHandlerCompose(void * _this, TR_Event event)
 protocolHandlerCompose(void * _this, TR_Event event)
 {
 {
 	TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject;
 	TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject;
@@ -94,13 +94,13 @@ protocolHandlerCompose(void * _this, TR_Event event)
 		TR_delete(message);
 		TR_delete(message);
 	}
 	}
 
 
-	return TRUE;
+	return TR_EVENT_DONE;
 }
 }
 
 
-int
+TR_EventDone
 protocolHandlerUpgrade(void * _this, TR_Event event)
 protocolHandlerUpgrade(void * _this, TR_Event event)
 {
 {
-	return TRUE;
+	return TR_EVENT_DONE;
 }
 }
 
 
 static
 static