#ifndef FOUNDATION_IOTACQ_ACQ_H #define FOUNDATION_IOTACQ_ACQ_H #include #include #include #include #include #include "acq_task.h" #include namespace iot_acq { class AcqVendor : public vendor::VendorBase { public: AcqVendor(); virtual ~AcqVendor(); virtual int Run(); virtual std::string Name(); virtual void Stop(int signal); protected: virtual int ParseCmdline(const std::string &optname, const std::string &optarg); virtual vendor::MyOpt *GetOpts(); virtual int GetOptSize(); private: settings::ConfigParser configParser_; uv_handle_t* timerCheck_ = nullptr; uv_handle_t *eventStart_ = nullptr; uv_handle_t *eventStop_ = nullptr; AcqTask *acqTask_ = nullptr; std::shared_ptr dataAcqTask_; leoyun::RpcListener_t rpcListener_; }; } #endif // FOUNDATION_IOTACQ_ACQ_H