summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJosé Bollo <jose.bollo@iot.bzh>2017-05-30 19:20:35 +0200
committerRomain Forlot <romain.forlot@iot.bzh>2017-06-01 18:26:17 +0200
commit02deb38e600ba46a695963c6bb71ff13056761ee (patch)
treec8a99c4a74bc19bb77b2303cb0838891923f8fe7
parent1a6700012e66dfd67253e05819b9cb54daba64fa (diff)
optimise flow
Change-Id: I56d796531120236591f00fdf7a30f0a4495cbef2 Signed-off-by: José Bollo <jose.bollo@iot.bzh>
-rw-r--r--CAN-binder/low-can-binding/binding/low-can-cb.cpp87
1 files changed, 31 insertions, 56 deletions
diff --git a/CAN-binder/low-can-binding/binding/low-can-cb.cpp b/CAN-binder/low-can-binding/binding/low-can-cb.cpp
index e34ceaa3..ace53488 100644
--- a/CAN-binder/low-can-binding/binding/low-can-cb.cpp
+++ b/CAN-binder/low-can-binding/binding/low-can-cb.cpp
@@ -445,111 +445,86 @@ static int subscribe_unsubscribe_signals(struct afb_req request, bool subscribe,
return rets;
}
-static int process_args(struct afb_req request, std::map<std::string, struct event_filter_t>& args, bool subscribe)
+static int one_subscribe_unsubscribe(struct afb_req request, bool subscribe, const char *tag, struct json_object *event)
{
- struct utils::signals_found sf;
- int ok = 0, total = 0;
-
- for(auto& sig: args)
- {
- openxc_DynamicField search_key = build_DynamicField(sig.first);
- sf = utils::signals_manager_t::instance().find_signals(search_key);
- total = (int)sf.can_signals.size() + (int)sf.diagnostic_messages.size();
-
- if (sf.can_signals.empty() && sf.diagnostic_messages.empty())
- NOTICE(binder_interface, "%s: No signal(s) found for %s.", __FUNCTION__, sig.first.c_str());
- else
- ok = subscribe_unsubscribe_signals(request, subscribe, sf, sig.second);
- }
- NOTICE(binder_interface, "%s: Subscribed/unsubscribe correctly to %d/%d signal(s).", __FUNCTION__, ok, total);
- return ok;
-}
-
-static int parse_filter(json_object* event, struct event_filter_t& event_filter)
-{
- struct json_object *filter, *obj;
int ret = 0;
+ struct event_filter_t event_filter;
+ struct json_object *filter, *obj;
+ struct utils::signals_found sf;
+ // computes the filter
if (json_object_object_get_ex(event, "filter", &filter))
{
if (json_object_object_get_ex(filter, "frequency", &obj)
- && json_object_get_type(obj) == json_type_double)
+ && (json_object_is_type(obj, json_type_double) || json_object_is_type(obj, json_type_int)))
{
event_filter.frequency = (float)json_object_get_double(obj);
ret += 1;
}
if (json_object_object_get_ex(filter, "min", &obj)
- && json_object_get_type(obj) == json_type_double)
+ && (json_object_is_type(obj, json_type_double) || json_object_is_type(obj, json_type_int)))
{
event_filter.min = (float)json_object_get_double(obj);
ret += 2;
}
if (json_object_object_get_ex(filter, "max", &obj)
- && json_object_get_type(obj) == json_type_double)
+ && (json_object_is_type(obj, json_type_double) || json_object_is_type(obj, json_type_int)))
{
event_filter.max = (float)json_object_get_double(obj);
ret += 4;
}
}
+ // subscribe or unsubscribe
+ openxc_DynamicField search_key = build_DynamicField(tag);
+ sf = utils::signals_manager_t::instance().find_signals(search_key);
+ if (sf.can_signals.empty() && sf.diagnostic_messages.empty())
+ NOTICE(binder_interface, "%s: No signal(s) found for %s.", __FUNCTION__, tag.c_str());
+ else
+ ret = subscribe_unsubscribe_signals(request, subscribe, sf, event_filter);
+
return ret;
}
-static const std::map<std::string, struct event_filter_t> parse_args_from_request(struct afb_req request)
+static void do_subscribe_unsubscribe(struct afb_req request, bool subscribe)
{
- int i, n;
- std::map<std::string, struct event_filter_t > ret;
+ int rc, rc2;
struct json_object *args, *event, *x;
- struct event_filter_t event_filter;
- /* retrieve signals to subscribe */
args = afb_req_json(request);
if (args == NULL || !json_object_object_get_ex(args, "event", &event))
{
- parse_filter(json_object_new_string("*"), event_filter);
- ret["*"] = event_filter;
+ rc = one_subscribe_unsubscribe(request, subscribe, "*", NULL);
}
else if (json_object_get_type(event) != json_type_array)
{
- const std::string event_pattern = std::string(json_object_get_string(event));
- parse_filter(event, event_filter);
- ret[event_pattern] = event_filter;
+ rc = one_subscribe_unsubscribe(request, subscribe, json_object_get_string(event), event);
}
else
{
+ rc = 0;
n = json_object_array_length(event);
for (i = 0 ; i < n ; i++)
{
x = json_object_array_get_idx(event, i);
- const std::string event_pattern = std::string(json_object_get_string(x));
- parse_filter(x, event_filter);
- ret[event_pattern] = event_filter;
+ rc2 = one_subscribe_unsubscribe(request, subscribe, json_object_get_string(x), x);
+ if (rc >= 0)
+ rc = rc2 >= 0 ? rc + rc2 : rc2;
}
}
- return ret;
+ if (rc >= 0)
+ afb_req_success(request, NULL, NULL);
+ else
+ afb_req_fail(request, "error", NULL);
}
void subscribe(struct afb_req request)
{
- bool subscribe = true;
-
- std::map<std::string, struct event_filter_t> args = parse_args_from_request(request);
-
- if (process_args(request, args, subscribe) > 0)
- afb_req_success(request, NULL, NULL);
- else
- afb_req_fail(request, "error", NULL);
+ do_subscribe_unsubscribe(request, true);
}
void unsubscribe(struct afb_req request)
{
- bool subscribe = false;
-
- std::map<std::string, struct event_filter_t> args = parse_args_from_request(request);
-
- if (process_args(request, args, subscribe) > 0)
- afb_req_success(request, NULL, NULL);
- else
- afb_req_fail(request, "error", NULL);
-} \ No newline at end of file
+ do_subscribe_unsubscribe(request, false);
+}