4 * Copyright (c) 2014 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.
20 #ifndef _SENSOR_EVENT_QUEUE_H_
21 #define _SENSOR_EVENT_QUEUE_H_
27 #include <condition_variable>
29 #include <sensor_common.h>
31 extern std::set<unsigned int> priority_list;
33 class sensor_event_queue {
35 static const unsigned int QUEUE_FULL_SIZE = 1000;
39 bool operator() (void *&v1, void *&v2) {
40 sensor_event_t *e1 = (sensor_event_t *)v1;
41 sensor_event_t *e2 = (sensor_event_t *)v2;
42 bool prioritize_e1 = true;
43 bool prioritize_e2 = true;
45 if (priority_list.empty())
46 return (e2->data->timestamp < e1->data->timestamp);
48 std::set<unsigned int>::iterator iter_e1 = priority_list.find(e1->event_type);
49 std::set<unsigned int>::iterator iter_e2 = priority_list.find(e2->event_type);
51 if (iter_e1 == priority_list.end())
52 prioritize_e1 = false;
54 if (iter_e2 == priority_list.end())
55 prioritize_e2 = false;
61 if (e2->data->timestamp <= e1->data->timestamp)
69 else if (e2->data->timestamp <= e1->data->timestamp)
77 std::priority_queue<void *, std::vector<void *>, compare> m_queue;
80 std::condition_variable m_cond_var;
82 typedef std::lock_guard<std::mutex> lock;
83 typedef std::unique_lock<std::mutex> ulock;
85 sensor_event_queue() {};
86 ~sensor_event_queue() {};
87 sensor_event_queue(const sensor_event_queue &) {};
88 sensor_event_queue& operator=(const sensor_event_queue &);
89 void push_internal(void *event);
91 static sensor_event_queue& get_instance();
93 void push(sensor_event_t *event);
97 #endif /* _SENSOR_EVENT_QUEUE_H_*/