|
IBR-DTNSuite 0.6
|
#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 () |
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::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(), and dtn::api::ClientHandler::run().

| void dtn::streams::StreamConnection::keepalive | ( | ) |
send a keepalive
Definition at line 54 of file StreamConnection.cpp.
| void dtn::streams::StreamConnection::reject | ( | ) |
This method rejects the currently transmitted bundle
Definition at line 49 of file StreamConnection.cpp.
| 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::Client::close(), dtn::api::ClientHandler::run(), and dtn::api::ClientHandler::shutdown().
