[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.11.4.1 and 1.17

version 1.11.4.1, 2013/07/15 15:10:37 version 1.17, 2015/05/18 15:09:59
Line 4 Line 4
 #include "rc.h"  #include "rc.h"
   
   
   rpc_srv_t *srv;
   
   
 int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv)  int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv)
 {  {
 //      rpc_blob_t *b;  //      rpc_blob_t *b;
Line 26  int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ Line 29  int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
   
         rpc_srv_blobUnmap(b);          rpc_srv_blobUnmap(b);
         */          */
   
           RPC_SET_ERRNO(rpc, EAGAIN);
         return 0;          return 0;
 }  }
   
Line 59  int BBB(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ Line 64  int BBB(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
         AIT_SET_STR(ait_getVars(&RPC_RETVARS(cli), 2), "Oho boho i cheburashka");          AIT_SET_STR(ait_getVars(&RPC_RETVARS(cli), 2), "Oho boho i cheburashka");
   
         // return blob object          // return blob object
        b = rpc_srv_registerBLOB(s, 128, 0, cli);        b = rpc_srv_registerBLOB(s, 128, 0);
         if (!b)          if (!b)
                 return -1;                  return -1;
         else          else
Line 94  int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ Line 99  int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
         return 0;          return 0;
 }  }
   
   int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv)
   {
           ait_val_t *v;
   
int main()        RPC_CALLBACK_CHECK_INPUT(cli);
 
         printf("Ok lets fun... %d\n", array_Size(iv));
 
         v = ait_getVars(&RPC_RETVARS(cli), 0);
         AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*)));
         return 0;
 }
 
 int main(int argc, char **argv)
 {  {
         rpc_srv_t *srv;  
         rpc_func_t *f;          rpc_func_t *f;
         int ret;          int ret;
   
        srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM);        if (argc > 1) {
//        srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 0);                if (argc > 2)
                         srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 0, SOCK_RAW);
                 else
                         srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM);
         } else
                 srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 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;
Line 118  int main() Line 139  int main()
         rpc_srv_registerCall(srv, 3, NULL);          rpc_srv_registerCall(srv, 3, NULL);
         rpc_srv_registerCall(srv, RC_xYz, xYz);          rpc_srv_registerCall(srv, RC_xYz, xYz);
         rpc_srv_registerCall(srv, RC_xxx, xxx);          rpc_srv_registerCall(srv, RC_xxx, xxx);
           rpc_srv_registerCall(srv, RC_big, big);
   
         rpc_srv_unregisterCall(srv, 4);          rpc_srv_unregisterCall(srv, 4);
   
Removed from v.1.11.4.1  
changed lines
  Added in v.1.17

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