#include <opc_tcp_processor.h>

Inheritance diagram for OpcUa::Server::OpcTcpMessages:

Classes
struct	PublishRequestElement

Public Member Functions
	OpcTcpMessages (OpcUa::Services::SharedPtr server, OpcUa::OutputChannel::SharedPtr outputChannel, const Common::Logger::SharedPtr &logger)

bool	ProcessMessage (Binary::MessageType msgType, Binary::IStreamBinary &iStream)

	~OpcTcpMessages ()

Private Member Functions
void	CloseChannel (Binary::IStreamBinary &istream)

void	DeleteAllSubscriptions ()

void	DeleteSubscriptions (const std::vector< uint32_t > &ids)

void	FillResponseHeader (const RequestHeader &requestHeader, ResponseHeader &responseHeader)

void	ForwardPublishResponse (const PublishResult response)

void	HelloClient (Binary::IStreamBinary &istream, Binary::OStreamBinary &ostream)

void	OpenChannel (Binary::IStreamBinary &istream, Binary::OStreamBinary &ostream)

void	ProcessRequest (Binary::IStreamBinary &istream, Binary::OStreamBinary &ostream)

Private Attributes
uint32_t	ChannelId

Common::Logger::SharedPtr	Logger

OpcUa::OutputChannel::WeakPtr	OutputChannel

OpcUa::Binary::OStreamBinary	OutputStream

std::mutex	ProcessMutex

std::queue< PublishRequestElement >	PublishRequestQueue

std::mutex	PublishRequestQueueMutex

uint32_t	SequenceNb

OpcUa::Services::SharedPtr	Server

ExpandedNodeId	SessionId

std::list< uint32_t >	Subscriptions

uint32_t	TokenId

Detailed Description

Definition at line 26 of file opc_tcp_processor.h.

Constructor & Destructor Documentation

OpcUa::Server::OpcTcpMessages::OpcTcpMessages	(	OpcUa::Services::SharedPtr	server,
		OpcUa::OutputChannel::SharedPtr	outputChannel,
		const Common::Logger::SharedPtr &	logger
	)

Definition at line 47 of file opc_tcp_processor.cpp.

OpcUa::Server::OpcTcpMessages::~OpcTcpMessages ( )

Definition at line 65 of file opc_tcp_processor.cpp.

Member Function Documentation

void OpcUa::Server::OpcTcpMessages::CloseChannel ( Binary::IStreamBinary & istream )

private

Definition at line 252 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::DeleteAllSubscriptions ( )

private

Definition at line 910 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::DeleteSubscriptions ( const std::vector< uint32_t > & ids )

private

Definition at line 923 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::FillResponseHeader	(	const RequestHeader &	requestHeader,
		ResponseHeader &	responseHeader
	)

private

Definition at line 903 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::ForwardPublishResponse ( const PublishResult response )

private

Definition at line 143 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::HelloClient	(	Binary::IStreamBinary &	istream,
		Binary::OStreamBinary &	ostream
	)

private

Definition at line 184 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::OpenChannel	(	Binary::IStreamBinary &	istream,
		Binary::OStreamBinary &	ostream
	)

private

Definition at line 207 of file opc_tcp_processor.cpp.

bool OpcUa::Server::OpcTcpMessages::ProcessMessage	(	Binary::MessageType	msgType,
		Binary::IStreamBinary &	iStream
	)

Definition at line 79 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::ProcessRequest	(	Binary::IStreamBinary &	istream,
		Binary::OStreamBinary &	ostream
	)

private

Definition at line 267 of file opc_tcp_processor.cpp.

Member Data Documentation

uint32_t OpcUa::Server::OpcTcpMessages::ChannelId

private

Definition at line 53 of file opc_tcp_processor.h.

Common::Logger::SharedPtr OpcUa::Server::OpcTcpMessages::Logger

private

Definition at line 52 of file opc_tcp_processor.h.

OpcUa::OutputChannel::WeakPtr OpcUa::Server::OpcTcpMessages::OutputChannel

private

Definition at line 50 of file opc_tcp_processor.h.

OpcUa::Binary::OStreamBinary OpcUa::Server::OpcTcpMessages::OutputStream

private

Definition at line 51 of file opc_tcp_processor.h.

std::mutex OpcUa::Server::OpcTcpMessages::ProcessMutex

private

Definition at line 48 of file opc_tcp_processor.h.

std::queue<PublishRequestElement> OpcUa::Server::OpcTcpMessages::PublishRequestQueue

private

Definition at line 68 of file opc_tcp_processor.h.

std::mutex OpcUa::Server::OpcTcpMessages::PublishRequestQueueMutex

private

Definition at line 67 of file opc_tcp_processor.h.

uint32_t OpcUa::Server::OpcTcpMessages::SequenceNb

private

Definition at line 57 of file opc_tcp_processor.h.

OpcUa::Services::SharedPtr OpcUa::Server::OpcTcpMessages::Server

private

Definition at line 49 of file opc_tcp_processor.h.

ExpandedNodeId OpcUa::Server::OpcTcpMessages::SessionId

private

Definition at line 55 of file opc_tcp_processor.h.

std::list<uint32_t> OpcUa::Server::OpcTcpMessages::Subscriptions

private

Definition at line 66 of file opc_tcp_processor.h.

uint32_t OpcUa::Server::OpcTcpMessages::TokenId

private

Definition at line 54 of file opc_tcp_processor.h.

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

Classes

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation