2006-04-16 05:11:42 +08:00
|
|
|
|
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
|
|
|
* Copyright by the Board of Trustees of the University of Illinois. *
|
|
|
|
|
* All rights reserved. *
|
|
|
|
|
* *
|
|
|
|
|
* This file is part of HDF5. The full HDF5 copyright notice, including *
|
|
|
|
|
* terms governing use, modification, and redistribution, is contained in *
|
|
|
|
|
* the files COPYING and Copyright.html. COPYING can be found at the root *
|
|
|
|
|
* of the source code distribution tree; Copyright.html can be found at the *
|
|
|
|
|
* root level of an installed copy of the electronic HDF5 document set and *
|
|
|
|
|
* is linked from the top-level documents page. It can also be found at *
|
|
|
|
|
* http://hdf.ncsa.uiuc.edu/HDF5/doc/Copyright.html. If you do not have *
|
|
|
|
|
* access to either file, you may request a copy from hdfhelp@ncsa.uiuc.edu. *
|
|
|
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
*
|
|
|
|
|
* Created: H5HFhdr.c
|
|
|
|
|
* Apr 10 2006
|
|
|
|
|
* Quincey Koziol <koziol@ncsa.uiuc.edu>
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Heap header routines for fractal heaps.
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
/****************/
|
|
|
|
|
/* Module Setup */
|
|
|
|
|
/****************/
|
|
|
|
|
|
|
|
|
|
#define H5HF_PACKAGE /*suppress error about including H5HFpkg */
|
|
|
|
|
|
|
|
|
|
/***********/
|
|
|
|
|
/* Headers */
|
|
|
|
|
/***********/
|
|
|
|
|
#include "H5private.h" /* Generic Functions */
|
|
|
|
|
#include "H5Eprivate.h" /* Error handling */
|
|
|
|
|
#include "H5HFpkg.h" /* Fractal heaps */
|
2006-08-13 12:17:14 +08:00
|
|
|
|
#include "H5MFprivate.h" /* File memory management */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
#include "H5Vprivate.h" /* Vectors and arrays */
|
|
|
|
|
|
|
|
|
|
/****************/
|
|
|
|
|
/* Local Macros */
|
|
|
|
|
/****************/
|
|
|
|
|
|
|
|
|
|
/* Limit on the size of the max. direct block size */
|
|
|
|
|
/* (This is limited to 32-bits currently, because I think it's unlikely to
|
|
|
|
|
* need to be larger, the 32-bit limit for H5V_log2_of2(n), and
|
|
|
|
|
* some offsets/sizes are encoded with a maxiumum of 32-bits - QAK)
|
|
|
|
|
*/
|
2006-05-15 12:35:53 +08:00
|
|
|
|
#define H5HF_MAX_DIRECT_SIZE_LIMIT ((hsize_t)2 * 1024 * 1024 * 1024)
|
|
|
|
|
|
|
|
|
|
/* Limit on the width of the doubling table */
|
|
|
|
|
/* (This is limited to 16-bits currently, because I think it's unlikely to
|
|
|
|
|
* need to be larger, and its encoded with a maxiumum of 16-bits - QAK)
|
|
|
|
|
*/
|
|
|
|
|
#define H5HF_WIDTH_LIMIT (64 * 1024)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/******************/
|
|
|
|
|
/* Local Typedefs */
|
|
|
|
|
/******************/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/********************/
|
|
|
|
|
/* Package Typedefs */
|
|
|
|
|
/********************/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/********************/
|
|
|
|
|
/* Local Prototypes */
|
|
|
|
|
/********************/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*********************/
|
|
|
|
|
/* Package Variables */
|
|
|
|
|
/*********************/
|
|
|
|
|
|
2006-05-15 12:35:53 +08:00
|
|
|
|
/* Declare a free list to manage the H5HF_hdr_t struct */
|
|
|
|
|
H5FL_DEFINE(H5HF_hdr_t);
|
|
|
|
|
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/*****************************/
|
|
|
|
|
/* Library Private Variables */
|
|
|
|
|
/*****************************/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*******************/
|
|
|
|
|
/* Local Variables */
|
|
|
|
|
/*******************/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_alloc
|
|
|
|
|
*
|
2006-06-27 22:45:06 +08:00
|
|
|
|
* Purpose: Allocate shared fractal heap header
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 21 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
2006-04-30 21:32:41 +08:00
|
|
|
|
H5HF_hdr_t *
|
2006-04-16 05:11:42 +08:00
|
|
|
|
H5HF_hdr_alloc(H5F_t *f)
|
|
|
|
|
{
|
2006-04-30 21:32:41 +08:00
|
|
|
|
H5HF_hdr_t *hdr = NULL; /* Shared fractal heap header */
|
|
|
|
|
H5HF_hdr_t *ret_value = NULL; /* Return value */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_alloc)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(f);
|
|
|
|
|
|
|
|
|
|
/* Allocate space for the shared information */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
if(NULL == (hdr = H5FL_CALLOC(H5HF_hdr_t)))
|
2006-04-16 05:11:42 +08:00
|
|
|
|
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, NULL, "memory allocation failed for fractal heap shared header")
|
|
|
|
|
|
|
|
|
|
/* Set the internal parameters for the heap */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
hdr->f = f;
|
|
|
|
|
hdr->sizeof_size = H5F_SIZEOF_SIZE(f);
|
|
|
|
|
hdr->sizeof_addr = H5F_SIZEOF_ADDR(f);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Set the return value */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
ret_value = hdr;
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
if(!ret_value)
|
2006-04-30 21:32:41 +08:00
|
|
|
|
if(hdr)
|
|
|
|
|
(void)H5HF_cache_hdr_dest(f, hdr);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_alloc() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_free_space
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Compute direct block free space, for indirect blocks of
|
|
|
|
|
* different sizes.
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 21 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
2006-07-22 09:55:14 +08:00
|
|
|
|
static herr_t
|
|
|
|
|
H5HF_hdr_compute_free_space(H5HF_hdr_t *hdr, unsigned iblock_row)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
|
|
|
|
hsize_t acc_heap_size; /* Accumumated heap space */
|
2006-07-22 09:55:14 +08:00
|
|
|
|
hsize_t iblock_size; /* Size of indirect block to calculate for */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
hsize_t acc_dblock_free; /* Accumumated direct block free space */
|
2006-07-22 09:55:14 +08:00
|
|
|
|
size_t max_dblock_free; /* Max. direct block free space */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
unsigned curr_row; /* Current row in block */
|
2006-07-22 09:55:14 +08:00
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT_NOFUNC(H5HF_hdr_compute_free_space)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
2006-07-22 09:55:14 +08:00
|
|
|
|
HDassert(iblock_row >= hdr->man_dtable.max_direct_rows);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Set the free space in direct blocks */
|
|
|
|
|
acc_heap_size = 0;
|
|
|
|
|
acc_dblock_free = 0;
|
2006-07-22 09:55:14 +08:00
|
|
|
|
max_dblock_free = 0;
|
|
|
|
|
iblock_size = hdr->man_dtable.row_block_size[iblock_row];
|
2006-04-16 05:11:42 +08:00
|
|
|
|
curr_row = 0;
|
|
|
|
|
while(acc_heap_size < iblock_size) {
|
|
|
|
|
acc_heap_size += hdr->man_dtable.row_block_size[curr_row] *
|
|
|
|
|
hdr->man_dtable.cparam.width;
|
2006-07-22 09:55:14 +08:00
|
|
|
|
acc_dblock_free += hdr->man_dtable.row_tot_dblock_free[curr_row] *
|
2006-04-16 05:11:42 +08:00
|
|
|
|
hdr->man_dtable.cparam.width;
|
2006-07-22 09:55:14 +08:00
|
|
|
|
if(hdr->man_dtable.row_max_dblock_free[curr_row] > max_dblock_free)
|
|
|
|
|
max_dblock_free = hdr->man_dtable.row_max_dblock_free[curr_row];
|
2006-04-16 05:11:42 +08:00
|
|
|
|
curr_row++;
|
|
|
|
|
} /* end while */
|
|
|
|
|
|
2006-07-22 09:55:14 +08:00
|
|
|
|
/* Set direct block free space values for indirect block */
|
|
|
|
|
hdr->man_dtable.row_tot_dblock_free[iblock_row] = acc_dblock_free;
|
|
|
|
|
hdr->man_dtable.row_max_dblock_free[iblock_row] = max_dblock_free;
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_compute_free_space() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
2006-08-14 10:50:11 +08:00
|
|
|
|
* Function: H5HF_hdr_finish_init_phase1
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
2006-08-14 10:50:11 +08:00
|
|
|
|
* Purpose: First phase to finish initializing info in shared heap header
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
2006-08-14 10:50:11 +08:00
|
|
|
|
* koziol@hdfgroup.org
|
|
|
|
|
* Aug 12 2006
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-08-14 10:50:11 +08:00
|
|
|
|
H5HF_hdr_finish_init_phase1(H5HF_hdr_t *hdr)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
2006-08-14 10:50:11 +08:00
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_finish_init_phase1)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
|
|
|
|
/* Compute/cache some values */
|
|
|
|
|
hdr->heap_off_size = H5HF_SIZEOF_OFFSET_BITS(hdr->man_dtable.cparam.max_index);
|
|
|
|
|
if(H5HF_dtable_init(&hdr->man_dtable) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't initialize doubling table info")
|
|
|
|
|
|
|
|
|
|
/* Set the size of heap IDs */
|
2006-05-23 00:43:45 +08:00
|
|
|
|
hdr->heap_len_size = MIN(hdr->man_dtable.max_dir_blk_off_size,
|
2006-08-08 03:51:59 +08:00
|
|
|
|
((H5V_log2_gen((hsize_t)hdr->max_man_size) + 7) / 8));
|
2006-08-14 10:50:11 +08:00
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_finish_init_phase1() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_finish_init_pahse2
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Second phase to finish initializing info in shared heap header
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@hdfgroup.org
|
|
|
|
|
* Aug 12 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_finish_init_phase2(H5HF_hdr_t *hdr)
|
|
|
|
|
{
|
|
|
|
|
unsigned u; /* Local index variable */
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_finish_init_phase2)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Set the free space in direct blocks */
|
|
|
|
|
for(u = 0; u < hdr->man_dtable.max_root_rows; u++) {
|
2006-07-22 09:55:14 +08:00
|
|
|
|
if(u < hdr->man_dtable.max_direct_rows) {
|
|
|
|
|
hdr->man_dtable.row_tot_dblock_free[u] = hdr->man_dtable.row_block_size[u] -
|
2006-05-15 12:35:53 +08:00
|
|
|
|
H5HF_MAN_ABS_DIRECT_OVERHEAD(hdr);
|
2006-07-22 09:55:14 +08:00
|
|
|
|
hdr->man_dtable.row_max_dblock_free[u] = hdr->man_dtable.row_tot_dblock_free[u];
|
|
|
|
|
} /* end if */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
else
|
2006-07-22 09:55:14 +08:00
|
|
|
|
if(H5HF_hdr_compute_free_space(hdr, u) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't initialize direct block free space for indirect block")
|
2006-04-16 05:11:42 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: row_block_size[%Zu] = %Hu\n", FUNC, u, hdr->man_dtable.row_block_size[u]);
|
|
|
|
|
HDfprintf(stderr, "%s: row_block_off[%Zu] = %Hu\n", FUNC, u, hdr->man_dtable.row_block_off[u]);
|
2006-07-22 09:55:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: row_tot_dblock_free[%Zu] = %Hu\n", FUNC, u, hdr->man_dtable.row_tot_dblock_free[u]);
|
|
|
|
|
HDfprintf(stderr, "%s: row_max_dblock_free[%Zu] = %Zu\n", FUNC, u, hdr->man_dtable.row_max_dblock_free[u]);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
#endif /* QAK */
|
|
|
|
|
} /* end for */
|
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
/* Initialize the block iterator for searching for free space */
|
|
|
|
|
if(H5HF_man_iter_init(&hdr->next_block) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't initialize space search block iterator")
|
|
|
|
|
|
2006-08-10 11:45:06 +08:00
|
|
|
|
/* Initialize the information for tracking 'huge' objects */
|
|
|
|
|
if(H5HF_huge_init(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't informan for tracking huge objects")
|
|
|
|
|
|
2006-08-14 10:50:11 +08:00
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_finish_init_phase2() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_finish_init
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Finish initializing info in shared heap header
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 21 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_finish_init(H5HF_hdr_t *hdr)
|
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_finish_init)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
|
|
|
|
/* First phase of header final initialization */
|
|
|
|
|
if(H5HF_hdr_finish_init_phase1(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't finish phase #1 of header final initialization")
|
|
|
|
|
|
|
|
|
|
/* Second phase of header final initialization */
|
|
|
|
|
if(H5HF_hdr_finish_init_phase2(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't finish phase #2 of header final initialization")
|
|
|
|
|
|
2006-04-16 05:11:42 +08:00
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_finish_init() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
2006-08-13 12:17:14 +08:00
|
|
|
|
* Function: H5HF_hdr_create
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
2006-08-13 12:17:14 +08:00
|
|
|
|
* Purpose: Create new fractal heap header
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 21 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
2006-08-13 12:17:14 +08:00
|
|
|
|
haddr_t
|
|
|
|
|
H5HF_hdr_create(H5F_t *f, hid_t dxpl_id, const H5HF_create_t *cparam)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
2006-08-13 12:17:14 +08:00
|
|
|
|
H5HF_hdr_t *hdr = NULL; /* The new fractal heap header information */
|
|
|
|
|
haddr_t hdr_addr; /* Heap header address */
|
|
|
|
|
size_t dblock_overhead; /* Direct block's overhead */
|
|
|
|
|
haddr_t ret_value; /* Return value */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-08-13 12:17:14 +08:00
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_create)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HDassert(f);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
HDassert(cparam);
|
|
|
|
|
|
|
|
|
|
#ifndef NDEBUG
|
|
|
|
|
/* Check for valid parameters */
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.width == 0)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "width must be greater than zero")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.width > H5HF_WIDTH_LIMIT)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "width too large")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(!POWER_OF_TWO(cparam->managed.width))
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "width not power of two")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.start_block_size == 0)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "starting block size must be greater than zero")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(!POWER_OF_TWO(cparam->managed.start_block_size))
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "starting block size not power of two")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.max_direct_size == 0)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. direct block size must be greater than zero")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.max_direct_size > H5HF_MAX_DIRECT_SIZE_LIMIT)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. direct block size too large")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(!POWER_OF_TWO(cparam->managed.max_direct_size))
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. direct block size not power of two")
|
2006-08-08 03:51:59 +08:00
|
|
|
|
if(cparam->managed.max_direct_size < cparam->max_man_size)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. direct block size not large enough to hold all managed blocks")
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.max_index == 0)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. heap size must be greater than zero")
|
|
|
|
|
#endif /* NDEBUG */
|
|
|
|
|
|
|
|
|
|
/* Allocate & basic initialization for the shared header */
|
|
|
|
|
if(NULL == (hdr = H5HF_hdr_alloc(f)))
|
|
|
|
|
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, HADDR_UNDEF, "can't allocate space for shared heap info")
|
|
|
|
|
|
|
|
|
|
#ifndef NDEBUG
|
2006-05-15 12:35:53 +08:00
|
|
|
|
if(cparam->managed.max_index > (8 * hdr->sizeof_size))
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. heap size too large for file")
|
2006-04-16 05:11:42 +08:00
|
|
|
|
#endif /* NDEBUG */
|
|
|
|
|
|
2006-08-13 12:17:14 +08:00
|
|
|
|
/* Allocate space for the header on disk */
|
|
|
|
|
if(HADDR_UNDEF == (hdr_addr = H5MF_alloc(f, H5FD_MEM_FHEAP_HDR, dxpl_id, (hsize_t)H5HF_HEADER_SIZE(hdr))))
|
|
|
|
|
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, HADDR_UNDEF, "file allocation failed for fractal heap header")
|
|
|
|
|
|
2006-04-16 05:11:42 +08:00
|
|
|
|
/* Set the creation parameters for the heap */
|
2006-08-13 12:17:14 +08:00
|
|
|
|
hdr->heap_addr = hdr_addr;
|
2006-08-08 03:51:59 +08:00
|
|
|
|
hdr->max_man_size = cparam->max_man_size;
|
2006-04-30 21:32:41 +08:00
|
|
|
|
HDmemcpy(&(hdr->man_dtable.cparam), &(cparam->managed), sizeof(H5HF_dtable_cparam_t));
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-05-15 12:35:53 +08:00
|
|
|
|
/* Set root table address to indicate that the heap is empty currently */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
hdr->man_dtable.table_addr = HADDR_UNDEF;
|
|
|
|
|
|
2006-05-15 12:35:53 +08:00
|
|
|
|
/* Set free list header address to indicate that the heap is empty currently */
|
|
|
|
|
hdr->fs_addr = HADDR_UNDEF;
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-08-10 11:45:06 +08:00
|
|
|
|
/* Set "huge" object tracker v2 B-tree address to indicate that there aren't any yet */
|
|
|
|
|
hdr->huge_bt2_addr = HADDR_UNDEF;
|
2006-08-08 03:51:59 +08:00
|
|
|
|
|
2006-04-16 05:11:42 +08:00
|
|
|
|
/* Note that the shared info is dirty (it's not written to the file yet) */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
hdr->dirty = TRUE;
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-08-14 10:50:11 +08:00
|
|
|
|
/* First phase of header final initialization */
|
|
|
|
|
if(H5HF_hdr_finish_init_phase1(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, HADDR_UNDEF, "can't finish phase #1 of header final initialization")
|
|
|
|
|
|
|
|
|
|
/* Set the length of IDs in the heap */
|
|
|
|
|
/* (This code is not in the "finish init phase" routines because those
|
|
|
|
|
* routines are also called from the cache 'load' callback, and the ID
|
|
|
|
|
* length is already set in that case (its stored in the header on disk))
|
|
|
|
|
*/
|
|
|
|
|
switch(cparam->id_len) {
|
|
|
|
|
case 0: /* Set the length of heap IDs to just enough to hold the offset & length of 'normal' objects in the heap */
|
|
|
|
|
hdr->id_len = 1 + hdr->heap_off_size + hdr->heap_len_size;
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
case 1: /* Set the length of heap IDs to just enough to hold the file offset & length of 'huge' objects in the heap */
|
|
|
|
|
hdr->id_len = 1 + hdr->sizeof_size + hdr->sizeof_addr;
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
default: /* Use the requested size for the heap ID */
|
|
|
|
|
/* XXX: Limit heap ID length to 4096 + 1, due to # of bits required to store
|
|
|
|
|
* length of 'tiny' objects (12 bits)
|
|
|
|
|
*/
|
|
|
|
|
HDfprintf(stderr, "%s: Varying size of heap IDs not supported yet!\n", FUNC);
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_UNSUPPORTED, HADDR_UNDEF, "varying size of heap IDs not supported yet")
|
|
|
|
|
break;
|
|
|
|
|
} /* end switch */
|
|
|
|
|
|
|
|
|
|
/* Second phase of header final initialization */
|
|
|
|
|
if(H5HF_hdr_finish_init_phase2(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, HADDR_UNDEF, "can't finish phase #2 of header final initialization")
|
2006-08-13 12:17:14 +08:00
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->id_len = %Zu\n", FUNC, hdr->id_len);
|
|
|
|
|
#endif /* QAK */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-07-31 17:54:09 +08:00
|
|
|
|
/* Extra checking for possible gap between max. direct block size minus
|
2006-08-08 03:51:59 +08:00
|
|
|
|
* overhead and "huge" object size */
|
2006-07-31 17:54:09 +08:00
|
|
|
|
dblock_overhead = H5HF_MAN_ABS_DIRECT_OVERHEAD(hdr);
|
2006-08-08 03:51:59 +08:00
|
|
|
|
if((cparam->managed.max_direct_size - dblock_overhead) < cparam->max_man_size)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_BADVALUE, HADDR_UNDEF, "max. direct block size not large enough to hold all managed blocks")
|
|
|
|
|
|
|
|
|
|
/* Cache the new fractal heap header */
|
|
|
|
|
if(H5AC_set(f, dxpl_id, H5AC_FHEAP_HDR, hdr_addr, hdr, H5AC__NO_FLAGS_SET) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, HADDR_UNDEF, "can't add fractal heap header to cache")
|
|
|
|
|
|
|
|
|
|
/* Set address of heap header to return */
|
|
|
|
|
ret_value = hdr_addr;
|
2006-07-31 17:54:09 +08:00
|
|
|
|
|
2006-04-16 05:11:42 +08:00
|
|
|
|
done:
|
2006-08-13 12:17:14 +08:00
|
|
|
|
if(!H5F_addr_defined(ret_value))
|
2006-04-30 21:32:41 +08:00
|
|
|
|
if(hdr)
|
|
|
|
|
(void)H5HF_cache_hdr_dest(NULL, hdr);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
2006-08-13 12:17:14 +08:00
|
|
|
|
} /* end H5HF_hdr_create() */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_incr
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Increment reference count on shared heap header
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 27 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-04-30 21:32:41 +08:00
|
|
|
|
H5HF_hdr_incr(H5HF_hdr_t *hdr)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
2006-04-30 21:32:41 +08:00
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_incr)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Sanity check */
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
/* Mark header as un-evictable when a block is depending on it */
|
|
|
|
|
if(hdr->rc == 0)
|
|
|
|
|
if(H5AC_pin_protected_entry(hdr->f, hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTPIN, FAIL, "unable to pin fractal heap header")
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Increment reference count on shared header */
|
|
|
|
|
hdr->rc++;
|
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
} /* end H5HF_hdr_incr() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_decr
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Decrement reference count on shared heap header
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 27 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-04-30 21:32:41 +08:00
|
|
|
|
H5HF_hdr_decr(H5HF_hdr_t *hdr)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
2006-04-30 21:32:41 +08:00
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_decr)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Sanity check */
|
|
|
|
|
HDassert(hdr);
|
2006-05-23 09:24:26 +08:00
|
|
|
|
HDassert(hdr->rc);
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Decrement reference count on shared header */
|
|
|
|
|
hdr->rc--;
|
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
/* Mark header as evictable again when no child blocks depend on it */
|
|
|
|
|
if(hdr->rc == 0)
|
|
|
|
|
if(H5AC_unpin_entry(hdr->f, hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTUNPIN, FAIL, "unable to unpin fractal heap header")
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
} /* end H5HF_hdr_decr() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_dirty
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Mark heap header as dirty
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 27 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-04-30 21:32:41 +08:00
|
|
|
|
H5HF_hdr_dirty(H5HF_hdr_t *hdr)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_dirty)
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Marking heap header as dirty\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Sanity check */
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
/* Mark header as dirty in cache */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
if(H5AC_mark_pinned_or_protected_entry_dirty(hdr->f, hdr) < 0)
|
2006-04-30 21:32:41 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTMARKDIRTY, FAIL, "unable to mark fractal heap header as dirty")
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/* Set the dirty flags for the heap header */
|
|
|
|
|
hdr->dirty = TRUE;
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_dirty() */
|
|
|
|
|
|
2006-05-15 12:35:53 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_adj_free
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Adjust the free space for a heap
|
|
|
|
|
*
|
|
|
|
|
* Return: SUCCEED/FAIL
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* May 9 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_adj_free(H5HF_hdr_t *hdr, ssize_t amt)
|
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_adj_free)
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: amt = %Zd\n", FUNC, amt);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
|
|
|
|
/* Update heap header */
|
|
|
|
|
HDassert(amt > 0 || hdr->total_man_free >= (hsize_t)-amt);
|
|
|
|
|
hdr->total_man_free += amt;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->total_man_free = %Hu\n", FUNC, hdr->total_man_free);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Mark heap header as modified */
|
|
|
|
|
if(H5HF_hdr_dirty(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTDIRTY, FAIL, "can't mark heap header as dirty")
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_adj_free() */
|
|
|
|
|
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
2006-06-19 18:06:10 +08:00
|
|
|
|
* Function: H5HF_hdr_adjust_heap
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
2006-06-19 18:06:10 +08:00
|
|
|
|
* Purpose: Adjust heap space
|
2006-04-16 05:11:42 +08:00
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Apr 10 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-06-19 18:06:10 +08:00
|
|
|
|
H5HF_hdr_adjust_heap(H5HF_hdr_t *hdr, hsize_t new_size, hssize_t extra_free)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
{
|
2006-06-19 18:06:10 +08:00
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_adjust_heap)
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
2006-07-31 17:54:09 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s; new_size = %Hu, extra_free = %Hd\n", FUNC, new_size, extra_free);
|
|
|
|
|
HDfprintf(stderr, "%s; hdr->total_size = %Hu\n", FUNC, hdr->total_size);
|
|
|
|
|
HDfprintf(stderr, "%s; hdr->man_size = %Hu\n", FUNC, hdr->man_size);
|
|
|
|
|
HDfprintf(stderr, "%s; hdr->total_man_free = %Hu\n", FUNC, hdr->total_man_free);
|
|
|
|
|
#endif /* QAK */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-08-08 05:24:29 +08:00
|
|
|
|
/* Set the total managed space in heap */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
hdr->man_size = new_size;
|
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
/* Adjust the free space in direct blocks */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
hdr->total_man_free += extra_free;
|
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
/* Mark heap header as modified */
|
|
|
|
|
if(H5HF_hdr_dirty(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTDIRTY, FAIL, "can't mark header as dirty")
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_adjust_heap() */
|
2006-04-16 05:11:42 +08:00
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_inc_alloc
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Increase allocated size of heap
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
2006-06-19 18:06:10 +08:00
|
|
|
|
* May 23 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_inc_alloc(H5HF_hdr_t *hdr, size_t alloc_size)
|
|
|
|
|
{
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT_NOFUNC(H5HF_hdr_inc_alloc)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
HDassert(alloc_size);
|
|
|
|
|
|
|
|
|
|
/* Update the "allocated" size within the heap */
|
|
|
|
|
hdr->man_alloc_size += alloc_size;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->man_alloc_size = %Hu\n", "H5HF_hdr_inc_alloc", hdr->man_alloc_size);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
FUNC_LEAVE_NOAPI(SUCCEED)
|
|
|
|
|
} /* end H5HF_hdr_inc_alloc() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_start_iter
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Start "next block" iterator at an offset/entry in the heap
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* May 30 2006
|
2006-04-30 21:32:41 +08:00
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-06-19 18:06:10 +08:00
|
|
|
|
H5HF_hdr_start_iter(H5HF_hdr_t *hdr, H5HF_indirect_t *iblock, hsize_t curr_off, unsigned curr_entry)
|
2006-04-30 21:32:41 +08:00
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_start_iter)
|
2006-04-30 21:32:41 +08:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HDassert(iblock);
|
|
|
|
|
|
|
|
|
|
/* Set up "next block" iterator at correct location */
|
|
|
|
|
if(H5HF_man_iter_start_entry(hdr, &hdr->next_block, iblock, curr_entry) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't initialize block iterator")
|
|
|
|
|
|
|
|
|
|
/* Set the offset of the iterator in the heap */
|
|
|
|
|
hdr->man_iter_off = curr_off;
|
2006-04-30 21:32:41 +08:00
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_start_iter() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_reset_iter
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Reset "next block" iterator
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* May 31 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_reset_iter(H5HF_hdr_t *hdr, hsize_t curr_off)
|
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_reset_iter)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
|
|
|
|
/* Reset "next block" iterator */
|
|
|
|
|
if(H5HF_man_iter_reset(&hdr->next_block) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTRELEASE, FAIL, "can't reset block iterator")
|
|
|
|
|
|
|
|
|
|
/* Set the offset of the iterator in the heap */
|
2006-07-31 17:54:09 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->man_iter_off = %Hu, curr_off = %Hu\n", FUNC, hdr->man_iter_off, curr_off);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
hdr->man_iter_off = curr_off;
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_reset_iter() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_skip_blocks
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Add skipped direct blocks to free space for heap
|
|
|
|
|
*
|
|
|
|
|
* Return: SUCCEED/FAIL
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Apr 3 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_skip_blocks(H5HF_hdr_t *hdr, hid_t dxpl_id, H5HF_indirect_t *iblock,
|
|
|
|
|
unsigned start_entry, unsigned nentries)
|
|
|
|
|
{
|
2006-07-31 17:54:09 +08:00
|
|
|
|
unsigned row, col; /* Row & column of entry */
|
|
|
|
|
hsize_t sect_size; /* Size of section in heap space */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_skip_blocks)
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: start_entry = %u, nentries = %u\n", FUNC, start_entry, nentries);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
HDassert(iblock);
|
|
|
|
|
HDassert(nentries);
|
|
|
|
|
|
2006-07-31 17:54:09 +08:00
|
|
|
|
/* Compute the span within the heap to skip */
|
|
|
|
|
row = start_entry / hdr->man_dtable.cparam.width;
|
|
|
|
|
col = start_entry % hdr->man_dtable.cparam.width;
|
|
|
|
|
sect_size = H5HF_dtable_span_size(&hdr->man_dtable, row, col, nentries);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#ifdef QAK
|
2006-07-31 17:54:09 +08:00
|
|
|
|
HDfprintf(stderr, "%s: Check 1.0 - hdr->man_iter_off = %Hu, sect_size = %Hu\n", FUNC, hdr->man_iter_off, sect_size);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#endif /* QAK */
|
2006-07-31 17:54:09 +08:00
|
|
|
|
HDassert(sect_size > 0);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
|
|
|
|
/* Advance the new block iterator */
|
2006-07-31 17:54:09 +08:00
|
|
|
|
if(H5HF_hdr_inc_iter(hdr, sect_size, nentries) < 0)
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTRELEASE, FAIL, "can't increase allocated heap size")
|
2006-07-31 17:54:09 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Check 2.0 - hdr->man_iter_off = %Hu\n", FUNC, hdr->man_iter_off);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Add 'indirect' section for blocks skipped in this row */
|
|
|
|
|
if(H5HF_sect_indirect_add(hdr, dxpl_id, iblock, start_entry, nentries) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "can't create indirect section for indirect block's free space")
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_skip_blocks() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_update_iter
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Update state of heap to account for current iterator
|
|
|
|
|
* position.
|
|
|
|
|
*
|
|
|
|
|
* Note: Creates necessary indirect blocks
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* Mar 14 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_update_iter(H5HF_hdr_t *hdr, hid_t dxpl_id, size_t min_dblock_size)
|
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_update_iter)
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: min_dblock_size = %Zu\n", FUNC, min_dblock_size);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
HDassert(min_dblock_size > 0);
|
|
|
|
|
|
|
|
|
|
/* Check for creating first indirect block */
|
|
|
|
|
if(hdr->man_dtable.curr_root_rows == 0) {
|
2006-07-01 21:58:14 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Creating root direct block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
if(H5HF_man_iblock_root_create(hdr, dxpl_id, min_dblock_size) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTEXTEND, FAIL, "unable to create root indirect block")
|
|
|
|
|
} /* end if */
|
|
|
|
|
else {
|
|
|
|
|
H5HF_indirect_t *iblock; /* Pointer to indirect block */
|
|
|
|
|
hbool_t walked_up, walked_down; /* Condition variables for finding direct block location */
|
|
|
|
|
unsigned next_row; /* Iterator's next block row */
|
|
|
|
|
unsigned next_entry; /* Iterator's next block entry */
|
|
|
|
|
unsigned min_dblock_row; /* Minimum row for direct block size request */
|
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: searching root indirect block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Compute min. row for direct block requested */
|
|
|
|
|
min_dblock_row = H5HF_dtable_size_to_row(&hdr->man_dtable, min_dblock_size);
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: min_dblock_size = %Zu, min_dblock_row = %u\n", FUNC, min_dblock_size, min_dblock_row);
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: hdr->man_iter_off = %Hu\n", FUNC, hdr->man_iter_off);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Initialize block iterator, if necessary */
|
|
|
|
|
if(!H5HF_man_iter_ready(&hdr->next_block)) {
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->man_iter_off = %Hu\n", FUNC, hdr->man_iter_off);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Start iterator with previous offset of iterator */
|
|
|
|
|
if(H5HF_man_iter_start_offset(hdr, dxpl_id, &hdr->next_block, hdr->man_iter_off) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "unable to set block iterator location")
|
|
|
|
|
} /* end if */
|
|
|
|
|
|
|
|
|
|
/* Get information about current iterator location */
|
|
|
|
|
if(H5HF_man_iter_curr(&hdr->next_block, &next_row, NULL, &next_entry, &iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTGET, FAIL, "unable to retrieve current block iterator location")
|
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Check 1.0\n", FUNC);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock = %p\n", FUNC, iblock);
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: iblock->block_off = %Hu\n", FUNC, iblock->block_off);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HDfprintf(stderr, "%s: iblock->nrows = %u\n", FUNC, iblock->nrows);
|
|
|
|
|
HDfprintf(stderr, "%s: next_row = %u\n", FUNC, next_row);
|
|
|
|
|
HDfprintf(stderr, "%s: next_entry = %u\n", FUNC, next_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Check for skipping over blocks in the current block */
|
|
|
|
|
if(min_dblock_row > next_row && next_row < iblock->nrows) {
|
|
|
|
|
unsigned min_entry; /* Min entry for direct block requested */
|
|
|
|
|
unsigned skip_entries; /* Number of entries to skip in the current block */
|
|
|
|
|
|
|
|
|
|
/* Compute the number of entries to skip in the current block */
|
|
|
|
|
min_entry = min_dblock_row * hdr->man_dtable.cparam.width;
|
|
|
|
|
if(min_dblock_row >= iblock->nrows)
|
|
|
|
|
skip_entries = (iblock->nrows * hdr->man_dtable.cparam.width) - next_entry;
|
|
|
|
|
else
|
|
|
|
|
skip_entries = min_entry - next_entry;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: min_entry = %u, skip_entries = %u\n", FUNC, min_entry, skip_entries);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Add skipped direct blocks to heap's free space */
|
|
|
|
|
if(H5HF_hdr_skip_blocks(hdr, dxpl_id, iblock, next_entry, skip_entries) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTDEC, FAIL, "can't add skipped blocks to heap's free space")
|
|
|
|
|
|
|
|
|
|
/* Get information about new iterator location */
|
|
|
|
|
if(H5HF_man_iter_curr(&hdr->next_block, &next_row, NULL, &next_entry, &iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTGET, FAIL, "unable to retrieve current block iterator location")
|
|
|
|
|
} /* end if */
|
|
|
|
|
|
|
|
|
|
do {
|
|
|
|
|
/* Reset conditions for leaving loop */
|
|
|
|
|
walked_up = walked_down = FALSE;
|
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Check 2.0\n", FUNC);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock = %p\n", FUNC, iblock);
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: iblock->block_off = %Hu\n", FUNC, iblock->block_off);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HDfprintf(stderr, "%s: iblock->nrows = %u\n", FUNC, iblock->nrows);
|
|
|
|
|
HDfprintf(stderr, "%s: next_row = %u\n", FUNC, next_row);
|
|
|
|
|
HDfprintf(stderr, "%s: next_entry = %u\n", FUNC, next_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Check for walking off end of indirect block */
|
|
|
|
|
/* (walk up iterator) */
|
|
|
|
|
while(next_row >= iblock->nrows) {
|
|
|
|
|
#ifdef QAK
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: Off the end of a block, next_row = %u, iblock->nrows = %u\n", FUNC, next_row, iblock->nrows);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Check for needing to expand root indirect block */
|
|
|
|
|
if(iblock->parent == NULL) {
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Doubling root block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
if(H5HF_man_iblock_root_double(hdr, dxpl_id, min_dblock_size) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTEXTEND, FAIL, "unable to double root indirect block")
|
|
|
|
|
} /* end if */
|
|
|
|
|
else {
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Walking up a level\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Move iterator up one level */
|
|
|
|
|
if(H5HF_man_iter_up(&hdr->next_block) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTNEXT, FAIL, "unable to advance current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Increment location of next block at this level */
|
|
|
|
|
if(H5HF_man_iter_next(hdr, &hdr->next_block, 1) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINC, FAIL, "can't advance fractal heap block location")
|
|
|
|
|
} /* end else */
|
|
|
|
|
|
|
|
|
|
/* Get information about new iterator location */
|
|
|
|
|
if(H5HF_man_iter_curr(&hdr->next_block, &next_row, NULL, &next_entry, &iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTGET, FAIL, "unable to retrieve current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Indicate that we walked up */
|
|
|
|
|
walked_up = TRUE;
|
|
|
|
|
} /* end while */
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Check 3.0\n", FUNC);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock = %p\n", FUNC, iblock);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock->nrows = %u\n", FUNC, iblock->nrows);
|
|
|
|
|
HDfprintf(stderr, "%s: next_row = %u\n", FUNC, next_row);
|
|
|
|
|
HDfprintf(stderr, "%s: next_entry = %u\n", FUNC, next_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Check for walking into child indirect block */
|
|
|
|
|
/* (walk down iterator) */
|
|
|
|
|
if(next_row >= hdr->man_dtable.max_direct_rows) {
|
|
|
|
|
unsigned child_nrows; /* Number of rows in new indirect block */
|
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Walking down into child indirect block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Check 3.1\n", FUNC);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock = %p\n", FUNC, iblock);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock->nrows = %u\n", FUNC, iblock->nrows);
|
|
|
|
|
HDfprintf(stderr, "%s: next_row = %u\n", FUNC, next_row);
|
|
|
|
|
HDfprintf(stderr, "%s: next_entry = %u\n", FUNC, next_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
HDassert(!H5F_addr_defined(iblock->ents[next_entry].addr));
|
|
|
|
|
|
|
|
|
|
/* Compute # of rows in next child indirect block to use */
|
|
|
|
|
child_nrows = H5HF_dtable_size_to_rows(&hdr->man_dtable, hdr->man_dtable.row_block_size[next_row]);
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: child_nrows = %u\n", FUNC, child_nrows);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Check for skipping over indirect blocks */
|
|
|
|
|
/* (that don't have direct blocks large enough to hold direct block size requested) */
|
|
|
|
|
if(hdr->man_dtable.row_block_size[child_nrows - 1] < min_dblock_size) {
|
|
|
|
|
unsigned child_rows_needed; /* Number of rows needed to hold direct block */
|
|
|
|
|
unsigned child_entry; /* Entry of child indirect block */
|
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Skipping indirect block row that is too small\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Compute # of rows needed in child indirect block */
|
2006-08-08 05:24:29 +08:00
|
|
|
|
child_rows_needed = (H5V_log2_of2((uint32_t)min_dblock_size) - H5V_log2_of2((uint32_t)hdr->man_dtable.cparam.start_block_size)) + 2;
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HDassert(child_rows_needed > child_nrows);
|
|
|
|
|
child_entry = (next_row + (child_rows_needed - child_nrows)) * hdr->man_dtable.cparam.width;
|
|
|
|
|
if(child_entry > (iblock->nrows * hdr->man_dtable.cparam.width))
|
|
|
|
|
child_entry = iblock->nrows * hdr->man_dtable.cparam.width;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: child_rows_needed = %u\n", FUNC, child_rows_needed);
|
|
|
|
|
HDfprintf(stderr, "%s: child_entry = %u\n", FUNC, child_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
2006-07-22 09:55:14 +08:00
|
|
|
|
/* Add skipped indirect blocks to heap's free space */
|
|
|
|
|
if(H5HF_hdr_skip_blocks(hdr, dxpl_id, iblock, next_entry, (child_entry - next_entry)) < 0)
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTDEC, FAIL, "can't add skipped blocks to heap's free space")
|
|
|
|
|
} /* end if */
|
|
|
|
|
else {
|
|
|
|
|
H5HF_indirect_t *new_iblock; /* Pointer to new indirect block */
|
|
|
|
|
haddr_t new_iblock_addr; /* New indirect block's address */
|
|
|
|
|
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Allocating new child indirect block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Allocate new indirect block */
|
|
|
|
|
if(H5HF_man_iblock_create(hdr, dxpl_id, iblock, next_entry, child_nrows, child_nrows, &new_iblock_addr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTALLOC, FAIL, "can't allocate fractal heap indirect block")
|
|
|
|
|
|
|
|
|
|
/* Lock new indirect block */
|
|
|
|
|
if(NULL == (new_iblock = H5HF_man_iblock_protect(hdr, dxpl_id, new_iblock_addr, child_nrows, iblock, next_entry, H5AC_WRITE)))
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTPROTECT, FAIL, "unable to protect fractal heap indirect block")
|
|
|
|
|
|
|
|
|
|
/* Move iterator down one level */
|
|
|
|
|
if(H5HF_man_iter_down(&hdr->next_block, new_iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTNEXT, FAIL, "unable to advance current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Check for skipping over rows and add free section for skipped rows */
|
|
|
|
|
if(min_dblock_size > hdr->man_dtable.cparam.start_block_size) {
|
|
|
|
|
unsigned new_entry; /* Entry of direct block which is large enough */
|
|
|
|
|
|
|
|
|
|
/* Compute entry for direct block size requested */
|
|
|
|
|
new_entry = hdr->man_dtable.cparam.width * min_dblock_row;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Skipping rows in new child indirect block - new_entry = %u\n", FUNC, new_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Add skipped blocks to heap's free space */
|
|
|
|
|
if(H5HF_hdr_skip_blocks(hdr, dxpl_id, new_iblock, 0, new_entry) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTDEC, FAIL, "can't add skipped blocks to heap's free space")
|
|
|
|
|
} /* end if */
|
|
|
|
|
|
|
|
|
|
/* Unprotect child indirect block */
|
|
|
|
|
if(H5AC_unprotect(hdr->f, dxpl_id, H5AC_FHEAP_IBLOCK, new_iblock->addr, new_iblock, H5AC__NO_FLAGS_SET) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTUNPROTECT, FAIL, "unable to release fractal heap indirect block")
|
|
|
|
|
} /* end else */
|
|
|
|
|
|
|
|
|
|
/* Get information about new iterator location */
|
|
|
|
|
if(H5HF_man_iter_curr(&hdr->next_block, &next_row, NULL, &next_entry, &iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTGET, FAIL, "unable to retrieve current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Indicate that we walked down */
|
|
|
|
|
walked_down = TRUE;
|
|
|
|
|
} /* end if */
|
|
|
|
|
} while(walked_down || walked_up);
|
|
|
|
|
} /* end else */
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_update_iter() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_inc_iter
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Advance "next block" iterator
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* May 23 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_inc_iter(H5HF_hdr_t *hdr, hsize_t adv_size, unsigned nentries)
|
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_inc_iter)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
HDassert(nentries);
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->man_iter_off = %Hu, adv_size = %Hu\n", FUNC, hdr->man_iter_off, adv_size);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Advance the iterator for the current location within the indirect block */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
if(hdr->next_block.curr)
|
|
|
|
|
if(H5HF_man_iter_next(hdr, &hdr->next_block, nentries) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTNEXT, FAIL, "unable to advance current block iterator location")
|
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
/* Increment the offset of the iterator in the heap */
|
|
|
|
|
hdr->man_iter_off += adv_size;
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_inc_iter() */
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_reverse_iter
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Walk "next block" iterator backwards until the correct
|
|
|
|
|
* location to allocate next block from is found
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* May 31 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
2006-07-01 21:58:14 +08:00
|
|
|
|
H5HF_hdr_reverse_iter(H5HF_hdr_t *hdr, hid_t dxpl_id, haddr_t dblock_addr)
|
2006-06-19 18:06:10 +08:00
|
|
|
|
{
|
|
|
|
|
H5HF_indirect_t *iblock; /* Indirect block where iterator is located */
|
2006-07-01 21:58:14 +08:00
|
|
|
|
unsigned curr_entry; /* Current entry for iterator */
|
|
|
|
|
hbool_t walked_down; /* Loop flag */
|
|
|
|
|
hbool_t walked_up; /* Loop flag */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_reverse_iter)
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check arguments.
|
|
|
|
|
*/
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
|
|
|
|
/* Initialize block iterator, if necessary */
|
|
|
|
|
if(!H5HF_man_iter_ready(&hdr->next_block))
|
|
|
|
|
/* Start iterator with previous offset of iterator */
|
|
|
|
|
if(H5HF_man_iter_start_offset(hdr, dxpl_id, &hdr->next_block, hdr->man_iter_off) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTINIT, FAIL, "unable to set block iterator location")
|
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Walk backwards through heap, looking for direct block to place iterator after */
|
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
/* Get information about current iterator location */
|
2006-07-01 21:58:14 +08:00
|
|
|
|
if(H5HF_man_iter_curr(&hdr->next_block, NULL, NULL, &curr_entry, &iblock) < 0)
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTGET, FAIL, "unable to retrieve current block iterator information")
|
2006-04-30 21:32:41 +08:00
|
|
|
|
#ifdef QAK
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HDfprintf(stderr, "%s: iblock->nchildren = %u\n", FUNC, iblock->nchildren);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock->parent = %p\n", FUNC, iblock->parent);
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: curr_entry = %u\n", FUNC, curr_entry);
|
2006-04-30 21:32:41 +08:00
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Move current iterator position backwards once */
|
|
|
|
|
curr_entry--;
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Search backwards in the heap address space for direct block to latch onto */
|
|
|
|
|
do {
|
|
|
|
|
int tmp_entry; /* Temp. entry for iterator (use signed value to detect errors) */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Reset loop flags */
|
|
|
|
|
walked_down = FALSE;
|
|
|
|
|
walked_up = FALSE;
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Walk backwards through entries, until we find one that has a child */
|
|
|
|
|
/* (Skip direct block that will be deleted, if we find it) */
|
|
|
|
|
tmp_entry = curr_entry;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: tmp_entry = %d\n", FUNC, tmp_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
while(tmp_entry >= 0 &&
|
|
|
|
|
(H5F_addr_eq(iblock->ents[tmp_entry].addr, dblock_addr) ||
|
|
|
|
|
!H5F_addr_defined(iblock->ents[tmp_entry].addr)))
|
|
|
|
|
tmp_entry--;
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: check 2.0 - tmp_entry = %d\n", FUNC, tmp_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Check for no earlier blocks in this indirect block */
|
|
|
|
|
if(tmp_entry < 0) {
|
|
|
|
|
/* Check for parent of current indirect block */
|
|
|
|
|
if(iblock->parent) {
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Walking up a block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
/* Move iterator to parent of current block */
|
|
|
|
|
if(H5HF_man_iter_up(&hdr->next_block) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTNEXT, FAIL, "unable to move current block iterator location up")
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Get information about current iterator location */
|
|
|
|
|
if(H5HF_man_iter_curr(&hdr->next_block, NULL, NULL, &curr_entry, &iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTGET, FAIL, "unable to retrieve current block iterator information")
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#ifdef QAK
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: iblock->nchildren = %u\n", FUNC, iblock->nchildren);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock->parent = %p\n", FUNC, iblock->parent);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
HDfprintf(stderr, "%s: curr_entry = %u\n", FUNC, curr_entry);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Move current iterator position backwards once */
|
|
|
|
|
curr_entry--;
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Note that we walked up */
|
|
|
|
|
walked_up = TRUE;
|
|
|
|
|
} /* end if */
|
|
|
|
|
else {
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#ifdef QAK
|
2006-07-01 21:58:14 +08:00
|
|
|
|
HDfprintf(stderr, "%s: Heap empty\n", FUNC);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
#endif /* QAK */
|
2006-07-31 17:54:09 +08:00
|
|
|
|
/* Reset iterator offset */
|
|
|
|
|
hdr->man_iter_off = 0;
|
|
|
|
|
|
|
|
|
|
/* Reset 'next block' iterator */
|
|
|
|
|
if(H5HF_man_iter_reset(&hdr->next_block) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTRELEASE, FAIL, "can't reset block iterator")
|
2006-07-01 21:58:14 +08:00
|
|
|
|
} /* end else */
|
|
|
|
|
} /* end if */
|
|
|
|
|
else {
|
|
|
|
|
unsigned row; /* Row for entry */
|
|
|
|
|
|
2006-06-19 18:06:10 +08:00
|
|
|
|
curr_entry = tmp_entry;
|
|
|
|
|
|
|
|
|
|
/* Check if entry is for a direct block */
|
|
|
|
|
row = curr_entry / hdr->man_dtable.cparam.width;
|
2006-07-01 21:58:14 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: curr_entry = %u\n", FUNC, curr_entry);
|
|
|
|
|
HDfprintf(stderr, "%s: row = %u\n", FUNC, row);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
if(row < hdr->man_dtable.max_direct_rows) {
|
2006-07-01 21:58:14 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Found direct block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
/* Increment entry to empty location */
|
|
|
|
|
curr_entry++;
|
|
|
|
|
|
|
|
|
|
/* Set the current location of the iterator to next entry after the existing direct block */
|
|
|
|
|
if(H5HF_man_iter_set_entry(hdr, &hdr->next_block, curr_entry) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTSET, FAIL, "unable to set current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Update iterator offset */
|
|
|
|
|
hdr->man_iter_off = iblock->block_off;
|
|
|
|
|
hdr->man_iter_off += hdr->man_dtable.row_block_off[curr_entry / hdr->man_dtable.cparam.width];
|
|
|
|
|
hdr->man_iter_off += hdr->man_dtable.row_block_size[curr_entry / hdr->man_dtable.cparam.width] * (curr_entry % hdr->man_dtable.cparam.width);
|
2006-07-01 21:58:14 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: hdr->man_iter_off = %Hu\n", FUNC, hdr->man_iter_off);
|
|
|
|
|
HDfprintf(stderr, "%s: curr_entry = %u\n", FUNC, curr_entry);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
} /* end if */
|
|
|
|
|
else {
|
|
|
|
|
H5HF_indirect_t *child_iblock; /* Pointer to child indirect block */
|
|
|
|
|
unsigned child_nrows; /* # of rows in child block */
|
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: Walking down into child block\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
/* Compute # of rows in next child indirect block to use */
|
|
|
|
|
child_nrows = H5HF_dtable_size_to_rows(&hdr->man_dtable, hdr->man_dtable.row_block_size[row]);
|
|
|
|
|
|
|
|
|
|
/* Lock child indirect block */
|
|
|
|
|
if(NULL == (child_iblock = H5HF_man_iblock_protect(hdr, dxpl_id, iblock->ents[curr_entry].addr, child_nrows, iblock, curr_entry, H5AC_WRITE)))
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTPROTECT, FAIL, "unable to protect fractal heap indirect block")
|
|
|
|
|
|
|
|
|
|
/* Set the current location of the iterator */
|
|
|
|
|
if(H5HF_man_iter_set_entry(hdr, &hdr->next_block, curr_entry) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTSET, FAIL, "unable to set current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Walk down into child indirect block (pins child block) */
|
|
|
|
|
if(H5HF_man_iter_down(&hdr->next_block, child_iblock) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTNEXT, FAIL, "unable to advance current block iterator location")
|
|
|
|
|
|
|
|
|
|
/* Update iterator location */
|
|
|
|
|
iblock = child_iblock;
|
|
|
|
|
curr_entry = (child_iblock->nrows * hdr->man_dtable.cparam.width) - 1;
|
2006-07-01 21:58:14 +08:00
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: iblock->nchildren = %u\n", FUNC, iblock->nchildren);
|
|
|
|
|
HDfprintf(stderr, "%s: iblock->parent = %p\n", FUNC, iblock->parent);
|
|
|
|
|
HDfprintf(stderr, "%s: curr_entry = %u\n", FUNC, curr_entry);
|
|
|
|
|
#endif /* QAK */
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
|
|
|
|
/* Unprotect child indirect block */
|
|
|
|
|
if(H5AC_unprotect(hdr->f, dxpl_id, H5AC_FHEAP_IBLOCK, child_iblock->addr, child_iblock, H5AC__NO_FLAGS_SET) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTUNPROTECT, FAIL, "unable to release fractal heap indirect block")
|
|
|
|
|
|
|
|
|
|
/* Note that we walked down */
|
|
|
|
|
walked_down = TRUE;
|
|
|
|
|
} /* end else */
|
2006-07-01 21:58:14 +08:00
|
|
|
|
} /* end else */
|
|
|
|
|
} while(walked_down || walked_up);
|
2006-06-19 18:06:10 +08:00
|
|
|
|
|
2006-04-30 21:32:41 +08:00
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
2006-06-19 18:06:10 +08:00
|
|
|
|
} /* end H5HF_hdr_reverse_iter() */
|
2006-04-30 21:32:41 +08:00
|
|
|
|
|
2006-05-23 00:43:45 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5HF_hdr_empty
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Reset heap header to 'empty heap' state
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Quincey Koziol
|
|
|
|
|
* koziol@ncsa.uiuc.edu
|
|
|
|
|
* May 17 2006
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
|
|
|
|
H5HF_hdr_empty(H5HF_hdr_t *hdr)
|
|
|
|
|
{
|
|
|
|
|
herr_t ret_value = SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI_NOINIT(H5HF_hdr_empty)
|
|
|
|
|
#ifdef QAK
|
2006-07-31 17:54:09 +08:00
|
|
|
|
HDfprintf(stderr, "%s: Resetting heap header to empty\n", FUNC);
|
2006-05-23 00:43:45 +08:00
|
|
|
|
#endif /* QAK */
|
|
|
|
|
|
|
|
|
|
/* Sanity check */
|
|
|
|
|
HDassert(hdr);
|
|
|
|
|
|
2006-07-31 17:54:09 +08:00
|
|
|
|
/* Reset block iterator, if necessary */
|
|
|
|
|
if(H5HF_man_iter_ready(&hdr->next_block)) {
|
|
|
|
|
#ifdef QAK
|
|
|
|
|
HDfprintf(stderr, "%s: 'next block' iterator is ready\n", FUNC);
|
|
|
|
|
#endif /* QAK */
|
|
|
|
|
if(H5HF_man_iter_reset(&hdr->next_block) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTRELEASE, FAIL, "can't reset block iterator")
|
|
|
|
|
} /* end if */
|
|
|
|
|
|
2006-08-08 05:24:29 +08:00
|
|
|
|
/* Shrink managed heap size */
|
2006-05-23 00:43:45 +08:00
|
|
|
|
hdr->man_size = 0;
|
2006-06-19 18:06:10 +08:00
|
|
|
|
hdr->man_alloc_size = 0;
|
2006-05-23 00:43:45 +08:00
|
|
|
|
|
2006-07-01 21:58:14 +08:00
|
|
|
|
/* Reset the 'next block' iterator location */
|
|
|
|
|
hdr->man_iter_off = 0;
|
|
|
|
|
|
2006-05-23 00:43:45 +08:00
|
|
|
|
/* Reset the free space in direct blocks */
|
|
|
|
|
hdr->total_man_free = 0;
|
|
|
|
|
|
|
|
|
|
/* Mark heap header as modified */
|
|
|
|
|
if(H5HF_hdr_dirty(hdr) < 0)
|
|
|
|
|
HGOTO_ERROR(H5E_HEAP, H5E_CANTDIRTY, FAIL, "can't mark header as dirty")
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value)
|
|
|
|
|
} /* end H5HF_hdr_empty() */
|
|
|
|
|
|