Remove socket read management by systemd event

loop and use classic thread with a blocking
read

Change-Id: Iac5428009b57c727bb32bd4893bc3fe282ba35c7
Signed-off-by: Romain Forlot <romain.forlot@iot.bzh>

1 files changed, 59 insertions, 0 deletions

diff --git a/src/low-can-binding-new.cpp b/src/low-can-binding-new.cpp
index 3686c6b3..13571f2a 100644
--- a/src/low-can-binding-new.cpp
+++ b/src/low-can-binding-new.cpp
@@ -23,6 +23,65 @@
 *		Subscription and unsubscription
 *
 *********************************************************************************/
+static int subscribe_unsubscribe_signal(struct afb_req request, const std::string& sig)
+{
+	int ret;
+
+	// TODO: lock the subscribed_signals when insert/remove
+	const auto& ss_i = subscribed_signals.find(sig);
+	if (ss_i != subscribed_signals.end())
+	{
+		if(!afb_event_is_valid(ss_i->second))
+		{
+			if(!subscribe)
+			{
+				NOTICE(binder_interface, "Event isn't valid, it can't be unsubscribed.");
+				ret = 1;
+			}
+			else
+			{
+				ss_i->second = afb_daemon_make_event(binder_interface->daemon, ss_i->first.c_str());
+				if (!afb_event_is_valid(ss_i->second)) 
+				{
+					ERROR(binder_interface, "Can't create an event, something goes wrong.");
+					ret = 0;
+				}
+			}
+		}
+	}
+	else
+	{
+		subscribed_signals[sig] = afb_daemon_make_event(binder_interface->daemon, sig);
+		if (!afb_event_is_valid(ss_i->second)) 
+		{
+			ERROR(binder_interface, "Can't create an event, something goes wrong.");
+			ret = 0;
+		}
+	}
+
+	if (((subscribe ? afb_req_subscribe : afb_req_unsubscribe)(request, subscribed_signals[sig])) < 0)
+	{
+		ERROR(binder_interface, "Operation goes wrong for signal: %s", sig);
+		ret = 0;
+	}
+	else
+		ret = 1;
+	
+	return ret;
+}
+
+static int subscribe_signals(struct afb_req request, const std::vector<std::string>& signals)
+{
+	int ret = 0;
+
+	for(const auto& signal_i : signals)
+	{
+		ret = subscribe_signal(request, subscribe, signal_i);
+		if(ret == 0)
+			return ret;
+	}
+	return ret;
+}
 
 std::vector<std::string> get_name(struct afb_req request)
 {