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

Diff for /libaitrpc/src/cli.c between versions 1.26.4.3 and 1.28

version 1.26.4.3, 2016/08/02 12:00:39 version 1.28, 2020/06/25 19:11:00
Line 12  terms: Line 12  terms:
 All of the documentation and software included in the ELWIX and AITNET  All of the documentation and software included in the ELWIX and AITNET
 Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>  Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>
   
Copyright 2004 - 2016Copyright 2004 - 2019
         by Michael Pounov <misho@elwix.org>.  All rights reserved.          by Michael Pounov <misho@elwix.org>.  All rights reserved.
   
 Redistribution and use in source and binary forms, with or without  Redistribution and use in source and binary forms, with or without
Line 71  rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,  Line 71  rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli, 
         } else          } else
                 memcpy(cli, rpccli, sizeof(rpc_cli_t));                  memcpy(cli, rpccli, sizeof(rpc_cli_t));
   
        memcpy(&cli->cli_sa, &rpccli->cli_sa, sizeof(sockaddr_t));        memcpy(&cli->cli_sa, &rpccli->cli_sa, sizeof cli->cli_sa);
         switch (cli->cli_sa.sa.sa_family) {          switch (cli->cli_sa.sa.sa_family) {
                 case AF_INET:                  case AF_INET:
                         cli->cli_sa.sin.sin_port =                           cli->cli_sa.sin.sin_port = 
Line 111  rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,  Line 111  rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli, 
                 e_free(cli);                  e_free(cli);
                 return NULL;                  return NULL;
         }          }
        if (connect(cli->cli_sock, &cli->cli_sa.sa, sizeof cli->cli_sa.sa) == -1) {        if (connect(cli->cli_sock, &cli->cli_sa.sa, e_addrlen(&cli->cli_sa)) == -1) {
                 LOGERR;                  LOGERR;
                 close(cli->cli_sock);                  close(cli->cli_sock);
                 e_free(cli);                  e_free(cli);
Line 405  rpc_pkt_Receive(int sock, int type, sockaddr_t * __res Line 405  rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
                         if (seq != ntohl(rpc->call_seq))                          if (seq != ntohl(rpc->call_seq))
                                 continue;                                  continue;
                 }                  }
        } while (ret < 1);        } while (ret < 0);
   
         return ret;          return ret;
 }  }
Line 605  rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short  Line 605  rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short 
         if ((wlen = rpc_pkt_Receive(cli->cli_sock, cli->cli_id, &cli->cli_sa,           if ((wlen = rpc_pkt_Receive(cli->cli_sock, cli->cli_id, &cli->cli_sa, 
                                         &cli->cli_buf, seq)) == -1)                                          &cli->cli_buf, seq)) == -1)
                 return -1;                  return -1;
        if (!wlen)      /* closed rpc connection */        if (!wlen) {        /* closed rpc connection */
                return 1;                rpc_SetErr(ECONNRESET, "Closed connection");
                 return -1;
         }
   
         if ((wlen = rpc_pkt_Replay(&cli->cli_buf, cli->cli_parent, tag,           if ((wlen = rpc_pkt_Replay(&cli->cli_buf, cli->cli_parent, tag, 
                                         out_vars, type)) == -1)                                          out_vars, type)) == -1)
                 return -1;                  return -1;
   
        return 0;        return wlen;
 }  }
   
 /*  /*
Removed from v.1.26.4.3  
changed lines
  Added in v.1.28

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