Public Member Functions | |
void | AddBuffer (const char *buf, std::size_t size) |
BufferedInput (bool debug) | |
virtual std::size_t | Receive (char *data, std::size_t size) |
Receive data. | |
void | Stop () |
Private Member Functions | |
void | ThrowIfStopped () |
Private Attributes | |
std::vector< char > | Buffer |
std::mutex | BufferMutex |
std::condition_variable | DataReady |
bool | Debug |
std::atomic< bool > | Running |
Definition at line 22 of file builtin_server_impl.cpp.
BufferedInput::BufferedInput | ( | bool | debug | ) | [explicit] |
Definition at line 42 of file builtin_server_impl.cpp.
void BufferedInput::AddBuffer | ( | const char * | buf, |
std::size_t | size | ||
) |
Definition at line 92 of file builtin_server_impl.cpp.
std::size_t BufferedInput::Receive | ( | char * | data, |
std::size_t | size | ||
) | [virtual] |
Receive data.
data | data for send |
size | size of data |
Implements OpcUa::InputChannel.
Definition at line 49 of file builtin_server_impl.cpp.
void BufferedInput::Stop | ( | ) | [virtual] |
Implements OpcUa::BreakableChannel.
Definition at line 104 of file builtin_server_impl.cpp.
void BufferedInput::ThrowIfStopped | ( | ) | [private] |
Definition at line 110 of file builtin_server_impl.cpp.
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.
bool OpcUa::Impl::BufferedInput::Debug [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.