#include <tcpstream.h>

Inheritance diagram for ibrcommon::tcpstream:

Classes
class	select_exception
Public Types
enum	stream_error { ERROR_NONE = 0, ERROR_EPIPE = 1, ERROR_CLOSED = 2, ERROR_WRITE = 3, ERROR_READ = 4, ERROR_RESET = 5 }
Public Member Functions
	tcpstream (int socket=-1)
virtual	~tcpstream ()
string	getAddress () const
int	getPort () const
void	close (bool errorcheck=false)
void	enableKeepalive ()
void	enableLinger (int linger)
void	enableNoDelay ()
void	setTimeout (unsigned int value)
Public Attributes
stream_error	errmsg
Static Public Attributes
static const size_t	BUFF_SIZE = 5120
Protected Member Functions
virtual int	sync ()
virtual std::char_traits< char > ::int_type	overflow (std::char_traits< char >::int_type=std::char_traits< char >::eof())
virtual std::char_traits< char > ::int_type	underflow ()
void	interrupt ()
int	select (int int_pipe, bool &read, bool &write, bool &error, int timeout=0) throw (select_exception)
Protected Attributes
int	_socket
int	_interrupt_pipe_read [2]
int	_interrupt_pipe_write [2]

Detailed Description

Definition at line 28 of file tcpstream.h.

Member Enumeration Documentation

enum ibrcommon::tcpstream::stream_error

Enumerator:

ERROR_NONE
ERROR_EPIPE
ERROR_CLOSED
ERROR_WRITE
ERROR_READ
ERROR_RESET

Definition at line 31 of file tcpstream.h.

Constructor & Destructor Documentation

ibrcommon::tcpstream::tcpstream ( int socket = -1 )

Definition at line 25 of file tcpstream.cpp.

References _interrupt_pipe_read, _interrupt_pipe_write, _socket, BUFF_SIZE, close(), IBRCOMMON_LOGGER, IBRCOMMON_LOGGER_ENDL, and ibrcommon::vsocket::set_non_blocking().

Here is the call graph for this function:

ibrcommon::tcpstream::~tcpstream ( ) [virtual]

Definition at line 64 of file tcpstream.cpp.

References _interrupt_pipe_read, _interrupt_pipe_write, and close().

Here is the call graph for this function:

Member Function Documentation

void ibrcommon::tcpstream::close ( bool errorcheck = false )

Definition at line 103 of file tcpstream.cpp.

References _socket, and interrupt().

Referenced by dtn::api::OrderedStreamHandler::__cancellation(), dtn::api::ExtendedApiHandler::__cancellation(), dtn::api::BinaryStreamClient::__cancellation(), dtn::api::ApiServer::componentRun(), dtn::api::OrderedStreamHandler::finally(), dtn::api::ExtendedApiHandler::finally(), dtn::api::BinaryStreamClient::finally(), main(), overflow(), tcpstream(), term(), underflow(), dtn::api::Client::~Client(), and ~tcpstream().

Here is the call graph for this function:

void ibrcommon::tcpstream::enableKeepalive ( )

Definition at line 402 of file tcpstream.cpp.

References _socket.

void ibrcommon::tcpstream::enableLinger ( int linger )

Definition at line 411 of file tcpstream.cpp.

References _socket.

void ibrcommon::tcpstream::enableNoDelay ( )

Definition at line 421 of file tcpstream.cpp.

References _socket.

Referenced by dtn::api::ClientHandler::ClientHandler(), main(), and dtn::net::TCPConnection::TCPConnection().

string ibrcommon::tcpstream::getAddress ( ) const

Definition at line 79 of file tcpstream.cpp.

References _socket.

int ibrcommon::tcpstream::getPort ( ) const

Definition at line 88 of file tcpstream.cpp.

References _socket.

void ibrcommon::tcpstream::interrupt ( ) [protected]

Definition at line 97 of file tcpstream.cpp.

References _interrupt_pipe_read, and _interrupt_pipe_write.

Referenced by close().

std::char_traits< char >::int_type ibrcommon::tcpstream::overflow ( std::char_traits< char >::int_type c = std::char_traits<char>::eof() ) [protected, virtual]

Definition at line 258 of file tcpstream.cpp.

References _interrupt_pipe_write, _socket, BUFF_SIZE, close(), errmsg, ERROR_EPIPE, ERROR_RESET, ERROR_WRITE, IBRCOMMON_LOGGER_DEBUG, IBRCOMMON_LOGGER_ENDL, and select().