#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: os_open.c,v 1.1.1.1 2003/02/15 04:56:09 zarzycki Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <fcntl.h>
#include <string.h>
#endif
#include "db_int.h"
#ifdef HAVE_QNX
static int __os_region_open __P((DB_ENV *, const char *, int, int, DB_FH *));
#endif
int
__os_open(dbenv, name, flags, mode, fhp)
DB_ENV *dbenv;
const char *name;
u_int32_t flags;
int mode;
DB_FH *fhp;
{
int oflags, ret;
oflags = 0;
#ifdef DIAGNOSTIC
#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);
#endif
#if defined(O_BINARY)
oflags |= O_BINARY;
#endif
if (LF_ISSET(DB_OSO_CREATE))
oflags |= O_CREAT;
if (LF_ISSET(DB_OSO_EXCL))
oflags |= O_EXCL;
#if defined(O_DSYNC) && defined(XXX_NEVER_SET)
if (LF_ISSET(DB_OSO_LOG))
oflags |= O_DSYNC;
#endif
if (LF_ISSET(DB_OSO_RDONLY))
oflags |= O_RDONLY;
else
oflags |= O_RDWR;
if (LF_ISSET(DB_OSO_TRUNC))
oflags |= O_TRUNC;
#ifdef HAVE_O_DIRECT
if (LF_ISSET(DB_OSO_DIRECT))
oflags |= O_DIRECT;
#endif
#ifdef HAVE_QNX
if (LF_ISSET(DB_OSO_REGION))
return (__os_region_open(dbenv, name, oflags, mode, fhp));
#endif
if ((ret = __os_openhandle(dbenv, name, oflags, mode, fhp)) != 0)
return (ret);
#ifdef HAVE_DIRECTIO
if (LF_ISSET(DB_OSO_DIRECT))
(void)directio(fhp->fd, DIRECTIO_ON);
#endif
if (LF_ISSET(DB_OSO_TEMP)) {
#if defined(HAVE_UNLINK_WITH_OPEN_FAILURE) || defined(CONFIG_TEST)
if ((ret = __os_strdup(dbenv, name, &fhp->name)) != 0) {
(void)__os_closehandle(dbenv, fhp);
(void)__os_unlink(dbenv, name);
return (ret);
}
F_SET(fhp, DB_FH_UNLINK);
#else
(void)__os_unlink(dbenv, name);
#endif
}
return (0);
}
#ifdef HAVE_QNX
static int
__os_region_open(dbenv, name, oflags, mode, fhp)
DB_ENV *dbenv;
const char *name;
int oflags;
int mode;
DB_FH *fhp;
{
int ret;
char *newname;
if ((ret = __os_shmname(dbenv, name, &newname)) != 0)
goto err;
memset(fhp, 0, sizeof(*fhp));
fhp->fd = shm_open(newname, oflags, mode);
if (fhp->fd == -1)
ret = __os_get_errno();
else {
#ifdef HAVE_FCNTL_F_SETFD
if (fcntl(fhp->fd, F_SETFD, 1) == -1) {
ret = __os_get_errno();
__db_err(dbenv, "fcntl(F_SETFD): %s", strerror(ret));
__os_closehandle(dbenv, fhp);
} else
#endif
F_SET(fhp, DB_FH_VALID);
}
err:
if (newname != NULL)
__os_free(dbenv, newname);
return (ret);
}
int
__os_shmname(dbenv, name, newnamep)
DB_ENV *dbenv;
const char *name;
char **newnamep;
{
int ret;
size_t size;
char *p, *q, *tmpname;
*newnamep = NULL;
if ((ret = __os_strdup(dbenv, name, &tmpname)) != 0)
return (ret);
p = __db_rpath(tmpname);
if (p == NULL)
return (EINVAL);
if (p != tmpname) {
*p = '\0';
q = p;
p = __db_rpath(tmpname);
*q = ':';
}
if (p != NULL) {
ret = __os_strdup(dbenv, p, newnamep);
__os_free(dbenv, tmpname);
return (ret);
}
size = strlen(tmpname) + 2;
if ((ret = __os_malloc(dbenv, size, &p)) != 0)
return (ret);
p[0] = '/';
memcpy(&p[1], tmpname, size-1);
__os_free(dbenv, tmpname);
*newnamep = p;
return (0);
}
#endif