rpc_srvr.cxx

Go to the documentation of this file.

/********************************************************************\
 
  Name:         rpc_srvr.c
  Created by:   Stefan Ritt
 
  Contents:     A simple RPC server program. Implements a function
                rpc_test, which simply doubles some parameters.
                This function can be calles remotely by rpc_clnt.
 
 
  $Id$
 
\********************************************************************/
 
#include "midas.h"
#include <stdio.h>
 
#define RPC_MYTEST RPC_MIN_ID
 
RPC_LIST rpc_list[] = {
 
   {RPC_MYTEST, "rpc_mytest",
    {{TID_UINT8, RPC_IN}
     ,
     {TID_UINT16, RPC_IN}
     ,
     {TID_INT32, RPC_IN}
     ,
     {TID_FLOAT, RPC_IN}
     ,
     {TID_DOUBLE, RPC_IN}
     ,
     {TID_UINT8, RPC_OUT}
     ,
     {TID_UINT16, RPC_OUT}
     ,
     {TID_UINT32, RPC_OUT}
     ,
     {TID_FLOAT, RPC_OUT}
     ,
     {TID_DOUBLE, RPC_OUT}
     ,
     {0}
     }
    }
   ,
 
   {0}
 
};
 
/*------------------------------------------------------------------*/
 
/* just a small test routine which doubles numbers */
INT rpc_mytest(BYTE b, WORD w, INT i, float f, double d,
               BYTE * b1, WORD * w1, INT * i1, float *f1, double *d1)
{
   *b1 = b * 2;
   *w1 = w * 2;
   *i1 = i * 2;
   *f1 = f * 2;
   *d1 = d * 2;
 
   return 1;
}
 
/* this dispatchers forwards RPC calls to the destination functions */
INT rpc_dispatch(INT index, void *prpc_param[])
{
   INT status = 1;
 
   switch (index) {
   case RPC_MYTEST:
      status = rpc_mytest(CBYTE(0), CWORD(1), CINT(2), CFLOAT(3), CDOUBLE(4),
                          CPBYTE(5), CPWORD(6), CPINT(7), CPFLOAT(8), CPDOUBLE(9));
      break;
 
   default:
      cm_msg(MERROR, "rpc_dispatch", "received unrecognized command");
   }
 
   return status;
}
 
/*------------------------------------------------------------------*/
 
int main()
{
   INT status;
 
   /* register RPC server under port 1750 */
   status = rpc_register_server(1750, NULL, NULL);
   if (status != RPC_SUCCESS) {
      printf("Cannot start server");
      return 0;
   }
 
   /* Register function list. Calls get forwarded to rpc_dispatch */
   rpc_register_functions(rpc_list, rpc_dispatch);
 
   /* Print debugging messages */
   rpc_set_debug((void (*)(const char *)) puts, 0);
 
   /* Server loop */
   while (cm_yield(1000) != RPC_SHUTDOWN);
 
   /* Shutdown server */
   rpc_server_shutdown();
 
   return 1;
}