OpenJAUS Software Development Kit  4.3.1
Public Member Functions | Protected Member Functions | Protected Attributes | Friends | List of all members
openjaus::transport::AS5669::JtcpInterface Class Reference

#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::StreamServergetServer () const
 Accessor to get the value of server. More...
 
TCPAddressgetTcpAddress () 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::PriorityQueuegetRecvQueue () const
 Accessor to get the value of recvQueue. More...
 
bool setRecvQueue (system::PriorityQueue *recvQueue)
 Accessor to set value of recvQueue. More...
 
const system::PriorityQueuegetSendQueue () const
 Accessor to get the value of sendQueue. More...
 
const system::ThreadgetRecvThread () const
 Accessor to get the value of recvThread. More...
 
const system::ThreadgetSendThread () const
 Accessor to get the value of sendThread. More...
 
system::NetworkInterfacegetSubsIf () const
 Accessor to get the value of subsIf. More...
 
bool setSubsIf (system::NetworkInterface *subsIf)
 Accessor to set value of subsIf. More...
 
system::NetworkInterfacegetNodeIf () const
 Accessor to get the value of nodeIf. More...
 
bool setNodeIf (system::NetworkInterface *nodeIf)
 Accessor to set value of nodeIf. More...
 
AddressgetAddress () 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
 
TCPAddresstcpAddress
 
- Protected Attributes inherited from openjaus::transport::Interface
std::map< WrapperType, system::PriorityQueue *> recvQueues
 
uint16_t sequenceNumber
 
system::PriorityQueuerecvQueue
 
system::PriorityQueue sendQueue
 
system::Thread recvThread
 
system::Thread sendThread
 
system::NetworkInterfacesubsIf
 
system::NetworkInterfacenodeIf
 
Addressaddress
 
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)
 

Constructor & Destructor Documentation

§ JtcpInterface() [1/2]

openjaus::transport::AS5669::JtcpInterface::JtcpInterface ( )

§ ~JtcpInterface()

openjaus::transport::AS5669::JtcpInterface::~JtcpInterface ( )
virtual

§ JtcpInterface() [2/2]

openjaus::transport::AS5669::JtcpInterface::JtcpInterface ( system::InetAddress  ipAddress,
short  port 
)

Member Function Documentation

§ addAckNakCallback() [1/2]

void openjaus::transport::AS5669::JtcpInterface::addAckNakCallback ( void(*)(const AckNakEventArgs &args)  callback)
virtual

§ addAckNakCallback() [2/2]

void openjaus::transport::AS5669::JtcpInterface::addAckNakCallback ( void(*)(void *object, const AckNakEventArgs &args)  callback,
void *  object 
)
virtual

§ getDestinationAddresses()

std::list< TCPAddress *> openjaus::transport::AS5669::JtcpInterface::getDestinationAddresses ( transport::Wrapper wrapper)
Parameters
wrapper

§ getServer()

const system::StreamServer & openjaus::transport::AS5669::JtcpInterface::getServer ( ) const

§ getStreams()

const std::map< uint64_t, JtcpStream *> & openjaus::transport::AS5669::JtcpInterface::getStreams ( ) const

§ getTcpAddress()

TCPAddress * openjaus::transport::AS5669::JtcpInterface::getTcpAddress ( ) const

§ recvThreadMethod()

void * openjaus::transport::AS5669::JtcpInterface::recvThreadMethod ( )
protectedvirtual

Reimplemented from openjaus::transport::Interface.

§ removeAckNakCallback() [1/2]

void openjaus::transport::AS5669::JtcpInterface::removeAckNakCallback ( void(*)(const AckNakEventArgs &args)  callback)
virtual

§ removeAckNakCallback() [2/2]

void openjaus::transport::AS5669::JtcpInterface::removeAckNakCallback ( void(*)(void *object, const AckNakEventArgs &args)  callback,
void *  object 
)
virtual

§ sendMessage()

void openjaus::transport::AS5669::JtcpInterface::sendMessage ( Wrapper wrapper)
protectedvirtual

§ sendThreadMethod()

void * openjaus::transport::AS5669::JtcpInterface::sendThreadMethod ( )
protectedvirtual

Reimplemented from openjaus::transport::Interface.

§ setStreams()

bool openjaus::transport::AS5669::JtcpInterface::setStreams ( std::map< uint64_t, JtcpStream * >  streams)
Parameters
streamsThe value of the new streams.

§ setTcpAddress()

bool openjaus::transport::AS5669::JtcpInterface::setTcpAddress ( TCPAddress tcpAddress)
Parameters
tcpAddressThe value of the new tcpAddress.

§ toString()

std::string openjaus::transport::AS5669::JtcpInterface::toString ( ) const
virtual

Reimplemented from openjaus::transport::Interface.

Friends And Related Function Documentation

§ operator<< [1/2]

OPENJAUS_EXPORT friend std::ostream& operator<< ( std::ostream &  output,
const JtcpInterface object 
)
friend

§ operator<< [2/2]

OPENJAUS_EXPORT friend std::ostream& operator<< ( std::ostream &  output,
const JtcpInterface object 
)
friend

Member Data Documentation

§ server

system::StreamServer openjaus::transport::AS5669::JtcpInterface::server
protected

§ streams

std::map< uint64_t, JtcpStream * > openjaus::transport::AS5669::JtcpInterface::streams
protected

§ tcpAddress

TCPAddress* openjaus::transport::AS5669::JtcpInterface::tcpAddress
protected

The documentation for this class was generated from the following files: