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

Diff for /libaitrpc/src/blob.c between versions 1.6.2.2 and 1.7.2.1

version 1.6.2.2, 2012/05/11 12:53:35 version 1.7.2.1, 2012/05/16 08:10:39
Line 47  SUCH DAMAGE. Line 47  SUCH DAMAGE.
   
   
 /*  /*
 * rpc_srv_blobCreate() - Create map blob to memory region and return object * rpc_srv_blobCreate() - Create and map blob to memory region and return object
  *   *
  * @srv = RPC Server instance   * @srv = RPC Server instance
  * @len = BLOB length object   * @len = BLOB length object
Line 81  again: Line 81  again:
                 LOGERR;                  LOGERR;
                 return NULL;                  return NULL;
         }          }
        if (lseek(f, len - 1, SEEK_SET) == -1) {        if (ftruncate(f, len) == -1) {
                 LOGERR;                  LOGERR;
                 close(f);                  close(f);
                 unlink(szFName);                  unlink(szFName);
                 return NULL;                  return NULL;
        } else        }
                write(f, "", 1); 
   
         blob = malloc(sizeof(rpc_blob_t));          blob = malloc(sizeof(rpc_blob_t));
         if (!blob) {          if (!blob) {
Line 166  rpc_srv_blobMap(rpc_srv_t * __restrict srv, rpc_blob_t Line 165  rpc_srv_blobMap(rpc_srv_t * __restrict srv, rpc_blob_t
 inline void  inline void
 rpc_srv_blobUnmap(rpc_blob_t * __restrict blob)  rpc_srv_blobUnmap(rpc_blob_t * __restrict blob)
 {  {
        if (!blob || !blob->blob_data)        if (blob && blob->blob_data)
                rpc_SetErr(EINVAL, "Invalid arguments"); 
        else { 
                 munmap(blob->blob_data, blob->blob_len);                  munmap(blob->blob_data, blob->blob_len);
                 blob->blob_data = NULL;                  blob->blob_data = NULL;
         }          }
Line 189  rpc_srv_blobFree(rpc_srv_t * __restrict srv, rpc_blob_ Line 186  rpc_srv_blobFree(rpc_srv_t * __restrict srv, rpc_blob_
         if (!blob) {          if (!blob) {
                 rpc_SetErr(EINVAL, "Invalid argument BLOB");                  rpc_SetErr(EINVAL, "Invalid argument BLOB");
                 return -1;                  return -1;
        }        } else
 
        if (blob->blob_data) 
                 rpc_srv_blobUnmap(blob);                  rpc_srv_blobUnmap(blob);
   
         memset(szFName, 0, sizeof szFName);          memset(szFName, 0, sizeof szFName);
Line 204  rpc_srv_blobFree(rpc_srv_t * __restrict srv, rpc_blob_ Line 199  rpc_srv_blobFree(rpc_srv_t * __restrict srv, rpc_blob_
         return 0;          return 0;
 }  }
   
// ------------------------------------------------------------/* ------------------------------------------------------------ */
   
 /*  /*
  * rpc_srv_sendBLOB() - Send mapped BLOB to client   * rpc_srv_sendBLOB() - Send mapped BLOB to client
Line 326  rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, ait_val_t Line 321  rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, ait_val_t
                 if (ret)                  if (ret)
                         LOGERR;                          LOGERR;
                 else                  else
                        rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not responde");                        rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
                 return -1;                  return -1;
         }          }
         if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {          if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {
Line 424  rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t Line 419  rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t
                 if (len)                  if (len)
                         LOGERR;                          LOGERR;
                 else                  else
                        rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not responde");                        rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
                 free(*data);                  free(*data);
                 *data = NULL;                  *data = NULL;
                 return 1;                  return 1;
Line 498  rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_val_t  Line 493  rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_val_t 
                 if (ret)                  if (ret)
                         LOGERR;                          LOGERR;
                 else                  else
                        rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not responde");                        rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
                 return 1;                  return 1;
         }          }
         if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {          if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {
Removed from v.1.6.2.2  
changed lines
  Added in v.1.7.2.1

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