int stop(sensor_observer *ob);
int set_interval(sensor_observer *ob, int32_t interval);
+ int get_interval(sensor_observer *ob, int32_t& interval);
int set_batch_latency(sensor_observer *ob, int32_t latency);
+ int get_batch_latency(sensor_observer *ob, int32_t &latency);
int set_attribute(sensor_observer *ob, int32_t attr, int32_t value);
int set_attribute(sensor_observer *ob, int32_t attr, const char *value, int len);
int flush(sensor_observer *ob);
private:
ipc::channel *m_ch;
std::atomic<bool> m_started;
- int32_t m_prev_interval;
int get_min_interval(void);
std::vector<sensor_handler *> m_required_sensors;
std::unordered_map<sensor_observer *, int> m_interval_map;
+
};
}