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 | |
InputChannel & | operator= (const InputChannel &)=delete |
virtual | ~InputChannel () |
Public Member Functions inherited from OpcUa::BreakableChannel | |
BreakableChannel () | |
BreakableChannel (const BreakableChannel &)=delete | |
BreakableChannel (BreakableChannel &&)=delete | |
BreakableChannel & | operator= (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 |
Definition at line 22 of file builtin_server_impl.cpp.
|
explicit |
Definition at line 42 of file builtin_server_impl.cpp.
void BufferedInput::AddBuffer | ( | const char * | buf, |
std::size_t | size | ||
) |
Definition at line 102 of file builtin_server_impl.cpp.
|
virtual |
Receive data.
data | data for send |
size | size of data |
Implements OpcUa::InputChannel.
Definition at line 49 of file builtin_server_impl.cpp.
|
virtual |
Implements OpcUa::BreakableChannel.
Definition at line 118 of file builtin_server_impl.cpp.
|
private |
Definition at line 124 of file builtin_server_impl.cpp.
|
private |
Definition at line 34 of file builtin_server_impl.cpp.
|
private |
Definition at line 36 of file builtin_server_impl.cpp.
|
private |
Definition at line 37 of file builtin_server_impl.cpp.
|
private |
Definition at line 38 of file builtin_server_impl.cpp.
|
private |
Definition at line 35 of file builtin_server_impl.cpp.