From 8b12972092777af56ae21f65b41f4c40d52c2367 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Mon, 18 Jun 2007 19:42:34 +0000
Subject: Added the protocol class. servers work, but don't send data, updated
 the streams to include many more state indicators and caps queries, and
 everything is working better in general.

---
 src/client.cpp | 69 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 67 insertions(+), 2 deletions(-)

(limited to 'src/client.cpp')

diff --git a/src/client.cpp b/src/client.cpp
index a33cdc3..cf96424 100644
--- a/src/client.cpp
+++ b/src/client.cpp
@@ -1,6 +1,16 @@
-#include "client.h"
+#include "bu/client.h"
+#include "bu/socket.h"
+#include <stdlib.h>
+#include <errno.h>
+#include "bu/exceptions.h"
+#include "bu/protocol.h"
 
-Bu::Client::Client()
+/** Read buffer size. */
+#define RBS		(1024*2)
+
+Bu::Client::Client( Bu::Socket *pSocket ) :
+	pSocket( pSocket ),
+	pProto( NULL )
 {
 }
 
@@ -8,3 +18,58 @@ Bu::Client::~Client()
 {
 }
 
+void Bu::Client::processInput()
+{
+	char buf[RBS];
+	size_t nRead, nTotal=0;
+
+	for(;;)
+	{
+		nRead = pSocket->read( buf, nRead );
+		if( nRead < 0  )
+		{
+			throw Bu::ConnectionException(
+				excodeReadError,
+				"Read error: %s",
+				strerror( errno )
+				);
+		}
+		else if( nRead == 0 )
+		{
+			break;
+		}
+		else
+		{
+			nTotal += nRead;
+			sReadBuf.append( buf, nRead );
+			if( !pSocket->canRead() )
+				break;
+		}
+	}
+
+	if( pProto && nTotal )
+	{
+		pProto->onNewData( this );
+	}
+}
+
+void Bu::Client::setProtocol( Protocol *pProto )
+{
+	this->pProto = pProto;
+}
+
+Bu::Protocol *Bu::Client::getProtocol()
+{
+	return pProto;
+}
+
+void Bu::Client::clearProtocol()
+{
+	pProto = NULL;
+}
+
+Bu::FString &Bu::Client::getInput()
+{
+	return sReadBuf;
+}
+
-- 
cgit v1.2.3