some more fixes

-nobase_include_HEADERS = tr/comm_end_point.h \
+nobase_include_HEADERS = trcomm.h \
+			 tr/comm_end_point.h \
 			 tr/comm_manager.h \
 			 tr/comm_manager.h \
 			 tr/comm_manager_poll.h \
 			 tr/comm_manager_poll.h \
 			 tr/connect_entry_point.h \
 			 tr/connect_entry_point.h \

@@ -28,14 +28,16 @@
 int
 int
 cepBufferedRead(TR_CommEndPoint this)
 cepBufferedRead(TR_CommEndPoint this)
 {
 {
-	TR_RemoteData data = TR_socketRecv(this->transport);
+	TR_RemoteData data = TR_socketRecv(this->transport, this->read_chunk_size);
 
 
 	if (! data) return FALSE;
 	if (! data) return FALSE;
 
 
 	while (data) {
 	while (data) {
-		TR_cepAppendReadData(data);
-		data = TR_socketRecv(this->transport);
+		TR_cepAppendReadData(this, data);
+		data = TR_socketRecv(this->transport, this->read_chunk_size);
 	}
 	}
+
+	return TRUE;
 }
 }
 
 
 // vim: set ts=4 sw=4:
 // vim: set ts=4 sw=4:

@@ -26,7 +26,7 @@
 #include "tr/comm_end_point.h"
 #include "tr/comm_end_point.h"
 
 
 int
 int
-cepBufferedRead(TR_CommEndPoint this)
+cepWriteBuffered(TR_CommEndPoint this)
 {
 {
 	TR_RemoteData data = TR_cepNextWriteData(this);
 	TR_RemoteData data = TR_cepNextWriteData(this);
 	int           send = 0;
 	int           send = 0;
@@ -34,11 +34,14 @@ cepBufferedRead(TR_CommEndPoint this)
 	while (data) {
 	while (data) {
 		int current_send = TR_socketSend(this->transport, data);
 		int current_send = TR_socketSend(this->transport, data);
 
 
+		send += current_send;
 		// TODO if nothing was send put it back into the queue..
 		// TODO if nothing was send put it back into the queue..
 		// and stop loop. (This was a close.)
 		// and stop loop. (This was a close.)
 
 
-		data = TR_socketRecv(this->transport);
+		data = TR_cepNextWriteData(this);
 	}
 	}
+
+	return TRUE;
 }
 }
 
 
 // vim: set ts=4 sw=4:
 // vim: set ts=4 sw=4: