4 * Copyright (c) 2017 Samsung Electronics Co., Ltd.
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
21 #include <sensor_log.h>
22 #include "sensor_handler.h"
24 using namespace sensor;
26 bool sensor_handler::has_observer(sensor_observer *ob)
28 for (auto it = m_observers.begin(); it != m_observers.end(); ++it) {
36 void sensor_handler::add_observer(sensor_observer *ob)
38 ret_if(has_observer(ob));
40 m_observers.push_back(ob);
43 void sensor_handler::remove_observer(sensor_observer *ob)
45 m_observers.remove(ob);
48 int sensor_handler::notify(const char *uri, sensor_data_t *data, int len)
50 if (observer_count() == 0)
55 msg = new(std::nothrow) ipc::message((char *)data, len);
56 retvm_if(!msg, OP_ERROR, "Failed to allocate memory");
58 for (auto it = m_observers.begin(); it != m_observers.end(); ++it)
59 (*it)->update(uri, msg);
61 if (msg->ref_count() == 0)
67 uint32_t sensor_handler::observer_count(void)
69 return m_observers.size();