X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=low-can-binding%2Fbinding%2Flow-can-cb.cpp;h=750baeffcc585e160667a4876b2d6072a844a201;hb=a6fb72a70f90c35e0968f2460d324a8505410562;hp=daeb5a0bb01fa8f70f3eaf5cea8bba69a62f7db7;hpb=e190b7b3069d86fce25831c366bb0cd3fa615289;p=apps%2Fagl-service-can-low-level.git

diff --git a/low-can-binding/binding/low-can-cb.cpp b/low-can-binding/binding/low-can-cb.cpp
index daeb5a0b..750baeff 100644
--- a/low-can-binding/binding/low-can-cb.cpp
+++ b/low-can-binding/binding/low-can-cb.cpp
@@ -85,13 +85,13 @@ int read_message(sd_event_source *event_source, int fd, uint32_t revents, void *
 	low_can_subscription_t* can_subscription = (low_can_subscription_t*)userdata;
 	if ((revents & EPOLLIN) != 0)
 	{
-		can_message_t cm;
+		std::shared_ptr<can_message_t> cm;
 		utils::socketcan_bcm_t& s = can_subscription->get_socket();
-		s >> cm;
+		cm = s.read_message();
 
 		// Sure we got a valid CAN message ?
-		if(! cm.get_id() == 0 && ! cm.get_length() == 0)
-			{push_n_notify(cm);}
+		if(! cm->get_id() == 0 && ! cm->get_length() == 0)
+			{push_n_notify(*cm);}
 	}
 
 	// check if error or hangup
@@ -263,7 +263,7 @@ static int subscribe_unsubscribe_can_signals(afb_req_t request,
 			{return -1;}
 
 		rets++;
-		AFB_DEBUG("signal: %s subscribed", sig->get_name().c_str());
+		AFB_DEBUG("%s Signal: %s %ssubscribed", sig->get_message()->is_fd() ? "FD": "", sig->get_name().c_str(), subscribe ? "":"un");
 	}
 	return rets;
 }