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

Diff for /libaitrpc/src/blobcli.c between versions 1.2 and 1.3

version 1.2, 2015/07/02 22:28:15 version 1.3, 2024/03/20 17:32:31
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 - 2015Copyright 2004 - 2024
         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 79  rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, ait_val_t Line 79  rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, ait_val_t
         /* send SET request */          /* send SET request */
         pfd.fd = cli->cli_sock;          pfd.fd = cli->cli_sock;
         pfd.events = POLLOUT;          pfd.events = POLLOUT;
        if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) == -1 ||         if (poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000) == -1 || 
                         pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {                          pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
                 LOGERR;                  LOGERR;
                 return -1;                  return -1;
Line 165  rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t Line 165  rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t
         /* send GET request */          /* send GET request */
         pfd.fd = cli->cli_sock;          pfd.fd = cli->cli_sock;
         pfd.events = POLLOUT;          pfd.events = POLLOUT;
        if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) == -1 ||         if (poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000) == -1 || 
                         pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {                          pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
                 LOGERR;                  LOGERR;
                 e_free(*data);                  e_free(*data);
Line 182  rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t Line 182  rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t
         /* receive BLOB from server */          /* receive BLOB from server */
         pfd.events = POLLIN | POLLPRI;          pfd.events = POLLIN | POLLPRI;
         for (ret = AIT_LEN(var), pos = *data; ret > 0; ret -= len, pos += len) {          for (ret = AIT_LEN(var), pos = *data; ret > 0; ret -= len, pos += len) {
                if ((len = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 ||                 if (poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000) < 1 || 
                                 pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {                                  pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
                         LOGERR;                          LOGERR;
                         e_free(*data);                          e_free(*data);
Line 256  rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_val_t  Line 256  rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_val_t 
         /* send UNSET request */          /* send UNSET request */
         pfd.fd = cli->cli_sock;          pfd.fd = cli->cli_sock;
         pfd.events = POLLOUT;          pfd.events = POLLOUT;
        if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) == -1 ||         if (poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000) == -1 || 
                         pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {                          pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
                 LOGERR;                  LOGERR;
                 return -1;                  return -1;
Removed from v.1.2  
changed lines
  Added in v.1.3

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