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    33
  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         long    type;
  29         int     err_flg;
  30
  31         type    = ((BusMessage *)msg_req_param)->get_type(&err_flg);
  32         log_debug("request_received, msg type: %ld\n", type);
  33         *msg_rsp_param = new BusMessage(MSG_ID_HELLO);
  34         double dbl = (double)1.0;
  35         (*msg_rsp_param)->add_double_parameter("rsp_param_double", dbl);
  36         return 0;
  37 }
  38
  39 int main(int argc, char** argv) {
  40         BusServer               *server;
  41         ServerListenerImpl      *listener;
  42
  43         if (argc >= 2) {
  44                 log_info("starting server\n");
  45                 server          = new BusServer();
  46                 server->init();
  47                 listener        = new ServerListenerImpl();
  48                 server->add_server_listener(listener);
  49                 server->launch(argv[1]);
  50         }
  51         else {
  52                 log_info("usage: give server name as a parameter\n");
  53         }
  54         return 0;
  55 }