First draft about lock/wait thread management.
[apps/agl-service-can-low-level.git] / src / can-signals.cpp
1 /*
2  * Copyright (C) 2015, 2016 "IoT.bzh"
3  * Author "Romain Forlot" <romain.forlot@iot.bzh>
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  *       http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  */
17
18 #include "can-signals.hpp"
19
20 #include <fnmatch.h>
21
22 #include "low-can-binding.hpp"
23
24 /**
25  * @brief Dumb SIGNALS array. It is composed by CanMessageSet
26  * SIGNALS[MESSAGE_SET_ID][CanSignal]
27  */
28 std::vector<std::vector<CanSignal>> SIGNALS {
29         {}// message set: example
30 };
31
32 const std::vector<CanSignal> getSignals()
33 {
34         return SIGNALS[MESSAGE_SET_ID];
35 }
36
37 size_t getSignalCount()
38 {
39         return SIGNALS[MESSAGE_SET_ID].size();
40 }
41
42 std::vector<CanSignal> find_can_signals(openxc_DynamicField& key)
43 {
44         std::vector<CanSignal> signals;
45
46         switch(key.type)
47         {
48                 case openxc_DynamicField_Type::openxc_DynamicField_Type_STRING:
49                         for(const CanSignal& s : getSignals())
50                         {
51                                 if(fnmatch(key.string_value, s.genericName, FNM_CASEFOLD) == 0)
52                                         signals.push_back(s);
53                         }
54                         break;
55                 case openxc_DynamicField_Type::openxc_DynamicField_Type_NUM:
56                         for(const CanSignal& s : getSignals())
57                         {
58                                 CanMessageDefinition *msg_def = s.message;
59                                 if(msg_def->id == key.numeric_value)
60                                         signals.push_back(s);
61                         }
62                         break;
63                 default:
64                         ERROR(binder_interface, "find_can_signals: wrong openxc_DynamicField specified. Use openxc_DynamicField_Type_NUM or openxc_DynamicField_Type_STRING type only.");
65                         CanSignal cs;
66                         ::memset(&cs, 0, sizeof(CanSignal));
67                         signals.push_back(cs);
68                         return signals;
69                         break;
70         }
71         return signals;
72 }
73
74 inline uint32_t get_CanSignal_id(const CanSignal& sig)
75 {
76         return sig.message->id;
77 }
78
79 const std::map<std::string, struct afb_event> get_subscribed_signals()
80 {
81         return subscribed_signals;
82 }