Use a send instead of send_snyc

* To prevent timeout when calling select

Change-Id: Iba1bf0149012c4f3eae90e93a549a02349285167
Signed-off-by: Boram Bae <boram21.bae@samsung.com>

diff --git a/src/server/sensor_manager.cpp b/src/server/sensor_manager.cpp
index e1826d49ecaaf195ffd2319ad6c65146994e035b..6280b6aad64121b60f072295f7fceb90a1999e48 100644 (file)
--- a/src/server/sensor_manager.cpp
+++ b/src/server/sensor_manager.cpp
@@ -130,10 +130,10 @@ int sensor_manager::serialize(sensor_info *info, char **bytes)
        return size;
 }
 
-void sensor_manager::send(ipc::message &msg)
+void sensor_manager::send(std::shared_ptr<ipc::message> msg)
 {
        for (auto it = m_channels.begin(); it != m_channels.end(); ++it)
-               (*it)->send_sync(msg);
+               (*it)->send(msg);
 }
 
 void sensor_manager::send_added_msg(sensor_info *info)
@@ -143,17 +143,17 @@ void sensor_manager::send_added_msg(sensor_info *info)
 
        size = serialize(info, &bytes);
 
-       ipc::message msg((const char *)bytes, size);
-       msg.set_type(CMD_MANAGER_SENSOR_ADDED);
+       auto msg = ipc::message::create((const char *)bytes, size);
+       msg->set_type(CMD_MANAGER_SENSOR_ADDED);
 
        send(msg);
 }
 
 void sensor_manager::send_removed_msg(const std::string &uri)
 {
-       ipc::message msg;
-       msg.set_type(CMD_MANAGER_SENSOR_REMOVED);
-       msg.enclose(uri.c_str(), uri.size());
+       auto msg = ipc::message::create();
+       msg->set_type(CMD_MANAGER_SENSOR_REMOVED);
+       msg->enclose(uri.c_str(), uri.size());
 
        send(msg);
 }

diff --git a/src/server/sensor_manager.h b/src/server/sensor_manager.h
index aac7e935b3fb5b250eab6c86c94e696c5d6b69d1..489daafb668e6a5e98b9f780f1f2e2e469afc1f6 100644 (file)
--- a/src/server/sensor_manager.h
+++ b/src/server/sensor_manager.h
@@ -74,7 +74,7 @@ private:
 
        int serialize(sensor_info *info, char **bytes);
 
-       void send(ipc::message &msg);
+       void send(std::shared_ptr<ipc::message> msg);
        void send_added_msg(sensor_info *info);
        void send_removed_msg(const std::string &uri);