| 1234567891011121314151617181920212223242526272829 |
- #ifndef _raw_data_uv_ipc_server_h_
- #define _raw_data_uv_ipc_server_h_
- #include "uv_ipc_common.h"
- #include <string>
- ////////////////////////////////////////////////////////////////////////////////////////////////
- class RawDataUVIPCServer : public UVIPCSink
- {
- public:
- RawDataUVIPCServer();
- virtual ~RawDataUVIPCServer();
- bool StartPipeServer(char* pipe_name, UVIPCSink* sink);
- bool StopPipeServer();
- virtual void onMessageRecvNotification(UVIPCMessage* msg);
- virtual void onConnect();
- virtual void onDisconnect();
- virtual void onIdle();
- bool SendMessage(const char* buf, int len);
- bool SendMessage(UVIPCMessage* msg);
- bool HasClientConnected() { return _pipe_server.IsRunning(true); }
- private:
- int _client_connected_count;
- UVIPCInSubThread _pipe_server;
- UVIPCSink* _external_sink;
- };
- #endif
|
