17#ifndef NYMPH_SOCKET_LISTENER_H
18#define NYMPH_SOCKET_LISTENER_H
20#include "nymph_message.h"
22#include <Poco/Runnable.h>
23#include <Poco/Net/StreamSocket.h>
24#include <Poco/Semaphore.h>
25#include <Poco/Condition.h>
34 Poco::Net::StreamSocket* socket;
35 Poco::Semaphore* semaphore;
45 Poco::Condition condition;
55 std::string loggerName;
56 std::atomic<bool> listen;
58 Poco::Net::StreamSocket* socket;
59 std::map<uint64_t, NymphRequest*> messages;
60 Poco::Mutex messagesMutex;
62 Poco::Condition* readyCond;
63 Poco::Mutex* readyMutex;
71 bool removeMessage(uint64_t messageId);
Definition: nymph_socket_listener.h:54
Definition: nymph_types.h:85
Definition: nymph_message.h:33
Definition: nymph_socket_listener.h:41
Definition: nymph_socket_listener.h:33