added qse_mtx_t

qse/lib/sys/Makefile.am

@@ -6,6 +6,7 @@ AM_CPPFLAGS = \
 
 lib_LTLIBRARIES = libqsesys.la
 libqsesys_la_SOURCES =  \
+	mtx.c \
 	thr.c \
 	thr.h
 libqsesys_la_LDFLAGS = -L../cmn -version-info 1:0:0 -no-undefined

qse/lib/sys/Makefile.in

@@ -127,7 +127,7 @@ am__uninstall_files_from_dir = { \
 am__installdirs = "$(DESTDIR)$(libdir)"
 LTLIBRARIES = $(lib_LTLIBRARIES)
 libqsesys_la_DEPENDENCIES =
-am_libqsesys_la_OBJECTS = thr.lo
+am_libqsesys_la_OBJECTS = mtx.lo thr.lo
 libqsesys_la_OBJECTS = $(am_libqsesys_la_OBJECTS)
 AM_V_lt = $(am__v_lt_@AM_V@)
 am__v_lt_ = $(am__v_lt_@AM_DEFAULT_V@)
@@ -407,6 +407,7 @@ AM_CPPFLAGS = \
 
 lib_LTLIBRARIES = libqsesys.la $(am__append_1)
 libqsesys_la_SOURCES = \
+	mtx.c \
 	thr.c \
 	thr.h
 
@@ -500,6 +501,7 @@ distclean-compile:
 	-rm -f *.tab.c
 
 @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/SocketAddress.Plo@am__quote@
+@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/mtx.Plo@am__quote@
 @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/thr.Plo@am__quote@
 
 .c.o:

qse/lib/sys/mtx.c

@@ -0,0 +1,204 @@
+/*
+ * $Id$
+ *
+    Copyright (c) 2006-2014 Chung, Hyung-Hwan. All rights reserved.
+
+    Redistribution and use in source and binary forms, with or without
+    modification, are permitted provided that the following conditions
+    are met:
+    1. Redistributions of source code must retain the above copyright
+       notice, this list of conditions and the following disclaimer.
+    2. Redistributions in binary form must reproduce the above copyright
+       notice, this list of conditions and the following disclaimer in the
+       documentation and/or other materials provided with the distribution.
+
+    THIS SOFTWARE IS PROVIDED BY THE AUTHOR "AS IS" AND ANY EXPRESS OR
+    IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
+    OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
+    IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
+    INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
+    NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+    DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+    THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+    (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
+    THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include <qse/sys/mtx.h>
+#include "../cmn/mem.h"
+
+#if (!defined(__unix__) && !defined(__unix)) || defined(HAVE_PTHREAD)
+
+#if defined(_WIN32)
+	#include <process.h>
+#elif defined(__BEOS__)
+	#include <be/kernel/OS.h>
+#else
+	#if defined(AIX) && defined(__GNUC__)
+		typedef int crid_t;
+		typedef unsigned int class_id_t;
+	#endif
+	#include <pthread.h>
+#endif
+
+
+qse_mtx_t* qse_mtx_open (qse_mmgr_t* mmgr, qse_size_t xtnsize)
+{
+	qse_mtx_t* mtx;
+
+	mtx = (qse_mtx_t*) QSE_MMGR_ALLOC (mmgr, QSE_SIZEOF(qse_mtx_t) + xtnsize);
+	if (mtx)
+	{
+		if (qse_mtx_init (mtx, mmgr) <= -1)
+		{
+			QSE_MMGR_FREE (mmgr, mtx);
+			return QSE_NULL;
+		}
+		else QSE_MEMSET (QSE_XTN(mtx), 0, xtnsize);
+	}
+
+	return mtx;
+}
+
+void qse_mtx_close (qse_mtx_t* mtx)
+{
+	qse_mtx_fini (mtx);
+	QSE_MMGR_FREE (mtx->mmgr, mtx);
+}
+
+
+int qse_mtx_init (qse_mtx_t* mtx, qse_mmgr_t* mmgr)
+{
+	QSE_MEMSET (mtx, 0, QSE_SIZEOF(*mtx));
+	mtx->mmgr = mmgr;
+
+#if defined(_WIN32)
+	mtx->hnd = CreateMutex (QSE_NULL, FALSE, QSE_NULL);
+	if (mtx->hnd == QSE_NULL) return -1;
+
+#elif defined(__OS2__)
+#	error not implemented
+
+#elif defined(__DOS__)
+#	error not implemented
+
+#elif defined(__BEOS__)
+	mtx->hnd = create_sem (1, QSE_NULL);
+	if (mtx->hnd < B_OK)  return -1;
+
+#else
+	/*
+	qse_ensure (pthread_mutexattr_init (&attr) == 0);
+	if (pthread_mutexattr_settype (&attr, type) != 0) 
+	{
+		int num = qse_geterrno();
+		pthread_mutexattr_destroy (&attr);
+		if (mtx->__dynamic) qse_free (mtx);
+		qse_seterrno (num);
+		return QSE_NULL;
+	}
+	qse_ensure (pthread_mutex_init (&mtx->hnd, &attr) == 0);
+	qse_ensure (pthread_mutexattr_destroy (&attr) == 0);
+	*/
+	if (pthread_mutex_init (&mtx->hnd, QSE_NULL) != 0) return -1;
+#endif
+
+	return 0;
+}
+
+void qse_mtx_fini (qse_mtx_t* mtx)
+{
+#if defined(_WIN32)
+	CloseHandle (mtx->hnd);
+
+#elif defined(__OS2__)
+#	error not implemented
+
+#elif defined(__DOS__)
+#	error not implemented
+
+#elif defined(__BEOS__)
+	/*if (delete_sem(mtx->hnd) != B_NO_ERROR) return -1;*/
+	delete_sem(mtx->hnd);
+
+#else
+	pthread_mutex_destroy(&mtx->hnd);
+#endif
+}
+
+qse_mmgr_t* qse_mtx_getmmgr (qse_mtx_t* mtx)
+{
+	return mtx->mmgr;
+}
+
+void* qse_mtx_getxtn (qse_mtx_t* mtx)
+{
+	return QSE_XTN (mtx);
+}
+
+int qse_mtx_lock (qse_mtx_t* mtx)
+{
+#if defined(_WIN32)
+	/* 
+	 * MSDN
+	 *   WAIT_ABANDONED The specified object is a mutex object that was 
+	 *                  not released by the thread that owned the mutex 
+	 *                  object before the owning thread terminated. 
+	 *                  Ownership of the mutex object is granted to the 
+	 *                  calling thread, and the mutex is set to nonsignaled.
+	 *   WAIT_OBJECT_0  The state of the specified object is signaled. 
+	 *   WAIT_TIMEOUT   The time-out interval elapsed, and the object's 
+	 *                  state is nonsignaled. 
+	 *   WAIT_FAILED    An error occurred
+	 */
+	if (WaitForSingleObject (
+		mtx->hnd, INFINITE) == WAIT_FAILED) 
+	{
+		qse_seterrno (qse_maperrno(GetLastError()));
+		return -1;
+	}
+#elif defined(__BEOS__)
+	if (acquire_sem(mtx->hnd) != B_NO_ERROR) return -1;
+#else
+	if (pthread_mutex_lock (&mtx->hnd) != 0) return -1;
+#endif
+	return 0;
+}
+
+int qse_mtx_unlock (qse_mtx_t* mtx)
+{
+#if defined(_WIN32)
+	if (ReleaseMutex (mtx->hnd) == FALSE) 
+	{
+		qse_seterrno (qse_maperrno(GetLastError()));
+		return -1;
+	}
+#elif defined(__BEOS__)
+	if (release_sem(mtx->hnd) != B_NO_ERROR) return -1;
+#else
+	if (pthread_mutex_unlock (&mtx->hnd) != 0) return -1;
+#endif
+	return 0;
+}
+
+int qse_mtx_trylock (qse_mtx_t* mtx)
+{
+#if defined(_WIN32)
+	if (WaitForSingleObject(mtx->hnd,0) != WAIT_OBJECT_0) 
+	{
+		qse_seterrno (qse_maperrno(GetLastError()));
+		return -1;
+	}
+#elif defined(__BEOS__)
+	if (acquire_sem_etc(mtx->hnd,1,B_ABSOLUTE_TIMEOUT,0) != B_NO_ERROR) 
+	{
+		/* TODO: check for B_WOULD_BLOCK */
+		return -1;
+	}
+#else
+	if (pthread_mutex_trylock(&mtx->hnd) != 0) return -1;
+#endif
+	return 0;
+}
+
+#endif

qse/lib/sys/thr.c

@@ -78,6 +78,15 @@ void qse_thr_fini (qse_thr_t* thr)
 	thr->__handle = QSE_THR_HND_INVALID;
 }
 
+qse_mmgr_t* qse_thr_getmmgr (qse_thr_t* thr)
+{
+	return thr->mmgr;
+}
+
+void* qse_thr_getxtn (qse_thr_t* thr)
+{
+	return QSE_XTN (thr);
+}
 
 qse_size_t qse_thr_getstacksize (qse_thr_t* thr)
 {