From 878f170b6194fe4af589439c559cf3d9d4a04819 Mon Sep 17 00:00:00 2001 From: Jaeyun Date: Thu, 18 Aug 2022 19:35:26 +0900 Subject: [PATCH] [Test] set valid condition for MQTT test Set valid condition and start MQTT to run invalid param TCs. Signed-off-by: Jaeyun --- src/libnnstreamer-edge/nnstreamer-edge-mqtt.c | 2 +- tests/unittest_nnstreamer-edge.cc | 19 +++++++++++++++++++ 2 files changed, 20 insertions(+), 1 deletion(-) diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.c b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.c index 5fccb51..9f6a009 100644 --- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.c +++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.c @@ -296,7 +296,7 @@ nns_edge_mqtt_subscribe (nns_edge_h edge_h) } if (!MQTTAsync_isConnected (handle)) { - nns_edge_loge ("Invalid state, MQTT connection was not completed."); + nns_edge_loge ("Failed to subscribe, MQTT is not connected."); return NNS_EDGE_ERROR_IO; } diff --git a/tests/unittest_nnstreamer-edge.cc b/tests/unittest_nnstreamer-edge.cc index abd33ca..04ba730 100644 --- a/tests/unittest_nnstreamer-edge.cc +++ b/tests/unittest_nnstreamer-edge.cc @@ -3436,7 +3436,13 @@ TEST(edgeMqtt, publishInvalidParam2_n) ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID, NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h); EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); + nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost"); + nns_edge_set_info (edge_h, "DEST_PORT", "1883"); + + ret = nns_edge_start (edge_h); + EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); + /* data is null */ ret = nns_edge_mqtt_publish (edge_h, NULL, strlen (msg) + 1); EXPECT_NE (ret, NNS_EDGE_ERROR_NONE); @@ -3459,7 +3465,13 @@ TEST(edgeMqtt, publishInvalidParam3_n) ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID, NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h); EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); + nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost"); + nns_edge_set_info (edge_h, "DEST_PORT", "1883"); + ret = nns_edge_start (edge_h); + EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); + + /* data length is 0 */ ret = nns_edge_mqtt_publish (edge_h, msg, 0); EXPECT_NE (ret, NNS_EDGE_ERROR_NONE); @@ -3482,6 +3494,8 @@ TEST(edgeMqtt, publishInvalidParam4_n) ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID, NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h); EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); + nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost"); + nns_edge_set_info (edge_h, "DEST_PORT", "1883"); ret = nns_edge_mqtt_publish (edge_h, msg, strlen (msg) + 1); EXPECT_NE (ret, NNS_EDGE_ERROR_NONE); @@ -3555,6 +3569,11 @@ TEST(edgeMqtt, getMessageInvalidParam2_n) ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID, NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h); EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); + nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost"); + nns_edge_set_info (edge_h, "DEST_PORT", "1883"); + + ret = nns_edge_start (edge_h); + EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE); ret = nns_edge_mqtt_get_message (edge_h, NULL); EXPECT_NE (ret, NNS_EDGE_ERROR_NONE); -- 2.34.1