mirror/hdf5
2
0
Fork 0
mirror of https://github.com/HDFGroup/hdf5.git synced 2025-03-25 17:00:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

[svn-r6423] Purpose:

Browse Source 
Update
Description:
    Added support for the allocation and freeing of space in the file.
    This information is kept on the Server.
Platforms tested:
    Linux & Modi4
This commit is contained in:
Bill Wendling 2003-02-21 08:56:39 -05:00
parent 117381d325
commit 0dc2b9ea16
6 changed files with 293 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/H5E.c
View File

@ -176,7 +176,8 @@ static const H5E_minor_mesg_t H5E_minor_mesg_g[] = {
{H5E_CANTMAKETREE, "Can't create a binary tree node"},
{H5E_CANTRECV, "Can't receive messages from processes"},
{H5E_CANTSENDMDATA, "Can't send metadata message"},
{H5E_CANTCHANGE, "Can't register change with server"}
{H5E_CANTCHANGE, "Can't register change with server"},
{H5E_CANTALLOC, "Can't allocate from file"}
};
/* Interface initialization? */

3
src/H5Epublic.h
View File

@ -207,7 +207,8 @@ typedef enum H5E_minor_t {
H5E_CANTMAKETREE, /*can't make a TBBT tree */
H5E_CANTRECV, /*can't receive messages from processes */
H5E_CANTSENDMDATA, /*can't send metadata message */
H5E_CANTCHANGE /*can't register change on server */
H5E_CANTCHANGE, /*can't register change on server */
H5E_CANTALLOC /*can't allocate from file */
} H5E_minor_t;
/* Information about an error */

56
src/H5FP.c
View File

@ -32,6 +32,7 @@ static int interface_initialize_g = 0;
MPI_Datatype H5FP_request_t; /* MPI datatype for the H5FP_request obj*/
MPI_Datatype H5FP_reply_t; /* MPI datatype for the H5FP_reply obj */
MPI_Datatype H5FP_read_t; /* MPI datatype for the H5FP_read obj */
MPI_Datatype H5FP_alloc_t; /* MPI datatype for the H5FP_alloc obj */
/* SAP specific variables */
MPI_Comm H5FP_SAP_COMM; /* Comm we use: Supplied by user */
@ -73,6 +74,7 @@ H5FPinit(MPI_Comm comm, int sap_rank)
H5FP_request_t = MPI_DATATYPE_NULL;
H5FP_reply_t = MPI_DATATYPE_NULL;
H5FP_read_t = MPI_DATATYPE_NULL;
H5FP_alloc_t = MPI_DATATYPE_NULL;
H5FP_SAP_COMM = MPI_COMM_NULL;
H5FP_SAP_BARRIER_COMM = MPI_COMM_NULL;
@ -137,6 +139,10 @@ done:
if (MPI_Type_free(&H5FP_read_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_free failed");
if (H5FP_alloc_t != MPI_DATATYPE_NULL)
if (MPI_Type_free(&H5FP_alloc_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_free failed");
if (H5FP_SAP_BARRIER_COMM != MPI_COMM_NULL)
/* this comm will be NULL for the SAP */
if (MPI_Comm_free(&H5FP_SAP_BARRIER_COMM) != MPI_SUCCESS)
@ -194,6 +200,9 @@ H5FPfinalize(void)
if (MPI_Type_free(&H5FP_read_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_free failed");
if (MPI_Type_free(&H5FP_alloc_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_free failed");
/* Release the barrier communicator */
if (H5FP_SAP_BARRIER_COMM != MPI_COMM_NULL)
/* this comm will be NULL for the SAP */
@ -289,8 +298,8 @@ done:
/*
* Function: H5FP_commit_sap_datatypes
* Purpose: Commit the H5FP_request_t, H5FP_reply_t, and H5FP_read_t
* structure datatypes to MPI.
* Purpose: Commit the H5FP_request_t, H5FP_reply_t, H5FP_read_t, and
* H5FP_alloc_t structure datatypes to MPI.
* Return: Success: SUCCEED
* Failure: FAIL
* Programmer: Bill Wendling, 26. July, 2002
@ -299,9 +308,9 @@ done:
static herr_t
H5FP_commit_sap_datatypes(void)
{
int block_length[3];
MPI_Aint displs[3];
MPI_Datatype old_types[3];
int block_length[5];
MPI_Aint displs[5];
MPI_Datatype old_types[5];
H5FP_request req;
H5FP_read sap_read;
herr_t ret_value = SUCCEED;
@ -311,18 +320,26 @@ H5FP_commit_sap_datatypes(void)
/* Commit the H5FP_request_t datatype */
block_length[0] = 8;
block_length[1] = 1;
block_length[2] = sizeof(req.oid);
old_types[0] = MPI_INT;
block_length[2] = 1;
block_length[3] = 4;
block_length[4] = sizeof(req.oid);
old_types[0] = MPI_UNSIGNED;
old_types[1] = HADDR_AS_MPI_TYPE;
old_types[2] = MPI_UNSIGNED_CHAR;
old_types[2] = MPI_UNSIGNED_LONG;
old_types[3] = MPI_LONG_LONG_INT;
old_types[4] = MPI_UNSIGNED_CHAR;
MPI_Address(&req.req_type, &displs[0]);
MPI_Address(&req.addr, &displs[1]);
MPI_Address(&req.oid, &displs[2]);
MPI_Address(&req.feature_flags, &displs[2]);
MPI_Address(&req.meta_block_size, &displs[3]);
MPI_Address(&req.oid, &displs[4]);
displs[4] -= displs[3];
displs[3] -= displs[2];
displs[2] -= displs[1];
displs[1] -= displs[0];
displs[0] -= displs[0];
if (MPI_Type_struct(3, block_length, displs, old_types,
if (MPI_Type_struct(5, block_length, displs, old_types,
&H5FP_request_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_struct failed");
@ -344,7 +361,7 @@ H5FP_commit_sap_datatypes(void)
/* Commit the H5FP_read_t datatype */
block_length[0] = 5;
block_length[1] = 1;
old_types[0] = MPI_INT;
old_types[0] = MPI_UNSIGNED;
old_types[1] = HADDR_AS_MPI_TYPE;
MPI_Address(&sap_read.req_id, &displs[0]);
MPI_Address(&sap_read.addr, &displs[1]);
@ -358,6 +375,23 @@ H5FP_commit_sap_datatypes(void)
if (MPI_Type_commit(&H5FP_read_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_commit failed");
/* Commit the H5FP_alloc_t datatype */
block_length[0] = 4;
block_length[1] = 1;
old_types[0] = MPI_UNSIGNED;
old_types[1] = HADDR_AS_MPI_TYPE;
MPI_Address(&sap_read.req_id, &displs[0]);
MPI_Address(&sap_read.addr, &displs[1]);
displs[1] -= displs[0];
displs[0] -= displs[0];
if (MPI_Type_struct(2, block_length, displs, old_types,
&H5FP_alloc_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_struct failed");
if (MPI_Type_commit(&H5FP_alloc_t) != MPI_SUCCESS)
HGOTO_ERROR(H5E_INTERNAL, H5E_MPI, FAIL, "MPI_Type_commit failed");
done:
FUNC_LEAVE_NOAPI(ret_value);
}

135
src/H5FPclient.c
View File

@ -70,7 +70,9 @@ static herr_t H5FP_dump_to_file(H5FD_t *file, hid_t dxpl_id, H5FP_read *sap_read
*/
herr_t
H5FP_request_open(H5FP_obj_t obj_type, MPI_Offset maxaddr,
unsigned *file_id, unsigned *req_id)
unsigned long feature_flags, hsize_t meta_block_size,
hsize_t sdata_block_size, hsize_t threshold,
hsize_t alignment, unsigned *file_id, unsigned *req_id)
{
H5FP_request req;
MPI_Status mpi_status;
@ -100,6 +102,11 @@ H5FP_request_open(H5FP_obj_t obj_type, MPI_Offset maxaddr,
req.md_size = 0;
req.obj_type = obj_type;
req.addr = maxaddr;
req.feature_flags = feature_flags;
req.meta_block_size = meta_block_size;
req.sdata_block_size = sdata_block_size;
req.threshold = threshold;
req.alignment = alignment;
if ((mrc = MPI_Send(&req, 1, H5FP_request_t, (int)H5FP_sap_rank,
H5FP_TAG_REQUEST, H5FP_SAP_COMM)) != MPI_SUCCESS)
@ -573,11 +580,11 @@ herr_t
H5FP_request_close(H5FD_t *file, unsigned file_id, unsigned *req_id,
H5FP_status_t *status)
{
H5FP_reply sap_reply;
H5FP_request req;
MPI_Status mpi_status;
int mrc, my_rank;
int ret_value = SUCCEED;
H5FP_reply sap_reply;
H5FP_request req;
MPI_Status mpi_status;
int mrc;
herr_t ret_value = SUCCEED;
FUNC_ENTER_NOAPI(H5FP_request_close, FAIL);
@ -587,14 +594,10 @@ H5FP_request_close(H5FD_t *file, unsigned file_id, unsigned *req_id,
assert(status);
HDmemset(&req, 0, sizeof(req));
if ((mrc = MPI_Comm_rank(H5FP_SAP_COMM, &my_rank)) != MPI_SUCCESS)
HMPI_GOTO_ERROR(FAIL, "MPI_Comm_rank failed", mrc);
req.req_type = H5FP_REQ_CLOSE;
req.req_id = H5FP_gen_request_id();
req.file_id = file_id;
req.proc_rank = my_rank;
req.proc_rank = H5FD_fphdf5_mpi_rank(file);
if ((mrc = MPI_Send(&req, 1, H5FP_request_t, (int)H5FP_sap_rank,
H5FP_TAG_REQUEST, H5FP_SAP_COMM)) != MPI_SUCCESS)
@ -616,6 +619,116 @@ done:
FUNC_LEAVE_NOAPI(ret_value);
}
/*
* Function: H5FP_request_allocate
* Purpose: Request an allocation of space from the SAP.
* Return: Success: SUCCEED
* Failure: FAIL
* Programmer: Bill Wendling, 19. February 2003
* Modifications:
*/
herr_t
H5FP_request_allocate(H5FD_t *file, H5FD_mem_t mem_type, hsize_t size,
haddr_t *addr, unsigned *req_id, H5FP_status_t *status)
{
H5FP_alloc sap_alloc;
H5FP_request req;
MPI_Status mpi_status;
int mrc;
herr_t ret_value = SUCCEED;
FUNC_ENTER_NOAPI(H5FP_request_allocate, FAIL);
/* check args */
assert(file);
assert(req_id);
assert(status);
HDmemset(&req, 0, sizeof(req));
req.req_type = H5FP_REQ_ALLOC;
req.req_id = H5FP_gen_request_id();
req.file_id = H5FD_fphdf5_file_id(file);
req.proc_rank = H5FD_fphdf5_mpi_rank(file);
req.mem_type = mem_type;
req.meta_block_size = size; /* use this field as the size to allocate */
if ((mrc = MPI_Send(&req, 1, H5FP_request_t, (int)H5FP_sap_rank,
H5FP_TAG_REQUEST, H5FP_SAP_COMM)) != MPI_SUCCESS)
HMPI_GOTO_ERROR(FAIL, "MPI_Send failed", mrc);
HDmemset(&mpi_status, 0, sizeof(mpi_status));
if ((mrc = MPI_Recv(&sap_alloc, 1, H5FP_alloc_t, (int)H5FP_sap_rank,
H5FP_TAG_ALLOC, H5FP_SAP_COMM, &mpi_status)) != MPI_SUCCESS)
HMPI_GOTO_ERROR(FAIL, "MPI_Recv failed", mrc);
if (sap_alloc.status != H5FP_STATUS_OK)
HGOTO_ERROR(H5E_RESOURCE, H5E_CANTCHANGE, FAIL, "can't allocate space on server");
*status = H5FP_STATUS_OK;
*addr = sap_alloc.addr;
done:
*req_id = req.req_id;
FUNC_LEAVE_NOAPI(ret_value);
}
/*
* Function: H5FP_request_free
* Purpose: Request freeing of space from the SAP.
* Return: Success: SUCCEED
* Failure: FAIL
* Programmer: Bill Wendling, 20. February 2003
* Modifications:
*/
herr_t
H5FP_request_free(H5FD_t *file, H5FD_mem_t mem_type, haddr_t addr,
hsize_t size, unsigned *req_id, H5FP_status_t *status)
{
H5FP_reply sap_reply;
H5FP_request req;
MPI_Status mpi_status;
int mrc;
herr_t ret_value = SUCCEED;
FUNC_ENTER_NOAPI(H5FP_request_free, FAIL);
/* check args */
assert(file);
assert(req_id);
assert(status);
HDmemset(&req, 0, sizeof(req));
req.req_type = H5FP_REQ_ALLOC;
req.req_id = H5FP_gen_request_id();
req.file_id = H5FD_fphdf5_file_id(file);
req.proc_rank = H5FD_fphdf5_mpi_rank(file);
req.mem_type = mem_type;
req.addr = addr;
req.meta_block_size = size; /* use this field as the size to free */
if ((mrc = MPI_Send(&req, 1, H5FP_request_t, (int)H5FP_sap_rank,
H5FP_TAG_REQUEST, H5FP_SAP_COMM)) != MPI_SUCCESS)
HMPI_GOTO_ERROR(FAIL, "MPI_Send failed", mrc);
HDmemset(&mpi_status, 0, sizeof(mpi_status));
if ((mrc = MPI_Recv(&sap_reply, 1, H5FP_reply_t, (int)H5FP_sap_rank,
H5FP_TAG_REPLY, H5FP_SAP_COMM, &mpi_status)) != MPI_SUCCESS)
HMPI_GOTO_ERROR(FAIL, "MPI_Recv failed", mrc);
if (sap_reply.status != H5FP_STATUS_OK)
HGOTO_ERROR(H5E_RESOURCE, H5E_CANTCHANGE, FAIL, "can't free space on server");
*status = H5FP_STATUS_OK;
done:
*req_id = req.req_id;
FUNC_LEAVE_NOAPI(ret_value);
}
/*
*===----------------------------------------------------------------------===
* Functions Private to Client Module

39
src/H5FPprivate.h
View File

@ -39,6 +39,7 @@
* for that object.
*/
typedef enum {
/* Metadata Requests */
H5FP_REQ_OPEN, /* Open a file (or eventually an object) */
H5FP_REQ_LOCK, /* Lock an object (in a sequence) */
H5FP_REQ_LOCK_END, /* Last lock request in lock sequence */
@ -48,7 +49,11 @@ typedef enum {
H5FP_REQ_READ, /* Reading a piece of metadata */
H5FP_REQ_FLUSH, /* Flush the metadata out to disk */
H5FP_REQ_CLOSE, /* Close a file (or eventually an object) */
H5FP_REQ_STOP /* Stop SAP */
H5FP_REQ_STOP, /* Stop SAP */
/* Allocation Requests */
H5FP_REQ_ALLOC, /* Allocate a region of metadata */
H5FP_REQ_FREE /* Free a region of metadata */
} H5FP_req_t;
/*===----------------------------------------------------------------------===
@ -105,6 +110,7 @@ enum {
H5FP_TAG_REPLY,
H5FP_TAG_READ,
H5FP_TAG_METADATA,
H5FP_TAG_ALLOC,
H5FP_TAG_FILE_ID
};
@ -168,6 +174,11 @@ typedef struct {
H5FD_mem_t mem_type; /* Type of memory updated, if req'd */
unsigned md_size; /* Size of the metadata sent in next msg */
MPI_Offset addr; /* Address of the metadata */
unsigned long feature_flags; /* Feature flags for the file driver */
hsize_t meta_block_size; /* Metadata block size */
hsize_t sdata_block_size; /* Small data block size */
hsize_t threshold; /* Alignment threshold */
hsize_t alignment; /* Alignment (really!) */
unsigned char oid[H5R_OBJ_REF_BUF_SIZE]; /* Buffer to store OID of object */
} H5FP_request;
@ -205,6 +216,22 @@ typedef struct {
extern MPI_Datatype H5FP_read_t; /* MPI datatype for the H5FP_read obj */
/*===----------------------------------------------------------------------===
* H5FP_alloc
*===----------------------------------------------------------------------===
*
* The reply message from the SAP on an H5FP_alloc H5FP_REQ_ALLOC send.
*/
typedef struct {
unsigned req_id; /* Request ID copied from the SAP_request */
unsigned file_id; /* SAP's file ID for the specific file */
H5FP_status_t status; /* Status of the request */
H5FD_mem_t mem_type; /* Type of memory updated, if req'd */
haddr_t addr; /* Address of the metadata */
} H5FP_alloc;
extern MPI_Datatype H5FP_alloc_t; /* MPI datatype for the H5FP_alloc obj */
/* Handy #define for copying OIDs */
#define H5FP_COPY_OID(dst, src) HDmemcpy((dst), (src), H5R_OBJ_REF_BUF_SIZE)
@ -224,6 +251,9 @@ extern herr_t H5FP_sap_receive_loop(void);
/* Use these functions to communicate with the SAP */
extern herr_t H5FP_request_open(H5FP_obj_t obj_type, MPI_Offset maxaddr,
unsigned long feature_flags, hsize_t
meta_block_size, hsize_t sdata_block_size,
hsize_t threshold, hsize_t alignment,
unsigned *file_id, unsigned *req_id);
extern herr_t H5FP_request_lock(unsigned sap_file_id, unsigned char *mdata,
H5FP_lock_t rw_lock, int last, unsigned *req_id,
@ -245,6 +275,13 @@ extern herr_t H5FP_request_flush_metadata(H5FD_t *file, unsigned file_id,
extern herr_t H5FP_request_close(H5FD_t *file, unsigned sap_file_id,
unsigned *req_id, H5FP_status_t *status);
extern herr_t H5FP_request_allocate(H5FD_t *file, H5FD_mem_t mem_type,
hsize_t size, haddr_t *addr,
unsigned *req_id, H5FP_status_t *status);
extern herr_t H5FP_request_free(H5FD_t *file, H5FD_mem_t mem_type,
haddr_t addr, hsize_t size,
unsigned *req_id, H5FP_status_t *status);
/* NOTE: Don't use these functions outside of the H5FP* modules! */
extern herr_t H5FP_send_metadata(const char *mdata, int len, int to);
extern herr_t H5FP_read_metadata(char **mdata, int len, int from);

86
src/H5FPserver.c
View File

@ -28,11 +28,13 @@
#include "H5private.h" /* Generic Functions */
#include "H5ACprivate.h" /* Metadata Cache */
#include "H5Eprivate.h" /* Error Handling */
#include "H5FDprivate.h" /* File driver */
#include "H5Oprivate.h" /* Object Headers */
#include "H5TBprivate.h" /* Threaded, Balanced, Binary Trees */
#ifdef H5_HAVE_FPHDF5
#include "H5FDfphdf5.h" /* File Driver for FPHDF5 */
#include "H5FPprivate.h" /* Flexible Parallel Functions */
/* Pablo mask */
@ -125,7 +127,12 @@ static herr_t H5FP_remove_object_lock_from_list(H5FP_file_info *info,
H5FP_object_lock *ol);
/* local file information handling functions */
static herr_t H5FP_add_new_file_info_to_list(unsigned file_id, MPI_Offset maxaddr);
static herr_t H5FP_add_new_file_info_to_list(unsigned file_id, MPI_Offset maxaddr,
unsigned long feature_flags,
hsize_t meta_block_size,
hsize_t sdata_block_size,
hsize_t threshold,
hsize_t alignment);
static int H5FP_file_info_cmp(H5FP_file_info *k1, H5FP_file_info *k2, int cmparg);
static H5FP_file_info *H5FP_new_file_info_node(unsigned file_id);
static H5FP_file_info *H5FP_find_file_info(unsigned file_id);
@ -150,6 +157,7 @@ static herr_t H5FP_sap_handle_write_request(H5FP_request req,
unsigned md_size);
static herr_t H5FP_sap_handle_flush_request(H5FP_request req);
static herr_t H5FP_sap_handle_close_request(H5FP_request req);
static herr_t H5FP_sap_handle_alloc_request(H5FP_request req);
/*
*===----------------------------------------------------------------------===
@ -219,6 +227,9 @@ H5FP_sap_receive_loop(void)
case H5FP_REQ_CLOSE:
hrc = H5FP_sap_handle_close_request(req);
break;
case H5FP_REQ_ALLOC:
hrc = H5FP_sap_handle_alloc_request(req);
break;
case H5FP_REQ_STOP:
if (++stop == comm_size - 1)
goto done;
@ -634,7 +645,12 @@ H5FP_find_file_info(unsigned file_id)
* Modifications:
*/
static herr_t
H5FP_add_new_file_info_to_list(unsigned file_id, MPI_Offset maxaddr)
H5FP_add_new_file_info_to_list(unsigned file_id, MPI_Offset maxaddr,
unsigned long feature_flags,
hsize_t meta_block_size,
hsize_t sdata_block_size,
hsize_t threshold,
hsize_t alignment)
{
H5FP_file_info *info;
herr_t ret_value = FAIL;
@ -652,9 +668,15 @@ H5FP_add_new_file_info_to_list(unsigned file_id, MPI_Offset maxaddr)
* Initialize some of the information needed for metadata
* allocation requests
*/
HDmemset(info->file.fl, 0, sizeof(info->file.fl));
info->file.cls = &H5FD_fphdf5_g;
info->file.maxaddr = maxaddr;
info->file.accum_loc = HADDR_UNDEF;
HDmemset(info->file.fl, 0, sizeof(info->file.fl));
info->file.feature_flags = feature_flags;
info->file.def_meta_block_size = meta_block_size;
info->file.def_sdata_block_size = sdata_block_size;
info->file.threshold = threshold;
info->file.alignment = alignment;
ret_value = SUCCEED;
}
@ -840,7 +862,9 @@ H5FP_sap_handle_open_request(H5FP_request req, unsigned UNUSED md_size)
unsigned new_file_id = H5FP_gen_sap_file_id();
/* N.B. At this point, req.addr is equiv. to maxaddr in H5FD_open() */
if (H5FP_add_new_file_info_to_list(new_file_id, req.addr) != SUCCEED)
if (H5FP_add_new_file_info_to_list(new_file_id, req.addr, req.feature_flags,
req.meta_block_size, req.sdata_block_size,
req.threshold, req.alignment) != SUCCEED)
HGOTO_ERROR(H5E_FPHDF5, H5E_CANTINSERT, FAIL,
"can't insert new file structure to list");
@ -1265,7 +1289,9 @@ H5FP_sap_handle_write_request(H5FP_request req, char *mdata, unsigned md_size)
FUNC_ENTER_NOINIT(H5FP_sap_handle_write_request);
if ((info = H5FP_find_file_info(req.file_id)) != NULL) {
#if 0
H5FP_object_lock *lock;
#endif /* 0 */
if (info->num_mods >= H5FP_MDATA_CACHE_HIGHWATER_MARK) {
/*
@ -1409,4 +1435,56 @@ done:
FUNC_LEAVE_NOAPI(ret_value);
}
/*
* Function: H5FP_sap_handle_alloc_request
* Purpose: Handle a request to allocate data from the file.
* Return: Success: SUCCEED
* Failure: FAIL
* Programmer: Bill Wendling, 19. February 2003
* Modifications:
*/
static herr_t
H5FP_sap_handle_alloc_request(H5FP_request req)
{
H5FP_alloc alloc;
H5FP_file_info *info;
int mrc;
herr_t ret_value = SUCCEED;
FUNC_ENTER_NOINIT(H5FP_sap_handle_alloc_request);
if ((info = H5FP_find_file_info(req.file_id)) != NULL) {
alloc.req_id = req.req_id;
alloc.file_id = info->file_id;
alloc.status = H5FP_STATUS_OK;
alloc.mem_type = req.mem_type;
/*
* Try allocating from the free-list that is kept on the server
* first. If that fails, then call the specified allocation
* functions depending upon what type of data is being allocated.
*
* Note: H5P_DEFAULT is passed in as the data xfer property list.
* This is okay since the only situation where that will be used
* is if you have a "hole" in the middle of your metadata (in
* aggregate mode) that needs to be freed. We've turned off
* metadata aggregation for FPHDF5 because we don't have the
* proper information.
*
* Whatta pain.
*/
if ((alloc.addr = H5FD_alloc(&info->file, req.mem_type,
H5P_DEFAULT, req.meta_block_size)) == HADDR_UNDEF)
HGOTO_ERROR(H5E_VFL, H5E_CANTINIT, FAIL,
"SAP unable to allocate file memory");
if ((mrc = MPI_Send(&alloc, 1, H5FP_alloc_t, (int)req.proc_rank,
H5FP_TAG_ALLOC, H5FP_SAP_COMM)) != MPI_SUCCESS)
HMPI_GOTO_ERROR(FAIL, "MPI_Send failed", mrc);
}
done:
FUNC_LEAVE_NOAPI(ret_value);
}
#endif /* H5_HAVE_FPHDF5 */