X-Git-Url: http://pilppa.org/gitweb/?p=libplpbus.git;a=blobdiff_plain;f=src_test%2Ftest_client.cc;fp=src_test%2Ftest_client.cc;h=64d06bc1817351fc7dc126d441ea8fcf5784a1fa;hp=71ba4aed907d8aa5ffa2ca82ee997b0351bc2526;hb=827ba77fe55e4587ef605068ab092216cfffad2c;hpb=14952f0047c37298f20c5c084c60a8be344cb446

diff --git a/src_test/test_client.cc b/src_test/test_client.cc
index 71ba4ae..64d06bc 100644
--- 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;
 }