1 files changed, 154 insertions, 0 deletions
diff --git a/src/include/os_fhandle.i b/src/include/os_fhandle.i
new file mode 100644
index 00000000000..8d2cda4b305
--- /dev/null
+++ b/src/include/os_fhandle.i
@@ -0,0 +1,154 @@
+/*-
+ * Copyright (c) 2014-2016 MongoDB, Inc.
+ * Copyright (c) 2008-2014 WiredTiger, Inc.
+ *	All rights reserved.
+ *
+ * See the file LICENSE for redistribution information.
+ */
+
+/*
+ * __wt_fsync --
+ *	POSIX fsync.
+ */
+static inline int
+__wt_fsync(WT_SESSION_IMPL *session, WT_FH *fh, bool block)
+{
+	WT_FILE_HANDLE *handle;
+
+	WT_ASSERT(session, !F_ISSET(S2C(session), WT_CONN_READONLY));
+
+	WT_RET(__wt_verbose(
+	    session, WT_VERB_HANDLEOPS, "%s: handle-sync", fh->handle->name));
+
+	handle = fh->handle;
+	if (block)
+		return (handle->sync == NULL ? 0 :
+		    handle->sync(handle, (WT_SESSION *)session));
+	else
+		return (handle->sync_nowait == NULL ? 0 :
+		    handle->sync_nowait(handle, (WT_SESSION *)session));
+}
+
+/*
+ * __wt_fallocate --
+ *	Extend a file.
+ */
+static inline int
+__wt_fallocate(
+    WT_SESSION_IMPL *session, WT_FH *fh, wt_off_t offset, wt_off_t len)
+{
+	WT_DECL_RET;
+	WT_FILE_HANDLE *handle;
+
+	WT_ASSERT(session, !F_ISSET(S2C(session), WT_CONN_READONLY));
+	WT_ASSERT(session, !F_ISSET(S2C(session), WT_CONN_IN_MEMORY));
+
+	WT_RET(__wt_verbose(session, WT_VERB_HANDLEOPS,
+	    "%s: handle-allocate: %" PRIuMAX " at %" PRIuMAX,
+	    fh->handle->name, (uintmax_t)len, (uintmax_t)offset));
+
+	/*
+	 * Our caller is responsible for handling any locking issues, all we
+	 * have to do is find a function to call.
+	 *
+	 * Be cautious, the underlying system might have configured the nolock
+	 * flavor, that failed, and we have to fallback to the locking flavor.
+	 */
+	handle = fh->handle;
+	if (handle->fallocate_nolock != NULL) {
+		if ((ret = handle->fallocate_nolock(
+		    handle, (WT_SESSION *)session, offset, len)) == 0)
+			return (0);
+		WT_RET_ERROR_OK(ret, ENOTSUP);
+	}
+	if (handle->fallocate != NULL)
+		return (handle->fallocate(
+		    handle, (WT_SESSION *)session, offset, len));
+	return (ENOTSUP);
+}
+
+/*
+ * __wt_file_lock --
+ *	Lock/unlock a file.
+ */
+static inline int
+__wt_file_lock(WT_SESSION_IMPL * session, WT_FH *fh, bool lock)
+{
+	WT_FILE_HANDLE *handle;
+
+	WT_RET(__wt_verbose(session, WT_VERB_HANDLEOPS,
+	    "%s: handle-lock: %s", fh->handle->name, lock ? "lock" : "unlock"));
+
+	handle = fh->handle;
+	return (handle->lock == NULL ? 0 :
+	    handle->lock(handle, (WT_SESSION*)session, lock));
+}
+
+/*
+ * __wt_read --
+ *	POSIX pread.
+ */
+static inline int
+__wt_read(
+    WT_SESSION_IMPL *session, WT_FH *fh, wt_off_t offset, size_t len, void *buf)
+{
+	WT_RET(__wt_verbose(session, WT_VERB_HANDLEOPS,
+	    "%s: handle-read: %" WT_SIZET_FMT " at %" PRIuMAX,
+	    fh->handle->name, len, (uintmax_t)offset));
+
+	WT_STAT_FAST_CONN_INCR(session, read_io);
+
+	return (fh->handle->read(
+	    fh->handle, (WT_SESSION *)session, offset, len, buf));
+}
+
+/*
+ * __wt_filesize --
+ *	Get the size of a file in bytes, by file handle.
+ */
+static inline int
+__wt_filesize(WT_SESSION_IMPL *session, WT_FH *fh, wt_off_t *sizep)
+{
+	WT_RET(__wt_verbose(
+	    session, WT_VERB_HANDLEOPS, "%s: handle-size", fh->handle->name));
+
+	return (fh->handle->size(fh->handle, (WT_SESSION *)session, sizep));
+}
+
+/*
+ * __wt_ftruncate --
+ *	POSIX ftruncate.
+ */
+static inline int
+__wt_ftruncate(WT_SESSION_IMPL *session, WT_FH *fh, wt_off_t len)
+{
+	WT_ASSERT(session, !F_ISSET(S2C(session), WT_CONN_READONLY));
+
+	WT_RET(__wt_verbose(session, WT_VERB_HANDLEOPS,
+	    "%s: handle-truncate: %" PRIuMAX,
+	    fh->handle->name, (uintmax_t)len));
+
+	return (fh->handle->truncate(fh->handle, (WT_SESSION *)session, len));
+}
+
+/*
+ * __wt_write --
+ *	POSIX pwrite.
+ */
+static inline int
+__wt_write(WT_SESSION_IMPL *session,
+    WT_FH *fh, wt_off_t offset, size_t len, const void *buf)
+{
+	WT_ASSERT(session, !F_ISSET(S2C(session), WT_CONN_READONLY) ||
+	    WT_STRING_MATCH(fh->name,
+	    WT_SINGLETHREAD, strlen(WT_SINGLETHREAD)));
+
+	WT_RET(__wt_verbose(session, WT_VERB_HANDLEOPS,
+	    "%s: handle-write: %" WT_SIZET_FMT " at %" PRIuMAX,
+	    fh->handle->name, len, (uintmax_t)offset));
+
+	WT_STAT_FAST_CONN_INCR(session, write_io);
+
+	return (fh->handle->write(
+	    fh->handle, (WT_SESSION *)session, offset, len, buf));
+}