1999-08-11 04:21:32 +08:00
|
|
|
|
/*
|
2001-04-06 01:29:14 +08:00
|
|
|
|
* Copyright <EFBFBD> 1999-2001 NCSA
|
|
|
|
|
* All rights reserved.
|
1999-08-11 04:21:32 +08:00
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke <matzke@llnl.gov>
|
|
|
|
|
* Tuesday, August 10, 1999
|
|
|
|
|
*
|
|
|
|
|
* Purpose: A driver which stores the HDF5 data in main memory using
|
|
|
|
|
* only the HDF5 public API. This driver is useful for fast
|
|
|
|
|
* access to small, temporary hdf5 files.
|
|
|
|
|
*/
|
2001-04-06 01:29:14 +08:00
|
|
|
|
#include "H5private.h" /*library functions */
|
|
|
|
|
#include "H5Eprivate.h" /*error handling */
|
|
|
|
|
#include "H5Fprivate.h" /*files */
|
|
|
|
|
#include "H5FDprivate.h" /*file driver */
|
2001-11-04 06:27:54 +08:00
|
|
|
|
#include "H5FDcore.h" /* Core file driver */
|
|
|
|
|
#include "H5Iprivate.h" /*object IDs */
|
|
|
|
|
#include "H5MMprivate.h" /* Memory allocation */
|
2001-04-06 01:29:14 +08:00
|
|
|
|
#include "H5Pprivate.h" /*property lists */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
#undef MAX
|
|
|
|
|
#define MAX(X,Y) ((X)>(Y)?(X):(Y))
|
|
|
|
|
|
|
|
|
|
#undef MIN
|
|
|
|
|
#define MIN(X,Y) ((X)<(Y)?(X):(Y))
|
|
|
|
|
|
|
|
|
|
/* The driver identification number, initialized at runtime */
|
|
|
|
|
static hid_t H5FD_CORE_g = 0;
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* The description of a file belonging to this driver. The `eoa' and `eof'
|
|
|
|
|
* determine the amount of hdf5 address space in use and the high-water mark
|
|
|
|
|
* of the file (the current size of the underlying memory).
|
|
|
|
|
*/
|
|
|
|
|
typedef struct H5FD_core_t {
|
|
|
|
|
H5FD_t pub; /*public stuff, must be first */
|
|
|
|
|
char *name; /*for equivalence testing */
|
|
|
|
|
unsigned char *mem; /*the underlying memory */
|
|
|
|
|
haddr_t eoa; /*end of allocated region */
|
|
|
|
|
haddr_t eof; /*current allocated size */
|
|
|
|
|
size_t increment; /*multiples for mem allocation */
|
1999-10-15 22:53:57 +08:00
|
|
|
|
int fd; /*backing store file descriptor */
|
|
|
|
|
hbool_t dirty; /*changes not saved? */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
} H5FD_core_t;
|
|
|
|
|
|
|
|
|
|
/* Driver-specific file access properties */
|
|
|
|
|
typedef struct H5FD_core_fapl_t {
|
|
|
|
|
size_t increment; /*how much to grow memory */
|
1999-10-15 22:53:57 +08:00
|
|
|
|
hbool_t backing_store; /*write to file name on flush */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
} H5FD_core_fapl_t;
|
|
|
|
|
|
|
|
|
|
/* Allocate memory in multiples of this size by default */
|
|
|
|
|
#define H5FD_CORE_INCREMENT 8192
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* These macros check for overflow of various quantities. These macros
|
|
|
|
|
* assume that file_offset_t is signed and haddr_t and size_t are unsigned.
|
|
|
|
|
*
|
|
|
|
|
* ADDR_OVERFLOW: Checks whether a file address of type `haddr_t'
|
|
|
|
|
* is too large to be represented by the second argument
|
|
|
|
|
* of the file seek function.
|
|
|
|
|
*
|
|
|
|
|
* SIZE_OVERFLOW: Checks whether a buffer size of type `hsize_t' is too
|
|
|
|
|
* large to be represented by the `size_t' type.
|
|
|
|
|
*
|
|
|
|
|
* REGION_OVERFLOW: Checks whether an address and size pair describe data
|
|
|
|
|
* which can be addressed entirely in memory.
|
|
|
|
|
*/
|
2002-10-01 00:31:55 +08:00
|
|
|
|
#define MAXADDR ((haddr_t)((~(size_t)0)-1))
|
1999-08-11 04:21:32 +08:00
|
|
|
|
#define ADDR_OVERFLOW(A) (HADDR_UNDEF==(A) || \
|
|
|
|
|
((A) & ~(haddr_t)MAXADDR))
|
|
|
|
|
#define SIZE_OVERFLOW(Z) ((Z) & ~(hsize_t)MAXADDR)
|
|
|
|
|
#define REGION_OVERFLOW(A,Z) (ADDR_OVERFLOW(A) || SIZE_OVERFLOW(Z) || \
|
|
|
|
|
HADDR_UNDEF==(A)+(Z) || \
|
|
|
|
|
(size_t)((A)+(Z))<(size_t)(A))
|
|
|
|
|
|
|
|
|
|
/* Prototypes */
|
1999-08-18 03:12:59 +08:00
|
|
|
|
static void *H5FD_core_fapl_get(H5FD_t *_file);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
static H5FD_t *H5FD_core_open(const char *name, unsigned flags, hid_t fapl_id,
|
|
|
|
|
haddr_t maxaddr);
|
|
|
|
|
static herr_t H5FD_core_close(H5FD_t *_file);
|
|
|
|
|
static int H5FD_core_cmp(const H5FD_t *_f1, const H5FD_t *_f2);
|
|
|
|
|
static haddr_t H5FD_core_get_eoa(H5FD_t *_file);
|
|
|
|
|
static herr_t H5FD_core_set_eoa(H5FD_t *_file, haddr_t addr);
|
|
|
|
|
static haddr_t H5FD_core_get_eof(H5FD_t *_file);
|
2002-10-01 00:31:55 +08:00
|
|
|
|
static herr_t H5FD_core_get_handle(H5FD_t *_file, hid_t fapl, void** file_handle);
|
2000-10-25 02:18:09 +08:00
|
|
|
|
static herr_t H5FD_core_read(H5FD_t *_file, H5FD_mem_t type, hid_t fapl_id, haddr_t addr,
|
2001-07-11 05:19:18 +08:00
|
|
|
|
size_t size, void *buf);
|
2000-09-01 03:33:58 +08:00
|
|
|
|
static herr_t H5FD_core_write(H5FD_t *_file, H5FD_mem_t type, hid_t fapl_id, haddr_t addr,
|
2001-07-11 05:19:18 +08:00
|
|
|
|
size_t size, const void *buf);
|
2003-02-11 01:26:09 +08:00
|
|
|
|
static herr_t H5FD_core_flush(H5FD_t *_file, hid_t dxpl_id, unsigned closing);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
static const H5FD_class_t H5FD_core_g = {
|
|
|
|
|
"core", /*name */
|
|
|
|
|
MAXADDR, /*maxaddr */
|
2001-12-12 03:53:44 +08:00
|
|
|
|
H5F_CLOSE_WEAK, /*fc_degree */
|
1999-08-18 03:12:59 +08:00
|
|
|
|
NULL, /*sb_size */
|
|
|
|
|
NULL, /*sb_encode */
|
|
|
|
|
NULL, /*sb_decode */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
sizeof(H5FD_core_fapl_t), /*fapl_size */
|
1999-08-18 03:12:59 +08:00
|
|
|
|
H5FD_core_fapl_get, /*fapl_get */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
NULL, /*fapl_copy */
|
|
|
|
|
NULL, /*fapl_free */
|
|
|
|
|
0, /*dxpl_size */
|
|
|
|
|
NULL, /*dxpl_copy */
|
|
|
|
|
NULL, /*dxpl_free */
|
|
|
|
|
H5FD_core_open, /*open */
|
|
|
|
|
H5FD_core_close, /*close */
|
|
|
|
|
H5FD_core_cmp, /*cmp */
|
2000-12-30 02:35:15 +08:00
|
|
|
|
NULL, /*query */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
NULL, /*alloc */
|
|
|
|
|
NULL, /*free */
|
|
|
|
|
H5FD_core_get_eoa, /*get_eoa */
|
|
|
|
|
H5FD_core_set_eoa, /*set_eoa */
|
|
|
|
|
H5FD_core_get_eof, /*get_eof */
|
2002-10-01 00:31:55 +08:00
|
|
|
|
H5FD_core_get_handle, /*get_handle */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
H5FD_core_read, /*read */
|
|
|
|
|
H5FD_core_write, /*write */
|
1999-10-15 22:53:57 +08:00
|
|
|
|
H5FD_core_flush, /*flush */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
H5FD_FLMAP_SINGLE, /*fl_map */
|
|
|
|
|
};
|
|
|
|
|
|
1999-10-23 08:36:04 +08:00
|
|
|
|
/* Interface initialization */
|
|
|
|
|
#define PABLO_MASK H5FD_core_mask
|
|
|
|
|
#define INTERFACE_INIT H5FD_core_init
|
2001-08-15 06:09:56 +08:00
|
|
|
|
static int interface_initialize_g = 0;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_init
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Initialize this driver by registering the driver with the
|
|
|
|
|
* library.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: The driver ID for the core driver.
|
|
|
|
|
*
|
|
|
|
|
* Failure: Negative.
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
hid_t
|
|
|
|
|
H5FD_core_init(void)
|
|
|
|
|
{
|
2002-08-10 04:48:23 +08:00
|
|
|
|
hid_t ret_value=H5FD_CORE_g; /* Return value */
|
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_init, FAIL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
|
|
|
|
if (H5I_VFL!=H5Iget_type(H5FD_CORE_g))
|
|
|
|
|
H5FD_CORE_g = H5FDregister(&H5FD_core_g);
|
|
|
|
|
|
2002-08-10 04:48:23 +08:00
|
|
|
|
/* Set return value */
|
|
|
|
|
ret_value=H5FD_CORE_g;
|
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5Pset_fapl_core
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Modify the file access property list to use the H5FD_CORE
|
|
|
|
|
* driver defined in this source file. The INCREMENT specifies
|
|
|
|
|
* how much to grow the memory each time we need more.
|
|
|
|
|
*
|
|
|
|
|
* Return: Non-negative on success/Negative on failure
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, February 19, 1998
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
1999-10-15 22:53:57 +08:00
|
|
|
|
* Robb Matzke, 1999-10-19
|
|
|
|
|
* Added the BACKING_STORE argument. If set then the entire file
|
|
|
|
|
* contents are flushed to a file with the same name as this
|
|
|
|
|
* core file.
|
2001-10-26 03:29:37 +08:00
|
|
|
|
*
|
|
|
|
|
* Raymond Lu, 2001-10-25
|
|
|
|
|
* Changed the file access list to the new generic list.
|
|
|
|
|
*
|
1999-08-11 04:21:32 +08:00
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
1999-10-15 22:53:57 +08:00
|
|
|
|
H5Pset_fapl_core(hid_t fapl_id, size_t increment, hbool_t backing_store)
|
1999-08-11 04:21:32 +08:00
|
|
|
|
{
|
|
|
|
|
H5FD_core_fapl_t fa;
|
2001-11-21 03:07:22 +08:00
|
|
|
|
H5P_genplist_t *plist; /* Property list pointer */
|
2002-08-09 00:52:55 +08:00
|
|
|
|
herr_t ret_value;
|
1999-10-08 00:51:49 +08:00
|
|
|
|
|
2002-10-01 00:31:55 +08:00
|
|
|
|
FUNC_ENTER_API(H5Pset_fapl_core, FAIL);
|
1999-11-01 23:21:16 +08:00
|
|
|
|
H5TRACE3("e","izb",fapl_id,increment,backing_store);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2001-10-26 03:29:37 +08:00
|
|
|
|
/* Check argument */
|
2002-08-12 21:33:42 +08:00
|
|
|
|
if(NULL == (plist = H5P_object_verify(fapl_id,H5P_FILE_ACCESS)))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_BADTYPE, FAIL, "not a file access property list");
|
2001-10-26 03:29:37 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
fa.increment = increment;
|
1999-10-15 22:53:57 +08:00
|
|
|
|
fa.backing_store = backing_store;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2001-11-21 03:07:22 +08:00
|
|
|
|
ret_value= H5P_set_driver(plist, H5FD_CORE, &fa);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_API(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5Pget_fapl_core
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Queries properties set by the H5Pset_fapl_core() function.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: Non-negative
|
|
|
|
|
*
|
|
|
|
|
* Failure: Negative
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Tuesday, August 10, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
1999-10-15 22:53:57 +08:00
|
|
|
|
* Robb Matzke, 1999-10-19
|
|
|
|
|
* Added the BACKING_STORE argument.
|
2001-10-26 03:29:37 +08:00
|
|
|
|
*
|
|
|
|
|
* Raymond Lu
|
|
|
|
|
* 2001-10-25
|
|
|
|
|
* Changed file access list to the new generic property list.
|
|
|
|
|
*
|
1999-08-11 04:21:32 +08:00
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
herr_t
|
1999-10-15 22:53:57 +08:00
|
|
|
|
H5Pget_fapl_core(hid_t fapl_id, size_t *increment/*out*/,
|
|
|
|
|
hbool_t *backing_store/*out*/)
|
1999-08-11 04:21:32 +08:00
|
|
|
|
{
|
|
|
|
|
H5FD_core_fapl_t *fa;
|
2001-11-21 03:07:22 +08:00
|
|
|
|
H5P_genplist_t *plist; /* Property list pointer */
|
2002-08-09 00:52:55 +08:00
|
|
|
|
herr_t ret_value=SUCCEED; /* Return value */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_API(H5Pget_fapl_core, FAIL);
|
1999-11-01 23:21:16 +08:00
|
|
|
|
H5TRACE3("e","ixx",fapl_id,increment,backing_store);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-12 21:33:42 +08:00
|
|
|
|
if(NULL == (plist = H5P_object_verify(fapl_id,H5P_FILE_ACCESS)))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_BADTYPE, FAIL,
|
2001-10-26 03:29:37 +08:00
|
|
|
|
"not a file access property list");
|
2001-11-21 03:07:22 +08:00
|
|
|
|
if (H5FD_CORE!=H5P_get_driver(plist))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_PLIST, H5E_BADVALUE, FAIL, "incorrect VFL driver");
|
2001-11-21 03:07:22 +08:00
|
|
|
|
if (NULL==(fa=H5P_get_driver_info(plist)))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_PLIST, H5E_BADVALUE, FAIL, "bad VFL driver info");
|
1999-10-15 22:53:57 +08:00
|
|
|
|
|
2001-11-21 03:07:22 +08:00
|
|
|
|
if (increment)
|
|
|
|
|
*increment = fa->increment;
|
|
|
|
|
if (backing_store)
|
|
|
|
|
*backing_store = fa->backing_store;
|
1999-10-15 22:53:57 +08:00
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_API(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
1999-08-18 03:12:59 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_fapl_get
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Returns a copy of the file access properties.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: Ptr to new file access properties.
|
|
|
|
|
*
|
|
|
|
|
* Failure: NULL
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Friday, August 13, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static void *
|
|
|
|
|
H5FD_core_fapl_get(H5FD_t *_file)
|
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
H5FD_core_fapl_t *fa = NULL;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
void *ret_value; /* Return value */
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_fapl_get, NULL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
|
|
|
|
if (NULL==(fa=H5MM_calloc(sizeof(H5FD_core_fapl_t))))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, NULL, "memory allocation failed");
|
1999-08-18 03:12:59 +08:00
|
|
|
|
|
|
|
|
|
fa->increment = file->increment;
|
1999-10-15 22:53:57 +08:00
|
|
|
|
fa->backing_store = (file->fd>=0);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
/* Set return value */
|
|
|
|
|
ret_value=fa;
|
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-18 03:12:59 +08:00
|
|
|
|
}
|
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_open
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Create memory as an HDF5 file.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: A pointer to a new file data structure. The
|
|
|
|
|
* public fields will be initialized by the
|
|
|
|
|
* caller, which is always H5FD_open().
|
|
|
|
|
*
|
|
|
|
|
* Failure: NULL
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
1999-10-15 22:53:57 +08:00
|
|
|
|
* Robb Matzke, 1999-10-19
|
|
|
|
|
* The backing store file is created and opened if specified.
|
1999-08-11 04:21:32 +08:00
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static H5FD_t *
|
1999-09-30 08:02:13 +08:00
|
|
|
|
H5FD_core_open(const char *name, unsigned UNUSED flags, hid_t fapl_id,
|
1999-08-11 04:21:32 +08:00
|
|
|
|
haddr_t maxaddr)
|
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file=NULL;
|
|
|
|
|
H5FD_core_fapl_t *fa=NULL;
|
2001-11-21 03:07:22 +08:00
|
|
|
|
H5P_genplist_t *plist; /* Property list pointer */
|
1999-10-15 22:53:57 +08:00
|
|
|
|
int fd=-1;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
H5FD_t *ret_value;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_open, NULL);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/* Check arguments */
|
2003-01-25 02:09:57 +08:00
|
|
|
|
if (!(H5F_ACC_CREAT & flags))
|
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_UNSUPPORTED, NULL, "must create core files, not open them");
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (0==maxaddr || HADDR_UNDEF==maxaddr)
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_BADRANGE, NULL, "bogus maxaddr");
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (ADDR_OVERFLOW(maxaddr))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_OVERFLOW, NULL, "maxaddr overflow");
|
2001-11-21 03:07:22 +08:00
|
|
|
|
if (H5P_DEFAULT!=fapl_id) {
|
|
|
|
|
if(NULL == (plist = H5I_object(fapl_id)))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_BADTYPE, NULL, "not a file access property list");
|
2001-11-21 03:07:22 +08:00
|
|
|
|
fa = H5P_get_driver_info(plist);
|
|
|
|
|
} /* end if */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
1999-10-15 22:53:57 +08:00
|
|
|
|
/* Open backing store */
|
|
|
|
|
if (fa && fa->backing_store && name &&
|
2001-11-21 03:07:22 +08:00
|
|
|
|
(fd=HDopen(name, O_CREAT|O_TRUNC|O_RDWR, 0666))<0)
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_FILE, H5E_CANTOPENFILE, NULL, "unable to open backing store");
|
1999-10-15 22:53:57 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
/* Create the new file struct */
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (NULL==(file=H5MM_calloc(sizeof(H5FD_core_t))))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, NULL, "unable to allocate file struct");
|
1999-10-15 22:53:57 +08:00
|
|
|
|
file->fd = fd;
|
2001-11-21 03:07:22 +08:00
|
|
|
|
if (name && *name)
|
1999-10-23 08:36:04 +08:00
|
|
|
|
file->name = HDstrdup(name);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* The increment comes from either the file access property list or the
|
|
|
|
|
* default value. But if the file access property list was zero then use
|
|
|
|
|
* the default value instead.
|
|
|
|
|
*/
|
2001-11-21 03:07:22 +08:00
|
|
|
|
file->increment = (fa && fa->increment>0) ? fa->increment : H5FD_CORE_INCREMENT;
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
/* Set return value */
|
|
|
|
|
ret_value=(H5FD_t *)file;
|
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_close
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Closes the file.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: 0
|
|
|
|
|
*
|
|
|
|
|
* Failure: -1
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
1999-10-15 22:53:57 +08:00
|
|
|
|
* Robb Matzke, 1999-10-19
|
|
|
|
|
* The contents of memory are written to the backing store if
|
|
|
|
|
* one is open.
|
1999-08-11 04:21:32 +08:00
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static herr_t
|
|
|
|
|
H5FD_core_close(H5FD_t *_file)
|
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
herr_t ret_value=SUCCEED; /* Return value */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_close, FAIL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
1999-10-15 22:53:57 +08:00
|
|
|
|
/* Release resources */
|
2002-08-09 00:52:55 +08:00
|
|
|
|
if (file->fd>=0)
|
|
|
|
|
HDclose(file->fd);
|
|
|
|
|
if (file->name)
|
|
|
|
|
H5MM_xfree(file->name);
|
|
|
|
|
if (file->mem)
|
|
|
|
|
H5MM_xfree(file->mem);
|
2001-01-10 05:22:30 +08:00
|
|
|
|
HDmemset(file, 0, sizeof(H5FD_core_t));
|
2000-09-27 11:46:39 +08:00
|
|
|
|
H5MM_xfree(file);
|
2002-08-09 00:52:55 +08:00
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_cmp
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Compares two files belonging to this driver by name. If one
|
|
|
|
|
* file doesn't have a name then it is less than the other file.
|
|
|
|
|
* If neither file has a name then the comparison is by file
|
|
|
|
|
* address.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: A value like strcmp()
|
|
|
|
|
*
|
|
|
|
|
* Failure: never fails (arguments were checked by the
|
|
|
|
|
* caller).
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static int
|
|
|
|
|
H5FD_core_cmp(const H5FD_t *_f1, const H5FD_t *_f2)
|
|
|
|
|
{
|
|
|
|
|
const H5FD_core_t *f1 = (const H5FD_core_t*)_f1;
|
|
|
|
|
const H5FD_core_t *f2 = (const H5FD_core_t*)_f2;
|
1999-11-01 23:21:16 +08:00
|
|
|
|
int ret_value;
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_cmp, FAIL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
if (NULL==f1->name && NULL==f2->name) {
|
2002-08-09 00:52:55 +08:00
|
|
|
|
if (f1<f2)
|
|
|
|
|
HGOTO_DONE(-1);
|
|
|
|
|
if (f1>f2)
|
|
|
|
|
HGOTO_DONE(1);
|
|
|
|
|
HGOTO_DONE(0);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
if (NULL==f1->name)
|
|
|
|
|
HGOTO_DONE(-1);
|
|
|
|
|
if (NULL==f2->name)
|
|
|
|
|
HGOTO_DONE(1);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
1999-11-01 23:21:16 +08:00
|
|
|
|
ret_value = HDstrcmp(f1->name, f2->name);
|
2002-08-09 00:52:55 +08:00
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_get_eoa
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Gets the end-of-address marker for the file. The EOA marker
|
|
|
|
|
* is the first address past the last byte allocated in the
|
|
|
|
|
* format address space.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: The end-of-address marker.
|
|
|
|
|
*
|
|
|
|
|
* Failure: HADDR_UNDEF
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Monday, August 2, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static haddr_t
|
|
|
|
|
H5FD_core_get_eoa(H5FD_t *_file)
|
|
|
|
|
{
|
2002-08-10 04:48:23 +08:00
|
|
|
|
haddr_t ret_value; /* Return value */
|
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_get_eoa, HADDR_UNDEF);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-10 04:48:23 +08:00
|
|
|
|
/* Set return value */
|
|
|
|
|
ret_value=file->eoa;
|
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_set_eoa
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Set the end-of-address marker for the file. This function is
|
|
|
|
|
* called shortly after an existing HDF5 file is opened in order
|
|
|
|
|
* to tell the driver where the end of the HDF5 data is located.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: 0
|
|
|
|
|
*
|
|
|
|
|
* Failure: -1
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static herr_t
|
|
|
|
|
H5FD_core_set_eoa(H5FD_t *_file, haddr_t addr)
|
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
herr_t ret_value=SUCCEED; /* Return value */
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_set_eoa, FAIL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
|
|
|
|
if (ADDR_OVERFLOW(addr))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_OVERFLOW, FAIL, "address overflow");
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
file->eoa = addr;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_get_eof
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Returns the end-of-file marker, which is the greater of
|
|
|
|
|
* either the size of the underlying memory or the HDF5
|
|
|
|
|
* end-of-address markers.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: End of file address, the first address past
|
|
|
|
|
* the end of the "file", either the memory
|
|
|
|
|
* or the HDF5 file.
|
|
|
|
|
*
|
|
|
|
|
* Failure: HADDR_UNDEF
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static haddr_t
|
|
|
|
|
H5FD_core_get_eof(H5FD_t *_file)
|
|
|
|
|
{
|
2002-08-10 04:48:23 +08:00
|
|
|
|
haddr_t ret_value; /* Return value */
|
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_get_eof, HADDR_UNDEF);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-10 04:48:23 +08:00
|
|
|
|
/* Set return value */
|
|
|
|
|
ret_value=MAX(file->eof, file->eoa);
|
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
2002-10-01 00:31:55 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_get_handle
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Returns the file handle of CORE file driver.
|
|
|
|
|
*
|
|
|
|
|
* Returns: Non-negative if succeed or negative if fails.
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Raymond Lu
|
|
|
|
|
* Sept. 16, 2002
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static herr_t
|
|
|
|
|
H5FD_core_get_handle(H5FD_t *_file, hid_t UNUSED fapl, void** file_handle)
|
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file = (H5FD_core_t *)_file;
|
|
|
|
|
herr_t ret_value = SUCCEED;
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_get_handle, FAIL);
|
|
|
|
|
|
|
|
|
|
if(!file_handle)
|
|
|
|
|
HGOTO_ERROR(H5E_ARGS, H5E_BADVALUE, FAIL, "file handle not valid");
|
|
|
|
|
|
|
|
|
|
*file_handle = &(file->mem);
|
|
|
|
|
|
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
2002-10-01 00:31:55 +08:00
|
|
|
|
}
|
2002-10-01 05:51:05 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_read
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Reads SIZE bytes of data from FILE beginning at address ADDR
|
|
|
|
|
* into buffer BUF according to data transfer properties in
|
|
|
|
|
* DXPL_ID.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: Zero. Result is stored in caller-supplied
|
|
|
|
|
* buffer BUF.
|
|
|
|
|
*
|
|
|
|
|
* Failure: -1, Contents of buffer BUF are undefined.
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static herr_t
|
2000-10-25 02:18:09 +08:00
|
|
|
|
H5FD_core_read(H5FD_t *_file, H5FD_mem_t UNUSED type, hid_t UNUSED dxpl_id, haddr_t addr,
|
2001-07-11 05:19:18 +08:00
|
|
|
|
size_t size, void *buf/*out*/)
|
1999-08-11 04:21:32 +08:00
|
|
|
|
{
|
2000-08-05 04:49:59 +08:00
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
herr_t ret_value=SUCCEED; /* Return value */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_read, FAIL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
assert(file && file->pub.cls);
|
|
|
|
|
assert(buf);
|
|
|
|
|
|
|
|
|
|
/* Check for overflow conditions */
|
2000-08-05 04:49:59 +08:00
|
|
|
|
if (HADDR_UNDEF == addr)
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_OVERFLOW, FAIL, "file address overflowed");
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (REGION_OVERFLOW(addr, size))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_OVERFLOW, FAIL, "file address overflowed");
|
2000-08-05 04:49:59 +08:00
|
|
|
|
if (addr + size > file->eoa)
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_OVERFLOW, FAIL, "file address overflowed");
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/* Read the part which is before the EOF marker */
|
2000-08-05 04:49:59 +08:00
|
|
|
|
if (addr < file->eof) {
|
2001-11-28 00:29:13 +08:00
|
|
|
|
size_t nbytes;
|
|
|
|
|
#ifndef NDEBUG
|
|
|
|
|
hsize_t temp_nbytes;
|
|
|
|
|
|
|
|
|
|
temp_nbytes = file->eof-addr;
|
|
|
|
|
H5_CHECK_OVERFLOW(temp_nbytes,hsize_t,size_t);
|
|
|
|
|
nbytes = MIN(size,(size_t)temp_nbytes);
|
|
|
|
|
#else /* NDEBUG */
|
|
|
|
|
nbytes = MIN(size,(size_t)(file->eof-addr));
|
|
|
|
|
#endif /* NDEBUG */
|
2000-08-05 04:49:59 +08:00
|
|
|
|
|
2001-07-11 05:19:18 +08:00
|
|
|
|
HDmemcpy(buf, file->mem + addr, nbytes);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
size -= nbytes;
|
|
|
|
|
addr += nbytes;
|
2000-08-05 04:49:59 +08:00
|
|
|
|
buf = (char *)buf + nbytes;
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Read zeros for the part which is after the EOF markers */
|
2002-08-09 00:52:55 +08:00
|
|
|
|
if (size > 0)
|
2001-07-11 05:19:18 +08:00
|
|
|
|
HDmemset(buf, 0, size);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_write
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Writes SIZE bytes of data to FILE beginning at address ADDR
|
|
|
|
|
* from buffer BUF according to data transfer properties in
|
|
|
|
|
* DXPL_ID.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: Zero
|
|
|
|
|
*
|
|
|
|
|
* Failure: -1
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Thursday, July 29, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static herr_t
|
2000-09-01 03:33:58 +08:00
|
|
|
|
H5FD_core_write(H5FD_t *_file, H5FD_mem_t UNUSED type, hid_t UNUSED dxpl_id, haddr_t addr,
|
2001-07-11 05:19:18 +08:00
|
|
|
|
size_t size, const void *buf)
|
1999-08-11 04:21:32 +08:00
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
2002-08-09 00:52:55 +08:00
|
|
|
|
herr_t ret_value=SUCCEED; /* Return value */
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
2002-05-29 23:07:55 +08:00
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_write, FAIL);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
1999-08-11 04:21:32 +08:00
|
|
|
|
assert(file && file->pub.cls);
|
|
|
|
|
assert(buf);
|
|
|
|
|
|
|
|
|
|
/* Check for overflow conditions */
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (REGION_OVERFLOW(addr, size))
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_OVERFLOW, FAIL, "file address overflowed");
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (addr+size>file->eoa)
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_OVERFLOW, FAIL, "file address overflowed");
|
1999-08-11 04:21:32 +08:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Allocate more memory if necessary, careful of overflow. Also, if the
|
|
|
|
|
* allocation fails then the file should remain in a usable state. Be
|
|
|
|
|
* careful of non-Posix realloc() that doesn't understand what to do when
|
|
|
|
|
* the first argument is null.
|
|
|
|
|
*/
|
|
|
|
|
if (addr+size>file->eof) {
|
1999-10-23 08:36:04 +08:00
|
|
|
|
unsigned char *x;
|
2001-11-28 00:29:13 +08:00
|
|
|
|
size_t new_eof;
|
|
|
|
|
|
|
|
|
|
H5_ASSIGN_OVERFLOW(new_eof,file->increment*((addr+size)/file->increment),hsize_t,size_t);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2001-07-11 05:19:18 +08:00
|
|
|
|
if ((addr+size) % file->increment)
|
|
|
|
|
new_eof += file->increment;
|
|
|
|
|
if (NULL==file->mem)
|
|
|
|
|
x = H5MM_malloc(new_eof);
|
|
|
|
|
else
|
|
|
|
|
x = H5MM_realloc(file->mem, new_eof);
|
1999-10-23 08:36:04 +08:00
|
|
|
|
if (!x)
|
2002-08-09 00:52:55 +08:00
|
|
|
|
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "unable to allocate memory block");
|
1999-10-23 08:36:04 +08:00
|
|
|
|
file->mem = x;
|
|
|
|
|
file->eof = new_eof;
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Write from BUF to memory */
|
2001-07-11 05:19:18 +08:00
|
|
|
|
HDmemcpy(file->mem+addr, buf, size);
|
1999-10-15 22:53:57 +08:00
|
|
|
|
file->dirty = TRUE;
|
1999-10-23 08:36:04 +08:00
|
|
|
|
|
2002-08-09 00:52:55 +08:00
|
|
|
|
done:
|
2003-01-11 04:26:02 +08:00
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
1999-08-11 04:21:32 +08:00
|
|
|
|
}
|
2003-02-11 01:26:09 +08:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
|
* Function: H5FD_core_flush
|
|
|
|
|
*
|
|
|
|
|
* Purpose: Flushes the file to backing store if there is any and if the
|
|
|
|
|
* dirty flag is set.
|
|
|
|
|
*
|
|
|
|
|
* Return: Success: 0
|
|
|
|
|
*
|
|
|
|
|
* Failure: -1
|
|
|
|
|
*
|
|
|
|
|
* Programmer: Robb Matzke
|
|
|
|
|
* Friday, October 15, 1999
|
|
|
|
|
*
|
|
|
|
|
* Modifications:
|
|
|
|
|
*
|
|
|
|
|
*-------------------------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
static herr_t
|
2003-02-13 01:04:40 +08:00
|
|
|
|
H5FD_core_flush(H5FD_t *_file, hid_t UNUSED dxpl_id, unsigned UNUSED closing)
|
2003-02-11 01:26:09 +08:00
|
|
|
|
{
|
|
|
|
|
H5FD_core_t *file = (H5FD_core_t*)_file;
|
|
|
|
|
herr_t ret_value=SUCCEED; /* Return value */
|
|
|
|
|
|
|
|
|
|
FUNC_ENTER_NOAPI(H5FD_core_flush, FAIL);
|
|
|
|
|
|
|
|
|
|
/* Write to backing store */
|
|
|
|
|
if (file->dirty && file->fd>=0) {
|
|
|
|
|
haddr_t size = file->eof;
|
|
|
|
|
unsigned char *ptr = file->mem;
|
|
|
|
|
|
|
|
|
|
if (0!=HDlseek(file->fd, (off_t)0, SEEK_SET))
|
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_SEEKERROR, FAIL, "error seeking in backing store");
|
|
|
|
|
|
|
|
|
|
while (size) {
|
|
|
|
|
ssize_t n;
|
|
|
|
|
|
|
|
|
|
H5_CHECK_OVERFLOW(size,hsize_t,size_t);
|
|
|
|
|
n = HDwrite(file->fd, ptr, (size_t)size);
|
|
|
|
|
if (n<0 && EINTR==errno)
|
|
|
|
|
continue;
|
|
|
|
|
if (n<0)
|
|
|
|
|
HGOTO_ERROR(H5E_IO, H5E_WRITEERROR, FAIL, "error writing backing store");
|
|
|
|
|
ptr += (size_t)n;
|
|
|
|
|
size -= (size_t)n;
|
|
|
|
|
}
|
|
|
|
|
file->dirty = FALSE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
done:
|
|
|
|
|
FUNC_LEAVE_NOAPI(ret_value);
|
|
|
|
|
}
|
|
|
|
|
|