add connector

include/Makefile.am

@@ -1,6 +1,7 @@
 nobase_include_HEADERS = trcomm.h \
 			 tr/comm_end_point.h \
 			 tr/connection.h \
+			 tr/connector.h \
 			 tr/protocol.h \
 			 tr/proto_message.h \
 			 tr/protocol/raw.h \

include/trcomm.h

@@ -3,6 +3,7 @@
 
 #include "tr/comm_end_point.h"
 #include "tr/connection.h"
+#include "tr/connector.h"
 #include "tr/protocol.h"
 #include "tr/proto_message.h"
 #include "tr/protocol/raw.h"

src/Makefile.am

@@ -5,6 +5,7 @@ AM_CFLAGS += -I../include/
 
 TRCOMM = comm_end_point.c \
 	 connection.c \
+	 connector.c \
 	 protocol.c \
 	 proto_message.c \
 	 protocol_raw.c \

src/comm_end_point.c

@@ -29,6 +29,7 @@
 #include "trio.h"
 
 #include "tr/comm_end_point.h"
+#include "tr/protocol.h"
 #include "tr/interface/comm_end_point.h"
 
 static
@@ -38,7 +39,7 @@ commEndPointCtor(void * _this, va_list * params)
 	TR_CommEndPoint this = _this;
 
 	this->transport       = va_arg(*params, TR_Socket);
-	this->protocol        = va_arg(*params, void *);
+	this->protocol        = va_arg(*params, TR_Protocol);
 	this->read_chunk_size = va_arg(*params, int);
 	this->do_close        = 0;
 	this->read_buffer     = TR_new(TR_Queue);

src/connection.c

@@ -52,6 +52,7 @@ connectionDtor(void * _this)
 	TR_Connection this = _this;
 
 	TR_delete(this->current_message);
+	TR_PARENTCALL(_this, TR_Class, dtor);
 }
 
 static