Force to add type_id identifier for messages. Receiver can then use the

[libplpbus.git] / src_test / test_server.cc

diff --git a/src_test/test_server.cc b/src_test/test_server.cc
index c59d76ee76280c6b072fe8a62d106d4293ee365d..a310b1d95abe4683ec107e53d27f8bc78ce9547d 100644 (file)
--- a/src_test/test_server.cc
+++ b/src_test/test_server.cc
@@ -1,10 +1,13 @@
-#include <iostream>
+#include <string.h>
+#include <plp/log.h>
 
 #include "plpbus/BusServer.hh"
 
 using namespace std;
 using namespace plpbus;
 
+#define MSG_ID_HELLO   0
+
 class ServerListenerImpl : public IServerListener
 {
        public:
@@ -15,16 +18,18 @@ class ServerListenerImpl : public IServerListener
 };
 
 int ServerListenerImpl::request_received(const char *msg_req_param, char **msg_rsp_param) {
-       cout << "request_received(char *" << msg_req_param << ") " << endl;
+       log_debug("request_received(), request_param: %s\n", msg_req_param);
        *msg_rsp_param = strdup("jee");
+       log_debug("request_received(), response param set: %s\n", *msg_rsp_param);
        return 0;
 }
 
 int ServerListenerImpl::request_received(const BusMessage *msg_req_param, BusMessage **msg_rsp_param) {
-       cout << "request_received(BusMessage *) " << endl;
-       *msg_rsp_param = new BusMessage();
+       log_debug("request_received(BusMessage *) started\n");
+       *msg_rsp_param = new BusMessage(MSG_ID_HELLO);
        double dbl = (double)1.0;
        (*msg_rsp_param)->add_double_parameter("rsp_param_double", dbl);
+       log_debug("request_received(BusMessage *) done\n");
        return 0;
 }
 
@@ -34,7 +39,7 @@ int main(int argc, char** argv)
        ServerListenerImpl      *listener;
 
        if (argc >= 2) {
-               cout << "starting server"  << endl;
+               log_info("starting server\n");
                server          = new BusServer();
                server->init();
                listener        = new ServerListenerImpl();
@@ -42,7 +47,7 @@ int main(int argc, char** argv)
                server->launch(argv[1]);
        }
        else {
-               cout << "usage: give server name as a parameter"  << endl;
+               log_info("usage: give server name as a parameter\n");
        }
        return 0;
 }