src_test/test_server.cc

   1 #include <string.h>
   2 #include <plp/log.h>
   3
   4 #include "plpbus/BusServer.hh"
   5
   6 using namespace std;
   7 using namespace plpbus;
   8
   9 #define MSG_ID_HELLO    0
  10
  11 class ServerListenerImpl : public IServerListener
  12 {
  13         public:
  14                 inline ServerListenerImpl() {}
  15                 virtual ~ServerListenerImpl() {}
  16                 virtual int request_received(const char *msg_req, char **msg_rsp);
  17                 virtual int request_received(const BusMessage *msg_req, BusMessage **msg_rsp);
  18 };
  19
  20 int ServerListenerImpl::request_received(const char *msg_req_param, char **msg_rsp_param) {
  21         log_debug("request_received(), request_param: %s\n", msg_req_param);
  22         *msg_rsp_param = strdup("jee");
  23         log_debug("request_received(), response param set: %s\n", *msg_rsp_param);
  24         return 0;
  25 }
  26
  27 int ServerListenerImpl::request_received(const BusMessage *msg_req_param, BusMessage **msg_rsp_param) {
  28         log_debug("request_received(BusMessage *) started\n");
  29         *msg_rsp_param = new BusMessage(MSG_ID_HELLO);
  30         double dbl = (double)1.0;
  31         (*msg_rsp_param)->add_double_parameter("rsp_param_double", dbl);
  32         log_debug("request_received(BusMessage *) done\n");
  33         return 0;
  34 }
  35
  36 int main(int argc, char** argv)
  37 {
  38         BusServer               *server;
  39         ServerListenerImpl      *listener;
  40
  41         if (argc >= 2) {
  42                 log_info("starting server\n");
  43                 server          = new BusServer();
  44                 server->init();
  45                 listener        = new ServerListenerImpl();
  46                 server->add_server_listener(listener);
  47                 server->launch(argv[1]);
  48         }
  49         else {
  50                 log_info("usage: give server name as a parameter\n");
  51         }
  52         return 0;
  53 }