#include <source/ariba/communication/modules/transport/omnet/AribaOmnetModule.h>
Public Member Functions | |
AribaOmnetModule () | |
virtual | ~AribaOmnetModule () |
void | setServerPort (uint16_t _port) |
virtual void | start () |
virtual void | stop () |
virtual TransportLocator::prot_t | getId () |
virtual const vector < TransportLocator * > | getLocators () |
virtual seqnum_t | sendMessage (const Message *message) |
virtual void | socketDataArrived (int connId, void *socket, cMessage *msg, bool urgent) |
virtual void | socketFailure (int connId, void *socket, int code) |
virtual void | socketClosed (int connId, void *socket) |
virtual void | socketPeerClosed (int connId, void *socket) |
virtual void | socketEstablished (int connId, void *socket) |
virtual void | socketStatusArrived (int connId, void *socket, TCPStatusInfo *status) |
Protected Member Functions | |
virtual void | initialize (int stage) |
virtual int | numInitStages () const |
virtual void | handleMessage (cMessage *msg) |
virtual void | finish () |
Private Types | |
typedef multimap< string, TCPSocket * > | SocketMap |
typedef map< TCPSocket *, AribaOmnetMessage * > | PendingSendQueue |
Private Member Functions | |
use_logging_h (AribaOmnetModule) | |
Private Attributes | |
TCPSocket | serverSocket |
SocketMap | sockets |
uint16_t | serverPort |
PendingSendQueue | pendingSends |
Definition at line 76 of file AribaOmnetModule.h.
typedef multimap<string, TCPSocket*> ariba::communication::AribaOmnetModule::SocketMap [private] |
Definition at line 129 of file AribaOmnetModule.h.
typedef map<TCPSocket*, AribaOmnetMessage*> ariba::communication::AribaOmnetModule::PendingSendQueue [private] |
Pending data that we have to send when the socket has been opened asynchronously
Definition at line 137 of file AribaOmnetModule.h.
ariba::communication::AribaOmnetModule::AribaOmnetModule | ( | ) |
Definition at line 49 of file AribaOmnetModule.cpp.
ariba::communication::AribaOmnetModule::~AribaOmnetModule | ( | ) | [virtual] |
Definition at line 52 of file AribaOmnetModule.cpp.
ariba::communication::AribaOmnetModule::use_logging_h | ( | AribaOmnetModule | ) | [private] |
void ariba::communication::AribaOmnetModule::setServerPort | ( | uint16_t | _port | ) |
Definition at line 55 of file AribaOmnetModule.cpp.
References serverPort.
Referenced by ariba::communication::BaseCommunication::start().
void ariba::communication::AribaOmnetModule::start | ( | ) | [virtual] |
Implements TransportProtocol.
Definition at line 59 of file AribaOmnetModule.cpp.
References logging_debug, serverPort, and serverSocket.
void ariba::communication::AribaOmnetModule::stop | ( | ) | [virtual] |
Implements TransportProtocol.
Definition at line 75 of file AribaOmnetModule.cpp.
References logging_debug, serverSocket, and sockets.
TransportLocator::prot_t ariba::communication::AribaOmnetModule::getId | ( | ) | [virtual] |
const vector< TransportLocator * > ariba::communication::AribaOmnetModule::getLocators | ( | ) | [virtual] |
Reimplemented from MessageSender.
Definition at line 172 of file AribaOmnetModule.cpp.
References data_serialize(), DataTpl< T, DataModel >::getBuffer(), Message::getDestinationAddress(), ariba::communication::IPv4Locator::getIP(), DataTpl< T, DataModel >::getLength(), ariba::communication::IPv4Locator::getPort(), logging_debug, pendingSends, DataTpl< T, DataModel >::release(), serverPort, AribaOmnetMessage::setData(), AribaOmnetMessage::setDataArraySize(), AribaOmnetMessage::setPort(), sockets, and ariba::communication::IPv4Locator::toString().
void ariba::communication::AribaOmnetModule::socketDataArrived | ( | int | connId, | |
void * | socket, | |||
cMessage * | msg, | |||
bool | urgent | |||
) | [virtual] |
see TCPSocket::CallbackInterface
Definition at line 238 of file AribaOmnetModule.cpp.
References ariba::communication::IPv4Locator::fromString(), DataTpl< T, DataModel >::getBuffer(), AribaOmnetMessage::getData(), AribaOmnetMessage::getDataArraySize(), AribaOmnetMessage::getPort(), logging_debug, MessageProvider::sendMessageToReceivers(), and Message::setSourceAddress().
void ariba::communication::AribaOmnetModule::socketFailure | ( | int | connId, | |
void * | socket, | |||
int | code | |||
) | [virtual] |
void ariba::communication::AribaOmnetModule::socketClosed | ( | int | connId, | |
void * | socket | |||
) | [virtual] |
void ariba::communication::AribaOmnetModule::socketPeerClosed | ( | int | connId, | |
void * | socket | |||
) | [virtual] |
void ariba::communication::AribaOmnetModule::socketEstablished | ( | int | connId, | |
void * | socket | |||
) | [virtual] |
void ariba::communication::AribaOmnetModule::socketStatusArrived | ( | int | connId, | |
void * | socket, | |||
TCPStatusInfo * | status | |||
) | [virtual] |
void ariba::communication::AribaOmnetModule::initialize | ( | int | stage | ) | [protected, virtual] |
Called from Omnet++ on initialization of the simulation
Definition at line 104 of file AribaOmnetModule.cpp.
References logging_debug, and logging_fatal.
int ariba::communication::AribaOmnetModule::numInitStages | ( | ) | const [protected, virtual] |
Definition at line 98 of file AribaOmnetModule.cpp.
void ariba::communication::AribaOmnetModule::handleMessage | ( | cMessage * | msg | ) | [protected, virtual] |
Called from Omnet++ during simulation: called when the module receives a message
Definition at line 134 of file AribaOmnetModule.cpp.
References logging_debug, and sockets.
void ariba::communication::AribaOmnetModule::finish | ( | ) | [protected, virtual] |
Called from Omnet++ during simulation: called when the simulation terminates. Can be used for writing statistics and the likes.
Definition at line 168 of file AribaOmnetModule.cpp.
TCPSocket ariba::communication::AribaOmnetModule::serverSocket [private] |
All our sockets to other nodes and the server socket
Definition at line 128 of file AribaOmnetModule.h.
Definition at line 130 of file AribaOmnetModule.h.
Referenced by handleMessage(), sendMessage(), socketPeerClosed(), and stop().
uint16_t ariba::communication::AribaOmnetModule::serverPort [private] |
Definition at line 131 of file AribaOmnetModule.h.
Referenced by sendMessage(), setServerPort(), and start().
Definition at line 138 of file AribaOmnetModule.h.
Referenced by sendMessage(), and socketEstablished().