#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: env_file.c,v 1.2 2004/03/30 01:23:16 jtownsen Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <string.h>
#endif
#include "db_int.h"
static int __db_overwrite_pass __P((DB_ENV *,
const char *, DB_FH *, u_int32_t, u_int32_t, int));
int
__db_fileinit(dbenv, fhp, size, zerofill)
DB_ENV *dbenv;
DB_FH *fhp;
size_t size;
int zerofill;
{
db_pgno_t pages;
size_t i;
size_t nw;
u_int32_t relative;
int ret;
char buf[OS_VMPAGESIZE];
memset(buf, 0, sizeof(buf));
if ((ret = __os_seek(dbenv, fhp, 0, 0, 0, 0, DB_OS_SEEK_END)) != 0)
return (ret);
pages = (db_pgno_t)((size - OS_VMPAGESIZE) / MEGABYTE);
relative = (u_int32_t)((size - OS_VMPAGESIZE) % MEGABYTE);
if ((ret = __os_seek(dbenv,
fhp, MEGABYTE, pages, relative, 0, DB_OS_SEEK_CUR)) != 0)
return (ret);
if ((ret = __os_write(dbenv, fhp, buf, sizeof(buf), &nw)) != 0)
return (ret);
if (zerofill) {
pages = (db_pgno_t)(size / MEGABYTE);
relative = (u_int32_t)(size % MEGABYTE);
if ((ret = __os_seek(dbenv, fhp,
MEGABYTE, pages, relative, 1, DB_OS_SEEK_END)) != 0)
return (ret);
for (i = 0; i < size; i += OS_VMPAGESIZE) {
if ((ret = __os_write(dbenv, fhp, buf, 1, &nw)) != 0)
return (ret);
if ((ret = __os_seek(dbenv, fhp,
0, 0, OS_VMPAGESIZE - 1, 0, DB_OS_SEEK_CUR)) != 0)
return (ret);
}
}
return (0);
}
int
__db_overwrite(dbenv, path)
DB_ENV *dbenv;
const char *path;
{
DB_FH *fhp;
u_int32_t mbytes, bytes;
int ret;
if ((ret = __os_open(dbenv, path, DB_OSO_REGION, 0, &fhp)) == 0 &&
(ret = __os_ioinfo(dbenv, path, fhp, &mbytes, &bytes, NULL)) == 0) {
if ((ret = __db_overwrite_pass(
dbenv, path, fhp, mbytes, bytes, 255)) != 0)
goto err;
if ((ret = __db_overwrite_pass(
dbenv, path, fhp, mbytes, bytes, 0)) != 0)
goto err;
if ((ret = __db_overwrite_pass(
dbenv, path, fhp, mbytes, bytes, 255)) != 0)
goto err;
} else
__db_err(dbenv, "%s: %s", path, db_strerror(ret));
err: if (fhp != NULL)
(void)__os_closehandle(dbenv, fhp);
return (ret);
}
static int
__db_overwrite_pass(dbenv, path, fhp, mbytes, bytes, pattern)
DB_ENV *dbenv;
const char *path;
DB_FH *fhp;
int pattern;
u_int32_t mbytes, bytes;
{
size_t len, nw;
int i, ret;
char buf[8 * 1024];
if ((ret = __os_seek(dbenv, fhp, 0, 0, 0, 0, DB_OS_SEEK_SET)) != 0)
goto err;
memset(buf, pattern, sizeof(buf));
for (; mbytes > 0; --mbytes)
for (i = MEGABYTE / sizeof(buf); i > 0; --i)
if ((ret =
__os_write(dbenv, fhp, buf, sizeof(buf), &nw)) != 0)
goto err;
for (; bytes > 0; bytes -= (u_int32_t)len) {
len = bytes < sizeof(buf) ? bytes : sizeof(buf);
if ((ret = __os_write(dbenv, fhp, buf, len, &nw)) != 0)
goto err;
}
if ((ret = __os_fsync(dbenv, fhp)) != 0)
err: __db_err(dbenv, "%s: %s", path, db_strerror(ret));
return (ret);
}