OpenJAUS Software Development Kit
4.3.1
|
#include <JtcpInterface.h>
Inherits openjaus::transport::Interface.
Public Member Functions | |
JtcpInterface () | |
virtual | ~JtcpInterface () |
JtcpInterface (system::InetAddress ipAddress, short port) | |
const std::map< uint64_t, JtcpStream *> & | getStreams () const |
Accessor to get the value of streams. More... | |
bool | setStreams (std::map< uint64_t, JtcpStream * > streams) |
Accessor to set value of streams. More... | |
const system::StreamServer & | getServer () const |
Accessor to get the value of server. More... | |
TCPAddress * | getTcpAddress () const |
Accessor to get the value of tcpAddress. More... | |
bool | setTcpAddress (TCPAddress *tcpAddress) |
Accessor to set value of tcpAddress. More... | |
std::list< TCPAddress *> | getDestinationAddresses (transport::Wrapper *wrapper) |
Operation getDestinationAddresses. More... | |
virtual std::string | toString () const |
virtual void | addAckNakCallback (void(*callback)(const AckNakEventArgs &args)) |
virtual void | addAckNakCallback (void(*callback)(void *object, const AckNakEventArgs &args), void *object) |
virtual void | removeAckNakCallback (void(*callback)(const AckNakEventArgs &args)) |
virtual void | removeAckNakCallback (void(*callback)(void *object, const AckNakEventArgs &args), void *object) |
Public Member Functions inherited from openjaus::transport::Interface | |
Interface () | |
virtual | ~Interface () |
Interface (InterfaceSettingsInterface *settings) | |
const std::map< WrapperType, system::PriorityQueue *> & | getRecvQueues () const |
Accessor to get the value of recvQueues. More... | |
uint16_t | getSequenceNumber () const |
Accessor to get the value of sequenceNumber. More... | |
bool | setSequenceNumber (uint16_t sequenceNumber) |
Accessor to set value of sequenceNumber. More... | |
system::PriorityQueue * | getRecvQueue () const |
Accessor to get the value of recvQueue. More... | |
bool | setRecvQueue (system::PriorityQueue *recvQueue) |
Accessor to set value of recvQueue. More... | |
const system::PriorityQueue & | getSendQueue () const |
Accessor to get the value of sendQueue. More... | |
const system::Thread & | getRecvThread () const |
Accessor to get the value of recvThread. More... | |
const system::Thread & | getSendThread () const |
Accessor to get the value of sendThread. More... | |
system::NetworkInterface * | getSubsIf () const |
Accessor to get the value of subsIf. More... | |
bool | setSubsIf (system::NetworkInterface *subsIf) |
Accessor to set value of subsIf. More... | |
system::NetworkInterface * | getNodeIf () const |
Accessor to get the value of nodeIf. More... | |
bool | setNodeIf (system::NetworkInterface *nodeIf) |
Accessor to set value of nodeIf. More... | |
Address * | getAddress () const |
Accessor to get the value of address. More... | |
bool | setAddress (Address *address) |
Accessor to set value of address. More... | |
bool | send (Wrapper *message) |
Operation send. More... | |
bool | open (Address tAddress) |
Operation open. More... | |
bool | close () |
Operation close. More... | |
bool | broadcast (Wrapper message) |
Operation broadcast. More... | |
virtual void | run () |
virtual void | stop () |
bool | setRecvQueue (WrapperType type, system::PriorityQueue *queue) |
Operation setRecvQueue. More... | |
bool | checkAddresses (Wrapper *message) |
Operation checkAddresses. More... | |
Protected Member Functions | |
virtual void * | recvThreadMethod () |
virtual void * | sendThreadMethod () |
virtual void | sendMessage (Wrapper *wrapper) |
Protected Member Functions inherited from openjaus::transport::Interface | |
virtual void | handleNakSend (Wrapper *nak) |
Sends a NAK over the interface. More... | |
void | recvLargeMessage (Wrapper *wrapper) |
void | sendLargeMessage (Wrapper *wrapper) |
bool | messageIsForMe (Wrapper *const wrapper) |
virtual bool | sendInternal (Wrapper *message) |
Protected Attributes | |
std::map< uint64_t, JtcpStream *> | streams |
system::StreamServer | server |
TCPAddress * | tcpAddress |
Protected Attributes inherited from openjaus::transport::Interface | |
std::map< WrapperType, system::PriorityQueue *> | recvQueues |
uint16_t | sequenceNumber |
system::PriorityQueue * | recvQueue |
system::PriorityQueue | sendQueue |
system::Thread | recvThread |
system::Thread | sendThread |
system::NetworkInterface * | subsIf |
system::NetworkInterface * | nodeIf |
Address * | address |
std::map< transport::Address, JausLargeMessageBuffer * > | largeMessageMap |
Friends | |
OPENJAUS_EXPORT friend std::ostream & | operator<< (std::ostream &output, const JtcpInterface &object) |
OPENJAUS_EXPORT friend std::ostream & | operator<< (std::ostream &output, const JtcpInterface *object) |
Additional Inherited Members | |
Static Public Member Functions inherited from openjaus::transport::Interface | |
static std::vector< AS5669::JausWrapper * > | splitLargeMessage (Wrapper *wrapper) |
openjaus::transport::AS5669::JtcpInterface::JtcpInterface | ( | ) |
|
virtual |
openjaus::transport::AS5669::JtcpInterface::JtcpInterface | ( | system::InetAddress | ipAddress, |
short | port | ||
) |
|
virtual |
Implements openjaus::transport::Interface.
|
virtual |
Implements openjaus::transport::Interface.
std::list< TCPAddress *> openjaus::transport::AS5669::JtcpInterface::getDestinationAddresses | ( | transport::Wrapper * | wrapper | ) |
wrapper |
const system::StreamServer & openjaus::transport::AS5669::JtcpInterface::getServer | ( | ) | const |
const std::map< uint64_t, JtcpStream *> & openjaus::transport::AS5669::JtcpInterface::getStreams | ( | ) | const |
TCPAddress * openjaus::transport::AS5669::JtcpInterface::getTcpAddress | ( | ) | const |
|
protectedvirtual |
Reimplemented from openjaus::transport::Interface.
|
virtual |
Implements openjaus::transport::Interface.
|
virtual |
Implements openjaus::transport::Interface.
|
protectedvirtual |
Implements openjaus::transport::Interface.
|
protectedvirtual |
Reimplemented from openjaus::transport::Interface.
bool openjaus::transport::AS5669::JtcpInterface::setStreams | ( | std::map< uint64_t, JtcpStream * > | streams | ) |
streams | The value of the new streams. |
bool openjaus::transport::AS5669::JtcpInterface::setTcpAddress | ( | TCPAddress * | tcpAddress | ) |
tcpAddress | The value of the new tcpAddress. |
|
virtual |
Reimplemented from openjaus::transport::Interface.
|
friend |
|
friend |
|
protected |
|
protected |
|
protected |