Fix timing issue

[platform/core/api/vine.git] / tests / vine-test / vine-test.cpp

diff --git a/tests/vine-test/vine-test.cpp b/tests/vine-test/vine-test.cpp
index 4e62d7f..bf77461 100755 (executable)
--- a/tests/vine-test/vine-test.cpp
+++ b/tests/vine-test/vine-test.cpp
@@ -241,6 +241,16 @@ static void __opened_cb(vine_dp_h dp, vine_error_e result, void *user_data)
                __add_new_dp(dp);
 }
 
+static void __joined_cb(vine_dp_h dp, const char *peer_id, void *user_data)
+{
+       printf(COLOR_GRN "[PEER_JOINED_CB] %s is joined." COLOR_RESET "\n", peer_id);
+}
+
+static void __left_cb(vine_dp_h dp, const char *peer_id, void *user_data)
+{
+       printf(COLOR_GRN "[PEER_LEFT_CB] %s is left." COLOR_RESET "\n", peer_id);
+}
+
 static void __set_callbacks()
 {
        CHECK_SESSION;
@@ -643,6 +653,8 @@ static void __join_service()
        vine_dp_set_address_family(g_pubsub_dp, (vine_address_family_e)addr_family);
        vine_dp_set_port(g_pubsub_dp, port);
        vine_dp_set_topic(g_pubsub_dp, topic);
+       vine_dp_set_peer_joined_cb(g_pubsub_dp, __joined_cb, NULL);
+       vine_dp_set_peer_left_cb(g_pubsub_dp, __left_cb, NULL);
        // TODO: set security.
 
        vine_dp_set_terminated_cb(g_pubsub_dp, __terminated_cb, NULL);