From ec05778d5718a7912e506764d443a78d6a6179e3 Mon Sep 17 00:00:00 2001 From: Mike Buland Date: Mon, 5 Nov 2012 22:41:51 +0000 Subject: Converted tabs to spaces with tabconv. --- src/stable/tcpsocket.h | 200 ++++++++++++++++++++++++------------------------- 1 file changed, 100 insertions(+), 100 deletions(-) (limited to 'src/stable/tcpsocket.h') diff --git a/src/stable/tcpsocket.h b/src/stable/tcpsocket.h index 92b3c1f..16eca12 100644 --- a/src/stable/tcpsocket.h +++ b/src/stable/tcpsocket.h @@ -17,110 +17,110 @@ namespace Bu { - subExceptionDeclBegin( TcpSocketException ); - enum { - cRead, - cWrite, - cBadRead, - cClosed, - cTimeout - }; - subExceptionDeclEnd(); - - /** - * Network socket stream class. This class provides a mechanism for - * communicating over a network using TCP/IP. It will provide other low - * level protocol and addressing support later on, but for now it's just - * standard STREAM TCP/IP sockets. - * - * Unlike system sockets, these sockets are opened by default in - * non-blocking mode, you can specify your own timeout for opening a socket, - * and a number of non-fatal error messages have been automatically handled - * and treated as standard no-data-available-yet situations on read. - * - * Please note that there is a condition that will occur eventually (at - * least on *nix systems) that will trigger a SIGPIPE condition. This - * will terminate your program immediately unless handled properly. Most - * people doing any connections with TcpSocket will want to put this in - * their program somewhere before they use it: - *@code - #include - ... - ... - ... - sigset( SIGPIPE, SIG_IGN ); // do this before you use a Bu::TcpSocket - @endcode - * When this is done, Bu::TcpSocket will simply throw a broken pipe - * exception just like every other error condition, allowing your program - * to handle it sanely. - * - *@ingroup Serving - *@ingroup Streams - */ - class TcpSocket : public Stream - { - public: + subExceptionDeclBegin( TcpSocketException ); + enum { + cRead, + cWrite, + cBadRead, + cClosed, + cTimeout + }; + subExceptionDeclEnd(); + + /** + * Network socket stream class. This class provides a mechanism for + * communicating over a network using TCP/IP. It will provide other low + * level protocol and addressing support later on, but for now it's just + * standard STREAM TCP/IP sockets. + * + * Unlike system sockets, these sockets are opened by default in + * non-blocking mode, you can specify your own timeout for opening a socket, + * and a number of non-fatal error messages have been automatically handled + * and treated as standard no-data-available-yet situations on read. + * + * Please note that there is a condition that will occur eventually (at + * least on *nix systems) that will trigger a SIGPIPE condition. This + * will terminate your program immediately unless handled properly. Most + * people doing any connections with TcpSocket will want to put this in + * their program somewhere before they use it: + *@code + #include + ... + ... + ... + sigset( SIGPIPE, SIG_IGN ); // do this before you use a Bu::TcpSocket + @endcode + * When this is done, Bu::TcpSocket will simply throw a broken pipe + * exception just like every other error condition, allowing your program + * to handle it sanely. + * + *@ingroup Serving + *@ingroup Streams + */ + class TcpSocket : public Stream + { + public: #ifdef WIN32 - typedef unsigned int handle; + typedef unsigned int handle; #else - typedef int handle; + typedef int handle; #endif - TcpSocket( handle nTcpSocket ); - TcpSocket( const String &sAddr, int nPort, int nTimeout=30, - bool bBlocking=true ); - virtual ~TcpSocket(); - - virtual void close(); - virtual size read( void *pBuf, size nBytes ); - virtual size read( void *pBuf, size nBytes, - uint32_t nSec, uint32_t nUSec=0 ); - virtual size write( const void *pBuf, size nBytes ); - virtual size write( const void *pBuf, size nBytes, - uint32_t nSec, uint32_t nUSec=0 ); - using Stream::write; - - virtual size tell(); - virtual void seek( size offset ); - virtual void setPos( size pos ); - virtual void setPosEnd( size pos ); - virtual bool isEos(); - virtual bool isOpen(); - - virtual void flush(); - - virtual bool canRead(); - virtual bool canWrite(); - - virtual bool isReadable(); - virtual bool isWritable(); - virtual bool isSeekable(); - - virtual bool isBlocking(); - virtual void setBlocking( bool bBlocking=true ); - - virtual void setSize( size iSize ); - - Bu::String getAddress() const; - operator handle() const; - - handle getHandle() const; - handle takeHandle(); - - virtual size getSize() const; - virtual size getBlockSize() const; - virtual Bu::String getLocation() const; - - private: - void setAddress(); - - handle nTcpSocket; - - bool bActive; - bool bBlocking; - String sReadBuf; - String sAddress; - }; + TcpSocket( handle nTcpSocket ); + TcpSocket( const String &sAddr, int nPort, int nTimeout=30, + bool bBlocking=true ); + virtual ~TcpSocket(); + + virtual void close(); + virtual size read( void *pBuf, size nBytes ); + virtual size read( void *pBuf, size nBytes, + uint32_t nSec, uint32_t nUSec=0 ); + virtual size write( const void *pBuf, size nBytes ); + virtual size write( const void *pBuf, size nBytes, + uint32_t nSec, uint32_t nUSec=0 ); + using Stream::write; + + virtual size tell(); + virtual void seek( size offset ); + virtual void setPos( size pos ); + virtual void setPosEnd( size pos ); + virtual bool isEos(); + virtual bool isOpen(); + + virtual void flush(); + + virtual bool canRead(); + virtual bool canWrite(); + + virtual bool isReadable(); + virtual bool isWritable(); + virtual bool isSeekable(); + + virtual bool isBlocking(); + virtual void setBlocking( bool bBlocking=true ); + + virtual void setSize( size iSize ); + + Bu::String getAddress() const; + operator handle() const; + + handle getHandle() const; + handle takeHandle(); + + virtual size getSize() const; + virtual size getBlockSize() const; + virtual Bu::String getLocation() const; + + private: + void setAddress(); + + handle nTcpSocket; + + bool bActive; + bool bBlocking; + String sReadBuf; + String sAddress; + }; } #endif -- cgit v1.2.3