some more fixes

@@ -33,11 +33,13 @@ TR_cepWriteBuffered(TR_CommEndPoint this)
 
 
 	switch (send) {
 	switch (send) {
 		case FALSE: // EAGAIN
 		case FALSE: // EAGAIN
+			TR_queuePutFirst(this->write_buffer, data);
+			break;
+
 		case -1:    // FAILURE
 		case -1:    // FAILURE
 		case -2:    // remote close
 		case -2:    // remote close
-			return send;
-
 		default:
 		default:
+			TR_delete(data);
 			break;
 			break;
 	}
 	}
 
 

@@ -122,9 +122,11 @@ TR_commManagerClose(void * _this, TR_Event event)
 		while (! this->endpoints[--this->max_handle]);
 		while (! this->endpoints[--this->max_handle]);
 	}
 	}
 
 
-	TR_eventSubjectFinalize(
-			(TR_EventSubject)this->endpoints[endpoint->transport->handle]);
-	this->endpoints[endpoint->transport->handle] = NULL;
+	if (this->endpoints[endpoint->transport->handle]) {
+		TR_eventSubjectFinalize(
+				(TR_EventSubject)this->endpoints[endpoint->transport->handle]);
+		this->endpoints[endpoint->transport->handle] = NULL;
+	}
 
 
 	return TR_EVENT_DONE;
 	return TR_EVENT_DONE;
 }
 }

@@ -97,17 +97,10 @@ ioHandlerWrite(void * _this, TR_Event event)
 
 
 	switch (TR_cepWriteBuffered((TR_CommEndPoint)event->subject)) {
 	switch (TR_cepWriteBuffered((TR_CommEndPoint)event->subject)) {
 		case FALSE: // EAGAIN
 		case FALSE: // EAGAIN
-			if (TR_cepHasPendingData((TR_CommEndPoint)event->subject)) {
-				revent = TR_eventSubjectEmit(
-						event->subject,
-						TR_CEP_EVENT_PENDING_DATA,
-						NULL);
-			} else {
-				revent = TR_eventSubjectEmit(
-						event->subject,
-						TR_CEP_EVENT_END_DATA,
-						NULL);
-			}
+			revent = TR_eventSubjectEmit(
+					event->subject,
+					TR_CEP_EVENT_PENDING_DATA,
+					NULL);
 			break;
 			break;
 
 
 		case -1:    // FAILURE
 		case -1:    // FAILURE