void ThreadService::Handle(const AcceptEvent &event)
{
- LogDebug("Accept event");
auto &info = m_connectionInfoMap[event.connectionID.counter];
info.interfaceID = event.interfaceID;
info.credentials = event.credentials;
}
-void ThreadService::Handle(const WriteEvent &event)
+void ThreadService::Handle(const WriteEvent &)
{
- LogDebug("Write event (" << event.size << " bytes )");
}
void ThreadService::Handle(const ReadEvent &event)
{
- LogDebug("Read event");
auto &info = m_connectionInfoMap[event.connectionID.counter];
info.buffer.Push(event.rawBuffer);
void ThreadService::Handle(const CloseEvent &event)
{
- LogDebug("Close event");
m_connectionInfoMap.erase(event.connectionID.counter);
}
void ThreadService::Handle(const SecurityEvent &event)
{
- LogDebug("Security event");
auto it = m_connectionInfoMap.find(event.connectionID.counter);
if (it == m_connectionInfoMap.end()) {
void EncryptionService::CustomHandle(const ReadEvent &event)
{
- LogDebug("Read event");
auto &info = m_connectionInfoMap[event.connectionID.counter];
info.buffer.Push(event.rawBuffer);