Started work adding more functions to stream, and changing to a new size type.

1 files changed, 28 insertions, 12 deletions

diff --git a/src/tcpsocket.cpp b/src/tcpsocket.cpp
index bbd9cf5..22acdf7 100644
--- a/src/tcpsocket.cpp
+++ b/src/tcpsocket.cpp
@@ -149,7 +149,7 @@ void Bu::TcpSocket::close()
         bActive = false;
 }
 
-size_t Bu::TcpSocket::read( void *pBuf, size_t nBytes )
+Bu::size Bu::TcpSocket::read( void *pBuf, Bu::size nBytes )
 {
         fd_set rfds;
         FD_ZERO(&rfds);
@@ -195,11 +195,11 @@ size_t Bu::TcpSocket::read( void *pBuf, size_t nBytes )
         return 0;
 }
 
-size_t Bu::TcpSocket::read( void *pBuf, size_t nBytes,
+Bu::size Bu::TcpSocket::read( void *pBuf, Bu::size nBytes,
                 uint32_t nSec, uint32_t nUSec )
 {
         struct timeval tv;
-        size_t nRead = 0;
+        Bu::size nRead = 0;
         
         fd_set rfds;
         FD_ZERO(&rfds);
@@ -239,7 +239,7 @@ size_t Bu::TcpSocket::read( void *pBuf, size_t nBytes,
         return nRead;
 }
 
-size_t Bu::TcpSocket::write( const void *pBuf, size_t nBytes )
+Bu::size Bu::TcpSocket::write( const void *pBuf, Bu::size nBytes )
 {
 //#ifdef WIN32
         int nWrote = TEMP_FAILURE_RETRY( 
@@ -261,10 +261,10 @@ size_t Bu::TcpSocket::write( const void *pBuf, size_t nBytes )
         return nWrote;
 }
 
-size_t Bu::TcpSocket::write( const void *pBuf, size_t nBytes, uint32_t nSec, uint32_t nUSec )
+Bu::size Bu::TcpSocket::write( const void *pBuf, Bu::size nBytes, uint32_t nSec, uint32_t nUSec )
 {
         struct timeval tv;
-        size_t nWrote = 0;
+        Bu::size nWrote = 0;
         
         fd_set wfds;
         FD_ZERO(&wfds);
@@ -304,22 +304,22 @@ size_t Bu::TcpSocket::write( const void *pBuf, size_t nBytes, uint32_t nSec, uin
         return nWrote;
 }
 
-long Bu::TcpSocket::tell()
+Bu::size Bu::TcpSocket::tell()
 {
         throw UnsupportedException();
 }
 
-void Bu::TcpSocket::seek( long )
+void Bu::TcpSocket::seek( Bu::size )
 {
         throw UnsupportedException();
 }
 
-void Bu::TcpSocket::setPos( long )
+void Bu::TcpSocket::setPos( Bu::size )
 {
         throw UnsupportedException();
 }
 
-void Bu::TcpSocket::setPosEnd( long )
+void Bu::TcpSocket::setPosEnd( Bu::size )
 {
         throw UnsupportedException();
 }
@@ -401,7 +401,7 @@ void Bu::TcpSocket::setBlocking( bool bBlocking )
                 fcntl( nTcpSocket, F_SETFL, fcntl( nTcpSocket, F_GETFL, 0 ) | O_NONBLOCK );
         }
 #else
-        u_long iMode;
+        u_Bu::size iMode;
         if( bBlocking )
                 iMode = 0;
         else
@@ -416,7 +416,7 @@ void Bu::TcpSocket::setBlocking( bool bBlocking )
 #endif  
 }
 
-void Bu::TcpSocket::setSize( long )
+void Bu::TcpSocket::setSize( Bu::size )
 {
 }
 
@@ -436,6 +436,8 @@ void Bu::TcpSocket::setAddress()
         addr.sin_family = AF_INET;
         bu_getpeername( nTcpSocket, (sockaddr *)(&addr), &len );
         sAddress = bu_inet_ntoa( addr.sin_addr );
+
+        printf("%d\n", IP_MTU );
 }
 
 Bu::FString Bu::TcpSocket::getAddress() const
@@ -448,3 +450,17 @@ Bu::TcpSocket::operator int() const
         return nTcpSocket;
 }
 
+Bu::size Bu::TcpSocket::getSize() const
+{
+        throw UnsupportedException();
+}
+
+Bu::size Bu::TcpSocket::getBlockSize() const
+{
+
+}
+
+Bu::FString Bu::TcpSocket::getLocation() const
+{
+}
+