IBR-DTNSuite
0.8
|
#include <StreamConnection.h>
Classes | |
class | Callback |
class | StreamBuffer |
class | StreamClosedException |
class | StreamErrorException |
class | StreamShutdownException |
class | TransmissionInterruptedException |
Public Types | |
enum | ConnectionShutdownCases { CONNECTION_SHUTDOWN_NOTSET = 0, CONNECTION_SHUTDOWN_IDLE = 1, CONNECTION_SHUTDOWN_ERROR = 2, CONNECTION_SHUTDOWN_SIMPLE_SHUTDOWN = 3, CONNECTION_SHUTDOWN_NODE_TIMEOUT = 4, CONNECTION_SHUTDOWN_PEER_SHUTDOWN = 5 } |
Public Member Functions | |
StreamConnection (StreamConnection::Callback &cb, iostream &stream, const size_t buffer_size=4096) | |
virtual | ~StreamConnection () |
void | handshake (const dtn::data::EID &eid, const size_t timeout=10, const char flags=0) |
void | shutdown (ConnectionShutdownCases csc=CONNECTION_SHUTDOWN_SIMPLE_SHUTDOWN) |
void | reject () |
void | keepalive () |
void | enableIdleTimeout (size_t seconds) |
Definition at line 28 of file StreamConnection.h.
CONNECTION_SHUTDOWN_NOTSET | |
CONNECTION_SHUTDOWN_IDLE | |
CONNECTION_SHUTDOWN_ERROR | |
CONNECTION_SHUTDOWN_SIMPLE_SHUTDOWN | |
CONNECTION_SHUTDOWN_NODE_TIMEOUT | |
CONNECTION_SHUTDOWN_PEER_SHUTDOWN |
Definition at line 31 of file StreamConnection.h.
dtn::streams::StreamConnection::StreamConnection | ( | StreamConnection::Callback & | cb, |
iostream & | stream, | ||
const size_t | buffer_size = 4096 |
||
) |
Constructor of the StreamConnection class
cb | Callback object for events of this stream |
stream | The underlying stream object |
Definition at line 22 of file StreamConnection.cpp.
dtn::streams::StreamConnection::~StreamConnection | ( | ) | [virtual] |
Destructor of the StreamConnection class
Definition at line 27 of file StreamConnection.cpp.
void dtn::streams::StreamConnection::enableIdleTimeout | ( | size_t | seconds | ) |
enables the idle timeout thread
seconds |
Definition at line 141 of file StreamConnection.cpp.
Referenced by dtn::net::TCPConnection::eventConnectionUp().
void dtn::streams::StreamConnection::handshake | ( | const dtn::data::EID & | eid, |
const size_t | timeout = 10 , |
||
const char | flags = 0 |
||
) |
Do a handshake with the other peer. This operation is needed to communicate.
eid | The local address of this node. |
timeout | The desired timeout for this connection. |
Definition at line 31 of file StreamConnection.cpp.
References dtn::streams::StreamContactHeader::_flags, dtn::streams::StreamContactHeader::_keepalive, and dtn::streams::StreamConnection::Callback::eventConnectionUp().
Referenced by dtn::api::Client::connect(), dtn::api::BinaryStreamClient::run(), and dtn::net::TCPConnection::run().
send a keepalive
Definition at line 54 of file StreamConnection.cpp.
This method rejects the currently transmitted bundle
Definition at line 49 of file StreamConnection.cpp.
Referenced by dtn::net::TCPConnection::rejectTransmission().
void dtn::streams::StreamConnection::shutdown | ( | ConnectionShutdownCases | csc = CONNECTION_SHUTDOWN_SIMPLE_SHUTDOWN | ) |
This method shutdown the whole connection handling process. To differ between the expected cases of disconnection a connection shutdown case is needed.
CONNECTION_SHUTDOWN_IDLE The connection was idle and should go down now.
CONNECTION_SHUTDOWN_ERROR A critical tcp error occured and the connection is closed.
CONNECTION_SHUTDOWN_SIMPLE_SHUTDOWN The connection is ok, but a shutdown is requested from anywhere.
CONNECTION_SHUTDOWN_NODE_TIMEOUT The node of this connection is gone. So shutdown this connection.
CONNECTION_SHUTDOWN_PEER_SHUTDOWN The peer has shutdown this connection by a shutdown message.
csc | The case of the requested shutdown. |
Definition at line 59 of file StreamConnection.cpp.
References CONNECTION_SHUTDOWN_ERROR, CONNECTION_SHUTDOWN_IDLE, CONNECTION_SHUTDOWN_NODE_TIMEOUT, CONNECTION_SHUTDOWN_NOTSET, CONNECTION_SHUTDOWN_PEER_SHUTDOWN, CONNECTION_SHUTDOWN_SIMPLE_SHUTDOWN, dtn::streams::StreamConnection::Callback::eventConnectionDown(), dtn::streams::StreamConnection::Callback::eventError(), dtn::streams::StreamConnection::Callback::eventShutdown(), dtn::streams::StreamConnection::Callback::eventTimeout(), dtn::streams::StreamDataSegment::MSG_SHUTDOWN_IDLE_TIMEOUT, and dtn::streams::StreamDataSegment::MSG_SHUTDOWN_NONE.
Referenced by dtn::api::BinaryStreamClient::__cancellation(), dtn::api::Client::abort(), dtn::api::Client::close(), dtn::net::TCPConnection::connect(), dtn::api::BinaryStreamClient::run(), dtn::net::TCPConnection::run(), and dtn::net::TCPConnection::shutdown().