/*
* Copyright 2006, Sine Nomine Associates and others.
* All Rights Reserved.
- *
+ *
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
* have been written so that it will be very simple to go
* back to standard I/O for just those poorly written platforms
*/
-#ifndef _WIN32
-#define FS_STATE_USE_MMAP
+#ifndef AFS_NT40_ENV
+#define FS_STATE_USE_MMAP 1
#endif
#ifdef FS_STATE_USE_MMAP
#define FS_STATE_INIT_FILESIZE (8 * 1024 * 1024) /* truncate to 8MB initially */
+#ifndef AFS_NT40_ENV
#include <sys/mman.h>
#endif
+#endif
static int fs_stateCreateDump(struct fs_dump_state * state);
static int fs_stateLoadDump(struct fs_dump_state * state);
extern afsUUID FS_HostUUID;
extern char cml_version_number[];
+int
+fs_stateFileOpen(struct fs_dump_state *state)
+{
+#ifdef AFS_NT40_ENV
+ return(state->fd != -1);
+#else
+ return(state->fd >= 0);
+#endif
+}
+
+
/*
* demand attach fs
- * save all fileserver state
+ * save all fileserver state
*/
int
fs_stateSave(void)
struct fs_dump_state state;
/* save and restore need to be atomic wrt other host package operations */
- H_LOCK;
+ H_LOCK;
ViceLog(0, ("fs_stateSave: commencing fileserver state dump\n"));
if (fs_stateCommitDump(&state)) {
ViceLog(0, ("fs_stateSave: error: dump commit failed\n"));
- ret = 1;
+ ret = 1;
goto done;
}
state.fn));
}
- done:
- if (state.fd >= 0)
+ done:
+ if (fs_stateFileOpen(&state))
fs_stateCloseDump(&state);
fs_stateFree(&state);
H_UNLOCK;
renamefile(state->fn, savedump);
}
- if (((fd = afs_open(state->fn,
- O_RDWR | O_CREAT | O_TRUNC,
+ if (((fd = afs_open(state->fn,
+ O_RDWR | O_CREAT | O_TRUNC,
S_IRUSR | S_IWUSR)) == -1) ||
(afs_fstat(fd, &status) == -1)) {
ViceLog(0, ("fs_stateCreateDump: failed to create state dump file '%s'\n",
}
#endif
- /* ensure that all pending data I/Os for the state file have been committed
+ /* ensure that all pending data I/Os for the state file have been committed
* _before_ we make the metadata I/Os */
if (fs_stateSync(state)) {
ViceLog(0, ("fs_stateCommitDump: failed to sync changes to disk\n"));
/* XXX madvise may not exist on all platforms, so
* we may need to add some ifdefs at some point... */
{
- madvise((((char *)state->mmap.map) + sizeof(struct fs_state_header)),
- state->mmap.size - sizeof(struct fs_state_header),
+ madvise((((char *)state->mmap.map) + sizeof(struct fs_state_header)),
+ state->mmap.size - sizeof(struct fs_state_header),
MADV_DONTNEED);
}
#endif
goto done;
}
}
-
+
memcpy(state->mmap.cursor, buf, len);
fs_stateIncCursor(state, len);
#else
fs_stateIncCursor(state, iov[i].iov_len);
}
#else
+#ifndef AFS_NT40_ENV
if (writev(state->fd, iov, niov) != len) {
ViceLog(0, ("fs_stateWriteV: write failed\n"));
ret = 1;
goto done;
}
+#else /* AFS_NT40_ENV */
+ for (i=0; i < niov; i++) {
+ if (write(state->fd, iov[i].iov_base, iov[i].iov_len) != iov[i].iov_len) {
+ ViceLog(0, ("fs_stateWriteV: write failed\n"));
+ ret = 1;
+ goto done;
+ }
+ }
+#endif /* AFS_NT40_ENV */
#endif
done:
fs_stateIncCursor(state, iov[i].iov_len);
}
#else
+#ifndef AFS_NT40_ENV
if (readv(state->fd, iov, niov) != len) {
ViceLog(0, ("fs_stateReadV: read failed\n"));
ret = 1;
goto done;
}
+#else
+ for (i=0; i < niov; i++) {
+ if (read(state->fd, iov[i].iov_base, iov[i].iov_len) != iov[i].iov_len) {
+ ViceLog(0, ("fs_stateReadV: read failed\n"));
+ ret = 1;
+ goto done;
+ }
+ }
+#endif /* AFS_NT40_ENV */
#endif
done:
int ret = 0;
afs_foff_t inc;
-#ifdef FS_STATE_USE_MMAP
fs_stateUnmapFile(state);
-#endif
inc = ((min_add / FS_STATE_INIT_FILESIZE)+1) * FS_STATE_INIT_FILESIZE;
state->file_len += inc;
goto done;
}
-#ifdef FS_STATE_USE_MMAP
if (fs_stateMapFile(state)) {
ViceLog(0, ("fs_stateResizeFile: remapping memory mapped file failed\n"));
ret = 1;
goto done;
}
-#endif
done:
return ret;
{
int ret = 0;
-#ifdef AFS_LARGEFILE_ENV
if (afs_ftruncate(state->fd, state->eof_offset) != 0) {
ret = 1;
}
-#else
- afs_uint32 hi, lo;
- SplitInt64(state->eof_offset, hi, lo);
- if (afs_ftruncate(state->fd, lo) != 0) {
- ret = 1;
- }
-#endif
return ret;
}
-#endif
-#ifdef FS_STATE_USE_MMAP
static int
fs_stateMapFile(struct fs_dump_state * state)
{
return 1;
}
- state->mmap.map = afs_mmap(NULL,
- state->file_len,
- flags,
+ state->mmap.map = afs_mmap(NULL,
+ state->file_len,
+ flags,
MAP_SHARED,
- state->fd,
+ state->fd,
0);
if (state->mmap.map == MAP_FAILED) {
done:
return ret;
}
-#endif /* FS_STATE_USE_MMAP */
-#ifdef FS_STATE_USE_MMAP
int
fs_stateSync(struct fs_dump_state * state)
{
msync(state->mmap.map, state->mmap.size, MS_SYNC);
- done:
return ret;
}
#else /* !FS_STATE_USE_MMAP */
if (fsync(state->fd) == -1)
ret = 1;
- done:
return ret;
}
#endif /* !FS_STATE_USE_MMAP */
{
int ret = 0;
char * p;
+#ifndef AFS_64BIT_ENV
afs_uint32 hi, lo;
SplitInt64(*offset, hi, lo);
+#endif
/* update cursor */
p = (char *) state->mmap.map;
state->mmap.cursor = (void *) p;
/* update offset */
-#ifdef AFS_LARGEFILE_ENV
state->mmap.offset = *offset;
-#else
- if (hi)
- ret = 1;
- state->mmap.offset = lo;
-#endif
return ret;
}
fs_stateSeek(struct fs_dump_state * state, afs_uint64 * offset)
{
int ret = 0;
-#ifndef AFS_LARGEFILE_ENV
- afs_uint32 high, low;
-
- SplitInt64(*offset, high, low);
- if (high) {
- ret = 1;
- goto done;
- }
-
- if (afs_lseek(state->fd, low, SEEK_SET) == -1)
- ret = 1;
-#else
+
if (afs_lseek(state->fd, *offset, SEEK_SET) == -1)
ret = 1;
-#endif
+
return ret;
}
#endif /* !FS_STATE_USE_MMAP */
* uncomment the following code. uncommenting this code is _strongly discouraged_ because
* we already make use of the version stamps in the various dump headers to deal with
* data structure version incompatabilities.
- else if (strncmp(hdr->server_version_string, cml_version_number,
+ else if (strncmp(hdr->server_version_string, cml_version_number,
sizeof(hdr->server_version_string)) != 0) {
ViceLog(0, ("fs_stateCheckHeader: dump from different server version\n"));
ret = 1;
}
*/
- else if (strncmp(hdr->server_version_string, cml_version_number,
+ else if (strncmp(hdr->server_version_string, cml_version_number,
sizeof(hdr->server_version_string)) != 0) {
ViceLog(0, ("fs_stateCheckHeader: dump from different server version ; attempting state reload anyway\n"));
}
int ret = 0;
memset(state, 0, sizeof(struct fs_dump_state));
state->fd = -1;
- state->fn = AFSDIR_SERVER_FSSTATE_FILEPATH;
+ state->fn = (char *)AFSDIR_SERVER_FSSTATE_FILEPATH;
state->hdr = (struct fs_state_header *)malloc(sizeof(struct fs_state_header));
state->h_hdr = (struct host_state_header *)malloc(sizeof(struct host_state_header));
state->cb_hdr = (struct callback_state_header *)malloc(sizeof(struct callback_state_header));
git://git.openafs.org / openafs.git / blobdiff