From: Seonah Moon <seonah1.moon@samsung.com>
Date: Wed, 2 Jun 2021 05:37:25 +0000 (+0900)
Subject: Verifier: send a message in joined callback for pubsub test
X-Git-Tag: submit/tizen/20210621.075049~8
X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=refs%2Fchanges%2F04%2F259204%2F2;p=platform%2Fcore%2Fapi%2Fvine.git

Verifier: send a message in joined callback for pubsub test

Change-Id: I78ac15aef4552ed8c8eabf2e8b5c8dc829170677
---

diff --git a/tests/verifier/vine-verifier.cpp b/tests/verifier/vine-verifier.cpp
index 92d2c94..b5fe0bc 100644
--- a/tests/verifier/vine-verifier.cpp
+++ b/tests/verifier/vine-verifier.cpp
@@ -421,12 +421,10 @@ static void __start_client(bool use_tls, bool use_psk)
 
 static void __pubsub_opened_cb(vine_dp_h dp, vine_error_e result, void *user_data)
 {
-	if (result == VINE_ERROR_NONE) {
+	if (result == VINE_ERROR_NONE)
 		printf("Success to open a pub/sub data path\n");
-		vine_dp_send(dp, (unsigned char *)PUBSUB_MSG, strlen(PUBSUB_MSG));
-	} else {
+	else
 		PRINT_IF_ERROR(result, "Fail to open the pub/sub data path.");
-	}
 }
 
 static void __pubsub_received_cb(vine_dp_h dp, size_t received_len, void *user_data)
@@ -441,6 +439,17 @@ static void __pubsub_received_cb(vine_dp_h dp, size_t received_len, void *user_d
 	} while (received_len > 0);
 }
 
+static void __pubsub_peer_joined_cb(vine_dp_h dp, const char *peer_id, void *user_data)
+{
+	printf("peer[%s] is joiend.\n", peer_id);
+	vine_dp_send(dp, (unsigned char *)PUBSUB_MSG, strlen(PUBSUB_MSG));
+}
+
+static void __pubsub_peer_left_cb(vine_dp_h dp, const char *peer_id, void *user_data)
+{
+	printf("peer[%s] is left.\n", peer_id);
+}
+
 static void __start_pubsub(bool use_tls, bool use_psk)
 {
 	printf("Start pub/sub\n");
@@ -463,6 +472,8 @@ static void __start_pubsub(bool use_tls, bool use_psk)
 	vine_dp_set_security(dp, security);
 	vine_dp_set_topic(dp, TOPIC);
 	vine_dp_set_received_cb(dp, __pubsub_received_cb, NULL);
+	vine_dp_set_peer_joined_cb(dp, __pubsub_peer_joined_cb, NULL);
+	vine_dp_set_peer_left_cb(dp, __pubsub_peer_left_cb, NULL);
 	PRINT_RESULT(vine_dp_open(dp, __pubsub_opened_cb, session), "vine_dp_open");
 	vine_security_destroy(security);
 }