Source of H5Dcontig.c - hdf5_ep

Ignore whitespace
Hide e-diff
Unified diff
Side-by-side diff
Source viewDiff to previous
 
    hsize_t     total_src_nbytes;       /* Total number of bytes to copy */
    size_t      buf_size;               /* Size of copy buffer */
    void       *buf = NULL;             /* Buffer for copying data */
    void       *bkg = NULL;             /* Temporary buffer for copying data */
    void       *reclaim_buf = NULL;     /* Buffer for reclaiming data */
    H5S_t      *buf_space = NULL;       /* Dataspace describing buffer */
    hid_t       buf_sid = -1;           /* ID for buffer dataspace */
    hsize_t     buf_dim[1] = {0};       /* Dimension for buffer */
    hbool_t     is_vlen = FALSE;        /* Flag to indicate that VL type conversion should occur */
    hbool_t     fix_ref = FALSE;        /* Flag to indicate that ref values should be fixed */
    H5D_shared_t    *shared_fo = cpy_info->shared_fo;  /* Pointer to the shared struct for dataset object */
    hbool_t     try_sieve = FALSE;          /* Try to get data from the sieve buffer */
    haddr_t     sieve_start = HADDR_UNDEF;  /* Start location of sieve buffer */
    haddr_t     sieve_end = HADDR_UNDEF;    /* End locations of sieve buffer */ 
    herr_t      ret_value = SUCCEED;    /* Return value */
​
    FUNC_ENTER_PACKAGE
​
    /* Check args */
    HDassert(f_src);
    HDassert(storage_src);
    HDassert(f_dst);
    HDassert(storage_dst);
    HDassert(dt_src);
Show more
    /* Need extra buffer for datatype conversions, to prevent stranding/leaking memory */
    if(is_vlen || fix_ref) {
        if(NULL == (reclaim_buf = H5FL_BLK_MALLOC(type_conv, buf_size)))
            HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "memory allocation failed for copy buffer")
​
        /* allocate temporary bkg buff for data conversion */
        if(NULL == (bkg = H5FL_BLK_MALLOC(type_conv, buf_size)))
            HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "memory allocation failed for copy buffer")
    } /* end if */
​
    /* Loop over copying data */
    addr_src = storage_src->addr;
    addr_dst = storage_dst->addr;
​
    /* If data sieving is enabled and the dataset is open in the file,
       set up to copy data out of the sieve buffer if deemed possible later */
    if(H5F_HAS_FEATURE(f_src, H5FD_FEAT_DATA_SIEVE) &&
       shared_fo && shared_fo->cache.contig.sieve_buf) {
        try_sieve = TRUE;
        sieve_start = shared_fo->cache.contig.sieve_loc;
        sieve_end = sieve_start + shared_fo->cache.contig.sieve_size;
        /* 
         * It is possble for addr_src to be undefined when:
         *  (a) The dataset is created and data is written to it.
         *  (b) The dataset is then copied via H5Ocopy().
         *  H5D_mark() in H5Dint.c is different between 
         *  1.8 and develop branches:
         *  1.8--it just sets dataset->shared->layout_dirty as TRUE 
         *       to be flushed later.
         *  develop--it will flush the layout message if it has been changed.
         */
        if(!H5F_addr_defined(addr_src))
            addr_src = sieve_start;
    }
​
    HDassert(H5F_addr_defined(addr_src));
    /* Loop over copying data */
    while(total_src_nbytes > 0) {
        /* Check if we should reduce the number of bytes to transfer */
        if(total_src_nbytes < src_nbytes) {
            /* Adjust bytes to transfer */
            src_nbytes = (size_t)total_src_nbytes;
​
            /* Adjust dataspace describing buffer */
            if(is_vlen) {
                /* Adjust destination & memory bytes to transfer */
                nelmts = src_nbytes / src_dt_size;
Show more
​
                /* Adjust size of buffer's dataspace */
                if(H5S_set_extent_real(buf_space, buf_dim) < 0)
                    HGOTO_ERROR(H5E_DATASPACE, H5E_CANTSET, FAIL, "unable to change buffer dataspace size")
            } /* end if */
            else
                /* Adjust destination & memory bytes to transfer */
                dst_nbytes = mem_nbytes = src_nbytes;
        } /* end if */
​
        /* Read raw data from source file */
        if(H5F_block_read(f_src, H5FD_MEM_DRAW, addr_src, src_nbytes, H5P_DATASET_XFER_DEFAULT, buf) < 0)
            HGOTO_ERROR(H5E_DATASET, H5E_READERROR, FAIL, "unable to read raw data")
         /* If the entire copy is within the sieve buffer, copy data from the sieve buffer */
        if(try_sieve && (addr_src >= sieve_start) && ((addr_src + src_nbytes -1) < sieve_end)) {
            unsigned char *base_sieve_buf = shared_fo->cache.contig.sieve_buf + (addr_src - sieve_start);
​
            HDmemcpy(buf, base_sieve_buf, src_nbytes);
        } else
            /* Read raw data from source file */
            if(H5F_block_read(f_src, H5FD_MEM_DRAW, addr_src, src_nbytes, H5P_DATASET_XFER_DEFAULT, buf) < 0)
                HGOTO_ERROR(H5E_DATASET, H5E_READERROR, FAIL, "unable to read raw data")
​
        /* Perform datatype conversion, if necessary */
        if(is_vlen) {
            /* Convert from source file to memory */
        if(H5T_convert(tpath_src_mem, tid_src, tid_mem, nelmts, (size_t)0, (size_t)0, buf, bkg, dxpl_id) < 0)
            if(H5T_convert(tpath_src_mem, tid_src, tid_mem, nelmts, (size_t)0, (size_t)0, buf, bkg, dxpl_id) < 0)
                HGOTO_ERROR(H5E_DATATYPE, H5E_CANTINIT, FAIL, "datatype conversion failed")
​
            /* Copy into another buffer, to reclaim memory later */
            HDmemcpy(reclaim_buf, buf, mem_nbytes);
​
            /* Set background buffer to all zeros */
            HDmemset(bkg, 0, buf_size);
​
            /* Convert from memory to destination file */
        if(H5T_convert(tpath_mem_dst, tid_mem, tid_dst, nelmts, (size_t)0, (size_t)0, buf, bkg, dxpl_id) < 0)
            if(H5T_convert(tpath_mem_dst, tid_mem, tid_dst, nelmts, (size_t)0, (size_t)0, buf, bkg, dxpl_id) < 0)
                HGOTO_ERROR(H5E_DATATYPE, H5E_CANTINIT, FAIL, "datatype conversion failed")
​
            /* Reclaim space from variable length data */
            if(H5D_vlen_reclaim(tid_mem, buf_space, H5P_DATASET_XFER_DEFAULT, reclaim_buf) < 0)
                HGOTO_ERROR(H5E_DATASET, H5E_BADITER, FAIL, "unable to reclaim variable-length data")
    } /* end if */
        } /* end if */
        else if(fix_ref) {
            /* Check for expanding references */
            if(cpy_info->expand_ref) {
                size_t ref_count;
​
                /* Determine # of reference elements to copy */
                ref_count = src_nbytes / H5T_get_size(dt_src);
​
                /* Copy the reference elements */
                if(H5O_copy_expand_ref(f_src, buf, dxpl_id, f_dst, bkg, ref_count, H5T_get_ref_type(dt_src), cpy_info) < 0)