set also the accepted sockets to nonblocking

@@ -64,7 +64,7 @@ connectionNextMessage(void * _this)
 	TR_RemoteData   data = TR_queueGet(comm->read_buffer);
 	size_t          end;
 
-	if (NULL == this->current_message || this->current_message->ready)
+	if (data && (! this->current_message || this->current_message->ready))
 	{
 		this->current_message =
 			TR_protoCreateMessage(comm->protocol, data->remote);

@@ -59,6 +59,7 @@ connectorAccept(void * _this, TR_Event event)
 			(TR_TcpSocket)connection->transport);
 
 	while (socket) {
+		TR_socketNonblock((TR_Socket)socket);
 		TR_Connection new_con = TR_new(
 				TR_Connection, 
 				socket,