#include "db_config.h"
#include "db_int.h"
static int __os_map
__P((DB_ENV *, char *, REGINFO *, DB_FH *, size_t, int, int, int, void **));
static int __os_unique_name __P((_TCHAR *, HANDLE, _TCHAR *, size_t));
int
__os_r_sysattach(dbenv, infop, rp)
DB_ENV *dbenv;
REGINFO *infop;
REGION *rp;
{
DB_FH *fhp;
int ret;
if (!F_ISSET(dbenv, DB_ENV_PRIVATE) && __os_is_winnt() == 0) {
__db_err(dbenv,
EINVAL, "Windows 9X systems must specify DB_PRIVATE");
return (EINVAL);
}
if ((ret = __os_open(dbenv, infop->name, 0, DB_OSO_REGION |
(F_ISSET(infop, REGION_CREATE_OK) ? DB_OSO_CREATE : 0),
dbenv->db_mode, &fhp)) != 0) {
__db_err(dbenv, ret, "%s", infop->name);
return (ret);
}
ret = __os_map(dbenv, infop->name, infop, fhp, rp->size,
1, F_ISSET(dbenv, DB_ENV_SYSTEM_MEM), 0, &infop->addr);
if (ret == 0 && F_ISSET(dbenv, DB_ENV_SYSTEM_MEM))
rp->segid = 1;
(void)__os_closehandle(dbenv, fhp);
return (ret);
}
int
__os_r_sysdetach(dbenv, infop, destroy)
DB_ENV *dbenv;
REGINFO *infop;
int destroy;
{
int ret, t_ret;
if (infop->wnt_handle != NULL) {
(void)CloseHandle(infop->wnt_handle);
infop->wnt_handle = NULL;
}
ret = !UnmapViewOfFile(infop->addr) ? __os_get_syserr() : 0;
if (ret != 0) {
__db_syserr(dbenv, ret, "UnmapViewOfFile");
ret = __os_posix_err(ret);
}
if (!F_ISSET(dbenv, DB_ENV_SYSTEM_MEM) && destroy) {
if (F_ISSET(dbenv, DB_ENV_OVERWRITE))
(void)__db_file_multi_write(dbenv, infop->name);
if ((t_ret = __os_unlink(dbenv, infop->name)) != 0 && ret == 0)
ret = t_ret;
}
return (ret);
}
int
__os_mapfile(dbenv, path, fhp, len, is_rdonly, addr)
DB_ENV *dbenv;
char *path;
DB_FH *fhp;
int is_rdonly;
size_t len;
void **addr;
{
if (dbenv != NULL &&
FLD_ISSET(dbenv->verbose, DB_VERB_FILEOPS | DB_VERB_FILEOPS_ALL))
__db_msg(dbenv, "fileops: mmap %s", path);
return (__os_map(dbenv, path, NULL, fhp, len, 0, 0, is_rdonly, addr));
}
int
__os_unmapfile(dbenv, addr, len)
DB_ENV *dbenv;
void *addr;
size_t len;
{
if (dbenv != NULL &&
FLD_ISSET(dbenv->verbose, DB_VERB_FILEOPS | DB_VERB_FILEOPS_ALL))
__db_msg(dbenv, "fileops: munmap");
return (!UnmapViewOfFile(addr) ? __os_posix_err(__os_get_syserr()) : 0);
}
static int
__os_unique_name(orig_path, hfile, result_path, result_path_len)
_TCHAR *orig_path, *result_path;
HANDLE hfile;
size_t result_path_len;
{
BY_HANDLE_FILE_INFORMATION fileinfo;
_TCHAR *basename, *p;
basename = _tcsrchr(orig_path, '/');
p = _tcsrchr(orig_path, '\\');
if (basename == NULL || (p != NULL && p > basename))
basename = p;
if (basename == NULL)
basename = _tcsrchr(orig_path, ':');
if (basename == NULL)
basename = orig_path;
else
basename++;
if (!GetFileInformationByHandle(hfile, &fileinfo))
return (__os_posix_err(__os_get_syserr()));
(void)_sntprintf(result_path, result_path_len,
_T("__db_shmem.%8.8lx.%8.8lx.%8.8lx.%8.8lx.%8.8lx.%s"),
fileinfo.dwVolumeSerialNumber,
fileinfo.nFileIndexHigh,
fileinfo.nFileIndexLow,
fileinfo.ftCreationTime.dwHighDateTime,
fileinfo.ftCreationTime.dwHighDateTime,
basename);
return (0);
}
static int
__os_map(dbenv, path, infop, fhp, len, is_region, is_system, is_rdonly, addr)
DB_ENV *dbenv;
REGINFO *infop;
char *path;
DB_FH *fhp;
int is_region, is_system, is_rdonly;
size_t len;
void **addr;
{
HANDLE hMemory;
int ret, use_pagefile;
_TCHAR *tpath, shmem_name[DB_MAXPATHLEN];
void *pMemory;
unsigned __int64 len64;
ret = 0;
if (infop != NULL)
infop->wnt_handle = NULL;
len64 = len;
use_pagefile = is_region && is_system;
if (use_pagefile) {
#ifdef DB_WINCE
__db_errx(dbenv, "Unable to memory map regions using system "
"memory on WinCE.");
return (EFAULT);
#endif
TO_TSTRING(dbenv, path, tpath, ret);
if (ret != 0)
return (ret);
ret = __os_unique_name(tpath, fhp->handle,
shmem_name, sizeof(shmem_name));
FREE_STRING(dbenv, tpath);
if (ret != 0)
return (ret);
}
hMemory = NULL;
if (use_pagefile) {
#ifndef DB_WINCE
hMemory = OpenFileMapping(
is_rdonly ? FILE_MAP_READ : FILE_MAP_ALL_ACCESS,
0, shmem_name);
if (hMemory == NULL && F_ISSET(infop, REGION_CREATE_OK))
hMemory = CreateFileMapping((HANDLE)-1, 0,
is_rdonly ? PAGE_READONLY : PAGE_READWRITE,
(DWORD)(len64 >> 32), (DWORD)len64, shmem_name);
#endif
} else {
hMemory = CreateFileMapping(fhp->handle, 0,
is_rdonly ? PAGE_READONLY : PAGE_READWRITE,
(DWORD)(len64 >> 32), (DWORD)len64, NULL);
#ifdef DB_WINCE
fhp->handle = INVALID_HANDLE_VALUE;
F_CLR(fhp, DB_FH_OPENED);
#endif
}
if (hMemory == NULL) {
ret = __os_get_syserr();
__db_syserr(dbenv, ret, "OpenFileMapping");
return (__db_panic(dbenv, __os_posix_err(ret)));
}
pMemory = MapViewOfFile(hMemory,
(is_rdonly ? FILE_MAP_READ : FILE_MAP_ALL_ACCESS), 0, 0, len);
if (pMemory == NULL) {
ret = __os_get_syserr();
__db_syserr(dbenv, ret, "MapViewOfFile");
return (__db_panic(dbenv, __os_posix_err(ret)));
}
if (use_pagefile && infop != NULL)
infop->wnt_handle = hMemory;
else
CloseHandle(hMemory);
*addr = pMemory;
return (ret);
}