1 files changed, 109 insertions, 0 deletions
diff --git a/tinySAK/src/tsk_thread.c b/tinySAK/src/tsk_thread.c
new file mode 100644
index 0000000..c8339e5
--- /dev/null
+++ b/tinySAK/src/tsk_thread.c
@@ -0,0 +1,109 @@
+/*
+* Copyright (C) 2009-2010 Mamadou Diop.
+*
+* Contact: Mamadou Diop <diopmamadou(at)doubango.org>
+*	
+* This file is part of Open Source Doubango Framework.
+*
+* DOUBANGO is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*	
+* DOUBANGO is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*	
+* You should have received a copy of the GNU General Public License
+* along with DOUBANGO.
+*
+*/
+
+/**@file tsk_thread.c
+ * @brief Utility functions for threading.
+ *
+ * @author Mamadou Diop <diopmamadou(at)doubango.org>
+ *
+ * @date Created: Sat Nov 8 16:54:58 2009 mdiop
+ */
+#include "tsk_thread.h"
+#include "tsk_debug.h"
+#include "tsk_memory.h"
+
+#if TSK_UNDER_WINDOWS
+#	include <windows.h>
+#else
+#	include <pthread.h>
+#endif
+
+/**@defgroup tsk_thread_group Utility functions for threading.
+*/
+
+/**@ingroup tsk_thread_group
+*/
+void tsk_thread_sleep(uint64_t ms)
+{
+#if TSK_UNDER_WINDOWS
+	Sleep((DWORD)ms);
+#else
+	struct timespec interval; 
+
+	interval.tv_sec = (long)(ms/1000); 
+	interval.tv_nsec = (long)(ms%1000) * 1000000; 
+	nanosleep(&interval, 0);
+#endif	
+}
+
+/**@ingroup tsk_thread_group
+* Creates a new thread.
+* @param tid Handle id of the newly created thread. The returned handle should be destroyed using @ref tsk_thread_join()
+* @param start The function to be run as the new thread's start routine 
+* @param arg An address for the argument for the thread's start routine 
+* @retval If successful, returns zero. Otherwise, an error number is returned to indicate the error
+*/
+int tsk_thread_create(void** tid, void *(*start) (void *), void *arg)
+{
+#if TSK_UNDER_WINDOWS
+	DWORD ThreadId;
+	*((HANDLE*)tid) = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)start, arg, 0, &ThreadId);
+	return *((HANDLE*)tid) ? 0 : -1;
+#else
+	*tid = tsk_calloc(1, sizeof(pthread_t));
+	return pthread_create((pthread_t*)*tid, 0, start, arg);
+#endif
+}
+
+/**@ingroup tsk_thread_group
+* Join a thread.
+* @param tid Pthread handle to the target thread.
+* @retval If successful, returns zero. Otherwise, an error number is returned to indicate the error. 
+*/
+int tsk_thread_join(void** tid)
+{
+	int ret;
+
+	if(!tid){
+		TSK_DEBUG_ERROR("Invalid parameter");
+		return -1;
+	}
+	if(!*tid){
+		TSK_DEBUG_WARN("Cannot join NULL tid");
+		return 0;
+	}
+    
+#if TSK_UNDER_WINDOWS
+	ret = (WaitForSingleObject(*((HANDLE*)tid), INFINITE) == WAIT_FAILED) ? -1 : 0;
+	if(ret == 0){
+		CloseHandle(*((HANDLE*)tid));
+		*tid = tsk_null;
+	}
+#else
+	if((ret = pthread_join(*((pthread_t*)*tid), 0)) == 0){
+		tsk_free(tid);
+	}
+#endif
+
+	return ret;
+}
+