#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: os_open.c,v 1.2 2004/03/30 01:23:48 jtownsen Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <fcntl.h>
#include <signal.h>
#include <string.h>
#include <unistd.h>
#endif
#include "db_int.h"
int
__os_have_direct()
{
return (1);
}
__os_open(dbenv, name, flags, mode, fhpp)
DB_ENV *dbenv;
const char *name;
u_int32_t flags;
int mode;
DB_FH **fhpp;
{
return (__os_open_extend(dbenv, name, 0, 0, flags, mode, fhpp));
}
int
__os_open_extend(dbenv, name, log_size, page_size, flags, mode, fhpp)
DB_ENV *dbenv;
const char *name;
u_int32_t log_size, page_size, flags;
int mode;
DB_FH **fhpp;
{
DB_FH *fhp;
DWORD bytesWritten;
DWORD cluster_size, sector_size, free_clusters, total_clusters;
int access, attr, createflag, nrepeat, oflags, ret, share;
char *drive, dbuf[4];
*fhpp = NULL;
#define OKFLAGS \
(DB_OSO_CREATE | DB_OSO_DIRECT | DB_OSO_EXCL | DB_OSO_LOG | \
DB_OSO_RDONLY | DB_OSO_REGION | DB_OSO_SEQ | DB_OSO_TEMP | \
DB_OSO_TRUNC)
if ((ret = __db_fchk(dbenv, "__os_open", flags, OKFLAGS)) != 0)
return (ret);
if (DB_GLOBAL(j_open) != NULL) {
oflags = O_BINARY | O_NOINHERIT;
if (LF_ISSET(DB_OSO_CREATE))
oflags |= O_CREAT;
if (LF_ISSET(DB_OSO_EXCL))
oflags |= O_EXCL;
if (LF_ISSET(DB_OSO_RDONLY))
oflags |= O_RDONLY;
else
oflags |= O_RDWR;
if (LF_ISSET(DB_OSO_SEQ))
oflags |= _O_SEQUENTIAL;
else
oflags |= _O_RANDOM;
if (LF_ISSET(DB_OSO_TEMP))
oflags |= _O_TEMPORARY;
if (LF_ISSET(DB_OSO_TRUNC))
oflags |= O_TRUNC;
return (__os_openhandle(dbenv, name, oflags, mode, fhpp));
}
if ((ret = __os_calloc(dbenv, 1, sizeof(DB_FH), fhpp)) != 0)
return (ret);
fhp = *fhpp;
access = GENERIC_READ;
if (!LF_ISSET(DB_OSO_RDONLY))
access |= GENERIC_WRITE;
share = FILE_SHARE_READ | FILE_SHARE_WRITE;
attr = FILE_ATTRIBUTE_NORMAL;
if (LF_ISSET(DB_OSO_CREATE) && LF_ISSET(DB_OSO_EXCL))
createflag = CREATE_NEW;
else if (!LF_ISSET(DB_OSO_CREATE) && LF_ISSET(DB_OSO_TRUNC))
createflag = TRUNCATE_EXISTING;
else if (LF_ISSET(DB_OSO_TRUNC))
createflag = CREATE_ALWAYS;
else if (LF_ISSET(DB_OSO_CREATE))
createflag = OPEN_ALWAYS;
else
createflag = OPEN_EXISTING;
if (LF_ISSET(DB_OSO_LOG)) {
F_SET(fhp, DB_FH_NOSYNC);
attr |= FILE_FLAG_WRITE_THROUGH;
}
if (LF_ISSET(DB_OSO_SEQ))
attr |= FILE_FLAG_SEQUENTIAL_SCAN;
else
attr |= FILE_FLAG_RANDOM_ACCESS;
if (LF_ISSET(DB_OSO_TEMP))
attr |= FILE_FLAG_DELETE_ON_CLOSE;
if (LF_ISSET(DB_OSO_DIRECT) && page_size != 0 && name[0] != '\0') {
if (name[1] == ':') {
drive = dbuf;
snprintf(dbuf, sizeof(dbuf), "%c:\\", name[0]);
} else
drive = NULL;
if (GetDiskFreeSpace(drive, &cluster_size,
§or_size, &free_clusters, &total_clusters) &&
page_size % sector_size == 0)
attr |= FILE_FLAG_NO_BUFFERING;
}
for (nrepeat = 1;; ++nrepeat) {
fhp->handle =
CreateFile(name, access, share, NULL, createflag, attr, 0);
if (fhp->handle == INVALID_HANDLE_VALUE) {
ret = __os_win32_errno();
if ((ret != ENFILE && ret != EMFILE && ret != ENOSPC) ||
nrepeat > 3)
goto err;
(void)__os_sleep(dbenv, nrepeat * 2, 0);
} else
break;
}
F_SET(fhp, DB_FH_OPENED);
if (LF_ISSET(DB_OSO_LOG) && log_size != 0 && __os_is_winnt()) {
if (SetFilePointer(fhp->handle,
log_size - 1, NULL, FILE_BEGIN) == (DWORD)-1)
goto err;
if (WriteFile(fhp->handle, "\x00", 1, &bytesWritten, NULL) == 0)
goto err;
if (bytesWritten != 1)
goto err;
if (SetEndOfFile(fhp->handle) == 0)
goto err;
if (SetFilePointer(
fhp->handle, 0, NULL, FILE_BEGIN) == (DWORD)-1)
goto err;
if (FlushFileBuffers(fhp->handle) == 0)
goto err;
}
return (0);
err: if (ret == 0)
ret = __os_win32_errno();
__os_closehandle(dbenv, fhp);
*fhpp = NULL;
return (ret);
}