X-Git-Url: http://pilppa.org/gitweb/?a=blobdiff_plain;f=src_test%2Ftest_client.cc;h=dcc22a68f59d0501d9339d36a4fcf34d9ee26c25;hb=3e002aa0945999a48cf8b9e852777f93d72830eb;hp=71ba4aed907d8aa5ffa2ca82ee997b0351bc2526;hpb=3325b4c3b02fdd377f8460c4a1d19bd75b4e32ab;p=libplpbus.git

diff --git a/src_test/test_client.cc b/src_test/test_client.cc
index 71ba4ae..dcc22a6 100644
--- a/src_test/test_client.cc
+++ b/src_test/test_client.cc
@@ -4,6 +4,9 @@
  *  Created on: Jun 9, 2010
  *      Author: lamikr
  */
+#include <malloc.h>
+#include <unistd.h>
+
 #include <plp/log.h>
 
 #include "plpbus/BusServer.hh"
@@ -42,12 +45,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 +59,49 @@ 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);
+					free(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");
 		}
+		delete(client);
+		delete(lstnr);
 	}
 	else {
-		cout << "usage: <server_name> <message text>"  << endl;
+		log_info("usage: <server_name> <message text>\n");
 	}
 	return 0;
 }