1 files changed, 95 insertions, 0 deletions
diff --git a/usr/src/lib/libfakekernel/common/mutex.c b/usr/src/lib/libfakekernel/common/mutex.c
new file mode 100644
index 0000000000..03bfa7d2a4
--- /dev/null
+++ b/usr/src/lib/libfakekernel/common/mutex.c
@@ -0,0 +1,95 @@
+/*
+ * This file and its contents are supplied under the terms of the
+ * Common Development and Distribution License ("CDDL"), version 1.0.
+ * You may only use this file in accordance with the terms of version
+ * 1.0 of the CDDL.
+ *
+ * A full copy of the text of the CDDL should have accompanied this
+ * source.  A copy of the CDDL is also available via the Internet at
+ * http://www.illumos.org/license/CDDL.
+ */
+
+/*
+ * Copyright 2013 Nexenta Systems, Inc.  All rights reserved.
+ */
+
+/*
+ * mutex(9f)
+ */
+
+/* This is the API we're emulating */
+#include <sys/mutex.h>
+
+#include <sys/errno.h>
+#include <sys/debug.h>
+#include <sys/thread.h>
+
+int	_lwp_mutex_lock(lwp_mutex_t *);
+int	_lwp_mutex_unlock(lwp_mutex_t *);
+int	_lwp_mutex_trylock(lwp_mutex_t *);
+
+extern clock_t ddi_get_lbolt(void);
+extern void clock2ts(clock_t, timespec_t *);
+
+static const lwp_mutex_t default_mutex =
+	{{0, 0, 0, {USYNC_THREAD}, _MUTEX_MAGIC},
+	{{{0, 0, 0, 0, 0, 0, 0, 0}}}, 0};
+
+/* ARGSUSED */
+void
+kmutex_init(kmutex_t *mp, char *name, kmutex_type_t typ, void *arg)
+{
+	mp->m_lock = default_mutex;
+	mp->m_owner = _KTHREAD_INVALID;
+}
+
+/* ARGSUSED */
+void
+kmutex_destroy(kmutex_t *mp)
+{
+	mp->m_owner = _KTHREAD_INVALID;
+}
+
+void
+mutex_enter(kmutex_t *mp)
+{
+	VERIFY(0 == _lwp_mutex_lock(&mp->m_lock));
+	mp->m_owner = _curthread();
+}
+
+int
+mutex_tryenter(kmutex_t *mp)
+{
+	int rc;
+
+	rc = _lwp_mutex_trylock(&mp->m_lock);
+	if (rc == 0) {
+		mp->m_owner = _curthread();
+		return (1);
+	}
+	return (0);
+}
+
+void
+mutex_exit(kmutex_t *mp)
+{
+	ASSERT(mp->m_owner == _curthread());
+	mp->m_owner = _KTHREAD_INVALID;
+	(void) _lwp_mutex_unlock(&mp->m_lock);
+}
+
+/*
+ * Returns the kthread_t * of the owner.
+ */
+void *
+mutex_owner(const kmutex_t *mp)
+{
+	return (mp->m_owner);
+}
+
+int
+mutex_owned(const kmutex_t *mp)
+{
+	void *t = _curthread();
+	return (t == mp->m_owner);
+}