Memory leak fixes.

[libplpbus.git] / src_test / test_client.cc

diff --git a/src_test/test_client.cc b/src_test/test_client.cc
index 71ba4aed907d8aa5ffa2ca82ee997b0351bc2526..64d06bc1817351fc7dc126d441ea8fcf5784a1fa 100644 (file)
--- a/src_test/test_client.cc
+++ b/src_test/test_client.cc
@@ -42,12 +42,12 @@ int ClientListenerImpl::response_received(const BusMessage *msg_rsp_param) {
 }
 
 int ClientListenerImpl::event_received(const char *event_param) {
-       cout << "event_received(char *" << event_param << ") " << endl;
+       log_debug("event_received(%s)\n", event_param);
        return 0;
 }
 
 int ClientListenerImpl::event_received(const BusMessage *event_param) {
-       cout << "event_received(BusMessage *)" << endl;
+       log_debug("event_received(BusMessage *)\n");
        return 0;
 }
 
@@ -56,43 +56,46 @@ int main(int argc, char** argv)
        BusClient               *client;
        ClientListenerImpl      *lstnr;
        int                     err_flg;
-       BusMessage              *busmsg;
+       BusMessage              *bus_msg;
 
        if (argc >= 3) {
                client  = new BusClient();
                lstnr   = new ClientListenerImpl();
                err_flg = client->init(argv[1]);
                if (err_flg == 0) {
-                       cout << "init success" << endl;
+                       log_debug("init success\n");
                        err_flg = client->add_client_listener(lstnr);
                        if (err_flg == 0) {
                                int     err_flg;
                                char    *rsp;
 
-                               busmsg  = new BusMessage(MSG_ID_HELLO);
-                               busmsg->add_string_parameter("a", "hello");
-                               busmsg->add_string_parameter("b", "world");
-                               client->send_message_and_request_response(busmsg);
+                               bus_msg = new BusMessage(MSG_ID_HELLO);
+                               if (bus_msg != NULL) {
+                                       bus_msg->add_string_parameter("a", "hello");
+                                       bus_msg->add_string_parameter("b", "world");
+                                       client->send_message_and_request_response(bus_msg);
 
-                               rsp     = NULL;
-                               err_flg = client->send_message_and_wait_response(argv[2], &rsp);
-                               cout << "rsp: " << rsp << endl;
-                               err_flg = client->send_message_and_request_response(argv[2]);
-                               if (err_flg == 0) {
-                                       cout << "request message send successfully"  << endl;
+                                       rsp     = NULL;
+                                       err_flg = client->send_message_and_wait_response(argv[2], &rsp);
+                                       log_debug("rsp: %s\n", rsp);
+                                       err_flg = client->send_message_and_request_response(argv[2]);
+                                       if (err_flg == 0) {
+                                               log_debug("request message send successfully\n");
+                                       }
+                                       sleep(5);
+                                       delete(bus_msg);
                                }
-                               sleep(10);
                        }
                        else {
-                               cout << "client failed to add response listener"  << endl;
+                               log_error("client failed to add response listener\n");
                        }
                }
                else {
-                       cout << "client failed to init"  << endl;
+                       log_error("client failed to init\n");
                }
        }
        else {
-               cout << "usage: <server_name> <message text>"  << endl;
+               log_info("usage: <server_name> <message text>\n");
        }
        return 0;
 }