Public Member Functions | Private Member Functions | Private Attributes | List of all members
OpcUa::Impl::BufferedInput Class Reference
Inheritance diagram for OpcUa::Impl::BufferedInput:
Inheritance graph
[legend]

Public Member Functions

void AddBuffer (const char *buf, std::size_t size)
 
 BufferedInput (const Common::Logger::SharedPtr &logger)
 
virtual std::size_t Receive (char *data, std::size_t size)
 Receive data. More...
 
void Stop ()
 
- Public Member Functions inherited from OpcUa::InputChannel
 InputChannel ()
 
 InputChannel (const InputChannel &)=delete
 
 InputChannel (InputChannel &&)=delete
 
InputChanneloperator= (const InputChannel &)=delete
 
virtual ~InputChannel ()
 
- Public Member Functions inherited from OpcUa::BreakableChannel
 BreakableChannel ()
 
 BreakableChannel (const BreakableChannel &)=delete
 
 BreakableChannel (BreakableChannel &&)=delete
 
BreakableChanneloperator= (const BreakableChannel &)=delete
 
virtual ~BreakableChannel ()
 

Private Member Functions

void ThrowIfStopped ()
 

Private Attributes

std::vector< char > Buffer
 
std::mutex BufferMutex
 
std::condition_variable DataReady
 
Common::Logger::SharedPtr Logger
 
std::atomic< bool > Running
 

Detailed Description

Definition at line 22 of file builtin_server_impl.cpp.

Constructor & Destructor Documentation

BufferedInput::BufferedInput ( const Common::Logger::SharedPtr &  logger)
explicit

Definition at line 42 of file builtin_server_impl.cpp.

Member Function Documentation

void BufferedInput::AddBuffer ( const char *  buf,
std::size_t  size 
)

Definition at line 102 of file builtin_server_impl.cpp.

std::size_t BufferedInput::Receive ( char *  data,
std::size_t  size 
)
virtual

Receive data.

Parameters
datadata for send
sizesize of data
Returns
size of received data

Implements OpcUa::InputChannel.

Definition at line 49 of file builtin_server_impl.cpp.

void BufferedInput::Stop ( )
virtual

Implements OpcUa::BreakableChannel.

Definition at line 118 of file builtin_server_impl.cpp.

void BufferedInput::ThrowIfStopped ( )
private

Definition at line 124 of file builtin_server_impl.cpp.

Member Data Documentation

std::vector<char> OpcUa::Impl::BufferedInput::Buffer
private

Definition at line 34 of file builtin_server_impl.cpp.

std::mutex OpcUa::Impl::BufferedInput::BufferMutex
private

Definition at line 36 of file builtin_server_impl.cpp.

std::condition_variable OpcUa::Impl::BufferedInput::DataReady
private

Definition at line 37 of file builtin_server_impl.cpp.

Common::Logger::SharedPtr OpcUa::Impl::BufferedInput::Logger
private

Definition at line 38 of file builtin_server_impl.cpp.

std::atomic<bool> OpcUa::Impl::BufferedInput::Running
private

Definition at line 35 of file builtin_server_impl.cpp.


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


ros_opcua_impl_freeopcua
Author(s): Denis Štogl
autogenerated on Tue Jan 19 2021 03:12:10