
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.