{
retvm_if(!sensor, false, "Invalid parameter[%#x]", sensor);
- for (auto it = m_infos.begin(); it != m_infos.end(); ++it) {
+ for (auto it = m_sensors.begin(); it != m_sensors.end(); ++it) {
if (&*it == sensor)
return true;
}
if (strncmp(uri, utils::get_uri(ALL_SENSOR), SIZE_STR_SENSOR_ALL) == 0)
return true;
- for (auto it = m_infos.begin(); it != m_infos.end(); ++it) {
+ for (auto it = m_sensors.begin(); it != m_sensors.end(); ++it) {
std::size_t found = (*it).get_uri().rfind(uri);
if (found != std::string::npos)
reply.disclose(buf);
- decode_sensors(buf, m_infos);
+ decode_sensors(buf, m_sensors);
return true;
}
sensor_info *sensor_manager::get_info(const char *uri)
{
if (strncmp(uri, utils::get_uri(ALL_SENSOR), SIZE_STR_SENSOR_ALL) == 0)
- return &m_infos[0];
+ return &m_sensors[0];
- for (auto it = m_infos.begin(); it != m_infos.end(); ++it) {
+ for (auto it = m_sensors.begin(); it != m_sensors.end(); ++it) {
std::size_t found = (*it).get_uri().rfind(uri);
if (found == std::string::npos)
if (strncmp(uri, utils::get_uri(ALL_SENSOR), SIZE_STR_SENSOR_ALL) == 0)
all = true;
-for (auto it = m_infos.begin(); it != m_infos.end(); ++it) {
+ for (auto it = m_sensors.begin(); it != m_sensors.end(); ++it) {
std::size_t found = (*it).get_uri().rfind(uri);
if (!all && found == std::string::npos)
/* int unregister_sensor(const char *uri) */
private:
- typedef std::vector<sensor_info> sensor_infos_t;
+ typedef std::vector<sensor_info> sensor_list_t;
bool init(void);
void deinit(void);
ipc::event_loop m_loop;
std::atomic<bool> m_connected;
- sensor_infos_t m_infos;
+ sensor_list_t m_sensors;
};
}
g_source_set_callback(src, (GSourceFunc) g_io_handler, info, NULL);
g_source_attach(src, g_main_loop_get_context(m_mainloop));
- m_infos[id] = info;
+ m_handlers[id] = info;
/* _D("Added[%llu](fd:%d)", id, fd); */
return id;
bool event_loop::remove_event(uint64_t id, bool close_channel)
{
- auto it = m_infos.find(id);
- retv_if(it == m_infos.end(), false);
+ auto it = m_handlers.find(id);
+ retv_if(it == m_handlers.end(), false);
if (close_channel)
g_io_channel_shutdown(it->second->g_ch, TRUE, NULL);
release_info(it->second);
- m_infos.erase(it);
+ m_handlers.erase(it);
/* _D("Removed[%llu]", id); */
return true;
void event_loop::remove_all_events(void)
{
- auto it = m_infos.begin();
- while (it != m_infos.end()) {
+ auto it = m_handlers.begin();
+ while (it != m_handlers.end()) {
release_info(it->second);
- it = m_infos.erase(it);
+ it = m_handlers.erase(it);
}
}
std::atomic<bool> m_running;
std::atomic<bool> m_terminating;
std::atomic<uint64_t> m_sequence;
- std::map<uint64_t, handler_info *> m_infos;
+ std::map<uint64_t, handler_info *> m_handlers;
int m_term_fd;
};