#include "db_config.h"
#include "db_int.h"
int
__db_file_extend(dbenv, fhp, size)
DB_ENV *dbenv;
DB_FH *fhp;
size_t size;
{
db_pgno_t pages;
size_t nw;
u_int32_t relative;
int ret;
char *buf;
#undef FILE_EXTEND_IO_SIZE
#define FILE_EXTEND_IO_SIZE (8 * 1024)
if ((ret = __os_calloc(dbenv, FILE_EXTEND_IO_SIZE, 1, &buf)) != 0)
return (ret);
pages = (db_pgno_t)((size - FILE_EXTEND_IO_SIZE) / MEGABYTE);
relative = (u_int32_t)((size - FILE_EXTEND_IO_SIZE) % MEGABYTE);
if ((ret = __os_seek(dbenv, fhp, pages, MEGABYTE, relative)) != 0)
goto err;
if ((ret = __os_write(dbenv, fhp, buf, FILE_EXTEND_IO_SIZE, &nw)) != 0)
goto err;
err: __os_free(dbenv, buf);
return (0);
}
int
__db_file_multi_write(dbenv, path)
DB_ENV *dbenv;
const char *path;
{
DB_FH *fhp;
u_int32_t mbytes, bytes;
int ret;
if ((ret = __os_open(dbenv, path, 0, DB_OSO_REGION, 0, &fhp)) == 0 &&
(ret = __os_ioinfo(dbenv, path, fhp, &mbytes, &bytes, NULL)) == 0) {
if ((ret =
__db_file_write(dbenv, fhp, mbytes, bytes, 255)) != 0)
goto err;
if ((ret =
__db_file_write(dbenv, fhp, mbytes, bytes, 0)) != 0)
goto err;
if ((ret =
__db_file_write(dbenv, fhp, mbytes, bytes, 255)) != 0)
goto err;
} else
__db_err(dbenv, ret, "%s", path);
err: if (fhp != NULL)
(void)__os_closehandle(dbenv, fhp);
return (ret);
}
int
__db_file_write(dbenv, fhp, mbytes, bytes, pattern)
DB_ENV *dbenv;
DB_FH *fhp;
int pattern;
u_int32_t mbytes, bytes;
{
size_t len, nw;
int i, ret;
char *buf;
#undef FILE_WRITE_IO_SIZE
#define FILE_WRITE_IO_SIZE (64 * 1024)
if ((ret = __os_malloc(dbenv, FILE_WRITE_IO_SIZE, &buf)) != 0)
return (ret);
memset(buf, pattern, FILE_WRITE_IO_SIZE);
if ((ret = __os_seek(dbenv, fhp, 0, 0, 0)) != 0)
goto err;
for (; mbytes > 0; --mbytes)
for (i = MEGABYTE / FILE_WRITE_IO_SIZE; i > 0; --i)
if ((ret = __os_write(
dbenv, fhp, buf, FILE_WRITE_IO_SIZE, &nw)) != 0)
goto err;
for (; bytes > 0; bytes -= (u_int32_t)len) {
len = bytes < FILE_WRITE_IO_SIZE ? bytes : FILE_WRITE_IO_SIZE;
if ((ret = __os_write(dbenv, fhp, buf, len, &nw)) != 0)
goto err;
}
ret = __os_fsync(dbenv, fhp);
err: __os_free(dbenv, buf);
return (ret);
}