lichao
2021-03-31 6eefba812ede29549af3633c490f2e85a4805524
src/socket.h
@@ -20,17 +20,18 @@
#define SOCKET_GWTJHBPO
#include "shm_queue.h"
#include <vector>
#include <thread>
#include <memory>
#include <functional>
#include <mutex>
#include <condition_variable>
#include <atomic>
#include <condition_variable>
#include <functional>
#include <memory>
#include <mutex>
#include <thread>
#include <vector>
class ShmSocket
{
    typedef bhome_shm::ShmMsgQueue Queue;
public:
    enum Type {
        eSockRequest,
@@ -55,6 +56,7 @@
    bool Subscribe(const std::vector<std::string> &topics, const int timeout_ms);
    bool RecvSub(std::string &topic, std::string &data, const int timeout_ms);
    bool SetRecvCallback(const RecvCB &onRecv);
private:
    bool HasRecvCB();
    void Stop();
@@ -69,6 +71,5 @@
    std::unique_ptr<Queue> mq_;
};
#endif // end of include guard: SOCKET_GWTJHBPO