OpcUa::Server::OpcTcpMessages Class Reference

#include <opc_tcp_processor.h>

List of all members.

Classes
struct	PublishRequestElement
Public Member Functions
	OpcTcpMessages (std::shared_ptr< OpcUa::Services > computer, OpcUa::OutputChannel &outputChannel, bool debug)
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
bool	Debug
OpcUa::Binary::OStreamBinary	OutputStream
boost::shared_mutex	ProcessMutex
std::queue< PublishRequestElement >	PublishRequestQueue
std::mutex	PublishRequestQueueMutex
uint32_t	SequenceNb
std::shared_ptr< OpcUa::Services >	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	(	std::shared_ptr< OpcUa::Services >	computer,
		OpcUa::OutputChannel &	outputChannel,
		bool	debug
	)

Definition at line 47 of file opc_tcp_processor.cpp.

OpcUa::Server::OpcTcpMessages::~OpcTcpMessages

(

)

Definition at line 61 of file opc_tcp_processor.cpp.

---

Member Function Documentation

void OpcUa::Server::OpcTcpMessages::CloseChannel

(

Binary::IStreamBinary &

istream

)

[private]

Definition at line 225 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::DeleteAllSubscriptions

(

)

[private]

Definition at line 761 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::DeleteSubscriptions

(

const std::vector< uint32_t > &

ids

)

[private]

Definition at line 772 of file opc_tcp_processor.cpp.

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

Definition at line 754 of file opc_tcp_processor.cpp.

void OpcUa::Server::OpcTcpMessages::ForwardPublishResponse

(

const PublishResult

response

)

[private]

Definition at line 130 of file opc_tcp_processor.cpp.

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

Definition at line 160 of file opc_tcp_processor.cpp.

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

Definition at line 180 of file opc_tcp_processor.cpp.

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

Definition at line 74 of file opc_tcp_processor.cpp.

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

Definition at line 240 of file opc_tcp_processor.cpp.

---

Member Data Documentation

uint32_t OpcUa::Server::OpcTcpMessages::ChannelId [private]

Definition at line 49 of file opc_tcp_processor.h.

bool OpcUa::Server::OpcTcpMessages::Debug [private]

Definition at line 48 of file opc_tcp_processor.h.

OpcUa::Binary::OStreamBinary OpcUa::Server::OpcTcpMessages::OutputStream [private]

Definition at line 47 of file opc_tcp_processor.h.

boost::shared_mutex OpcUa::Server::OpcTcpMessages::ProcessMutex [private]

Definition at line 45 of file opc_tcp_processor.h.

std::queue<PublishRequestElement> OpcUa::Server::OpcTcpMessages::PublishRequestQueue [private]

Definition at line 64 of file opc_tcp_processor.h.

std::mutex OpcUa::Server::OpcTcpMessages::PublishRequestQueueMutex [private]

Definition at line 63 of file opc_tcp_processor.h.

uint32_t OpcUa::Server::OpcTcpMessages::SequenceNb [private]

Definition at line 53 of file opc_tcp_processor.h.

std::shared_ptr<OpcUa::Services> OpcUa::Server::OpcTcpMessages::Server [private]

Definition at line 46 of file opc_tcp_processor.h.

ExpandedNodeId OpcUa::Server::OpcTcpMessages::SessionId [private]

Definition at line 51 of file opc_tcp_processor.h.

std::list<uint32_t> OpcUa::Server::OpcTcpMessages::Subscriptions [private]

Definition at line 62 of file opc_tcp_processor.h.

uint32_t OpcUa::Server::OpcTcpMessages::TokenId [private]

Definition at line 50 of file opc_tcp_processor.h.

---

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

• opc_tcp_processor.h
• opc_tcp_processor.cpp