#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::IPriorityQueue *> &	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::IPriorityQueue *	getRecvQueue () const
	Accessor to get the value of recvQueue. More...

bool	setRecvQueue (system::IPriorityQueue *recvQueue)
	Accessor to set value of recvQueue. More...

const system::IPriorityQueue &	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...

virtual void	run ()

virtual void	stop ()

bool	setRecvQueue (WrapperType type, system::IPriorityQueue *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)

uint16	getNextSequenceNumber ()

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::IPriorityQueue *>	recvQueues

uint16_t	sequenceNumber

system::IPriorityQueue *	recvQueue

system::PriorityQueue< system::Prioritized * >	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)

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

Implements openjaus::transport::Interface.

◆ addAckNakCallback() [2/2]

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

virtual

Implements openjaus::transport::Interface.

◆ 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

Implements openjaus::transport::Interface.

◆ removeAckNakCallback() [2/2]

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

virtual

Implements openjaus::transport::Interface.

◆ sendMessage()

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

protectedvirtual

Implements openjaus::transport::Interface.

◆ 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

streams The value of the new streams.

◆ setTcpAddress()

bool openjaus::transport::AS5669::JtcpInterface::setTcpAddress ( TCPAddress * tcpAddress )

Parameters

tcpAddress The 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:

include/openjaus/transport/AS5669/JtcpInterface.h
src/openjaus/transport/AS5669/JtcpInterface.cpp

Public Member Functions

Protected Member Functions

Protected Attributes

Friends

Additional Inherited Members

Constructor & Destructor Documentation

◆ JtcpInterface() [1/2]

◆ ~JtcpInterface()

◆ JtcpInterface() [2/2]

Member Function Documentation

◆ addAckNakCallback() [1/2]

◆ addAckNakCallback() [2/2]

◆ getDestinationAddresses()

◆ getServer()

◆ getStreams()

◆ getTcpAddress()

◆ recvThreadMethod()

◆ removeAckNakCallback() [1/2]

◆ removeAckNakCallback() [2/2]

◆ sendMessage()

◆ sendThreadMethod()

◆ setStreams()

◆ setTcpAddress()

◆ toString()

Friends And Related Function Documentation

◆ operator<< [1/2]

◆ operator<< [2/2]

Member Data Documentation

◆ server

◆ streams

◆ tcpAddress