[BACK]Return to tsrv.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / example

Diff for /libaitrpc/example/tsrv.c between versions 1.17 and 1.19

version 1.17, 2015/05/18 15:09:59 version 1.19, 2024/03/20 17:32:30
Line 1 Line 1
 #include <stdio.h>  #include <stdio.h>
   #include <string.h>
   #include <errno.h>
 #include <pthread.h>  #include <pthread.h>
 #include <aitrpc.h>  #include <aitrpc.h>
 #include "rc.h"  #include "rc.h"
Line 107  int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ Line 109  int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
   
         printf("Ok lets fun... %d\n", array_Size(iv));          printf("Ok lets fun... %d\n", array_Size(iv));
   
           mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__);
         v = ait_getVars(&RPC_RETVARS(cli), 0);          v = ait_getVars(&RPC_RETVARS(cli), 0);
         AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*)));          AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*)));
           mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__);
         return 0;          return 0;
 }  }
   
Line 121  int main(int argc, char **argv) Line 125  int main(int argc, char **argv)
                 if (argc > 2)                  if (argc > 2)
                         srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 0, SOCK_RAW);                          srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 0, SOCK_RAW);
                 else                  else
                        srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM);                        srv = rpc_srv_initServer(2, 5, 1024 * 10, "0.0.0.0", 11112, SOCK_DGRAM);
         } else          } else
                srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 0);                srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11112, 0);
         if (!srv) {          if (!srv) {
                 printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());                  printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
                 return 1;                  return 1;
         }          }
   
           rpc_srv_DispatchSignal(srv, 42);
   
         if (rpc_srv_initBLOBServer(srv, 0, "/tmp")) {          if (rpc_srv_initBLOBServer(srv, 0, "/tmp")) {
                 printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());                  printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
                 return 1;                  return 1;
Line 146  int main(int argc, char **argv) Line 152  int main(int argc, char **argv)
         rpc_register_srvServices(srv);          rpc_register_srvServices(srv);
         rpc_register_blobServices(srv);          rpc_register_blobServices(srv);
   
           mpool_dump(NULL, NULL);
   
         rpc_srv_execBLOBServer(srv);          rpc_srv_execBLOBServer(srv);
         rpc_srv_loopServer(srv);          rpc_srv_loopServer(srv);
           rpc_srv_DispatchSignal(srv, 0);
   
         rpc_srv_endBLOBServer(srv);          rpc_srv_endBLOBServer(srv);
         rpc_srv_endServer(&srv);          rpc_srv_endServer(&srv);
           mpool_dump(NULL, NULL);
         return 0;          return 0;
 }  }
Removed from v.1.17  
changed lines
  Added in v.1.19

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>