[Test] set valid condition for MQTT test

Set valid condition and start MQTT to run invalid param TCs.

Signed-off-by: Jaeyun <jy1210.jung@samsung.com>

diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.c b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.c
index 5fccb512d465ea474125fa79252683cfbd5c2046..9f6a009944120d83a333587c0e215f8929e364e0 100644 (file)
--- 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 abd33ca6e8eb0fc18863cafd116b9f75723dd1ab..04ba730322a83685d4c2efb730a38692a94558e4 100644 (file)
--- 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,\r
       NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h);\r
   EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
+  nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost");\r
+  nns_edge_set_info (edge_h, "DEST_PORT", "1883");\r
+\r
+  ret = nns_edge_start (edge_h);\r
+  EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
 \r
+  /* data is null */\r
   ret = nns_edge_mqtt_publish (edge_h, NULL, strlen (msg) + 1);\r
   EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);\r
 \r
@@ -3459,7 +3465,13 @@ TEST(edgeMqtt, publishInvalidParam3_n)
   ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID,\r
       NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h);\r
   EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
+  nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost");\r
+  nns_edge_set_info (edge_h, "DEST_PORT", "1883");\r
 \r
+  ret = nns_edge_start (edge_h);\r
+  EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
+\r
+  /* data length is 0 */\r
   ret = nns_edge_mqtt_publish (edge_h, msg, 0);\r
   EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);\r
 \r
@@ -3482,6 +3494,8 @@ TEST(edgeMqtt, publishInvalidParam4_n)
   ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID,\r
       NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h);\r
   EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
+  nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost");\r
+  nns_edge_set_info (edge_h, "DEST_PORT", "1883");\r
 \r
   ret = nns_edge_mqtt_publish (edge_h, msg, strlen (msg) + 1);\r
   EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);\r
@@ -3555,6 +3569,11 @@ TEST(edgeMqtt, getMessageInvalidParam2_n)
   ret = nns_edge_create_handle ("temp-server", NNS_EDGE_CONNECT_TYPE_HYBRID,\r
       NNS_EDGE_FLAG_RECV | NNS_EDGE_FLAG_SEND | NNS_EDGE_FLAG_SERVER, &edge_h);\r
   EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
+  nns_edge_set_info (edge_h, "DEST_HOST", "tcp://localhost");\r
+  nns_edge_set_info (edge_h, "DEST_PORT", "1883");\r
+\r
+  ret = nns_edge_start (edge_h);\r
+  EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);\r
 \r
   ret = nns_edge_mqtt_get_message (edge_h, NULL);\r
   EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);\r