1 files changed, 96 insertions, 0 deletions
diff --git a/Source/FusionDale/src/coma/thread.c b/Source/FusionDale/src/coma/thread.c
new file mode 100755
index 0000000..6aaac18
--- /dev/null
+++ b/Source/FusionDale/src/coma/thread.c
@@ -0,0 +1,96 @@
+/*
+   (c) Copyright 2007  directfb.org
+
+   All rights reserved.
+
+   Written by Denis Oliver Kropp <dok@directfb.org>.
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2 of the License, or (at your option) any later version.
+
+   This library 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
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with this library; if not, write to the
+   Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+   Boston, MA 02111-1307, USA.
+*/
+
+#include <config.h>
+
+#include <direct/debug.h>
+#include <direct/interface.h>
+#include <direct/messages.h>
+#include <direct/util.h>
+
+#include <fusion/call.h>
+#include <fusion/fusion.h>
+#include <fusion/hash.h>
+#include <fusion/lock.h>
+#include <fusion/shmalloc.h>
+
+#include <coma/coma.h>
+#include <coma/thread.h>
+
+D_DEBUG_DOMAIN( Coma_Thread, "Coma/Thread", "Coma Thread" );
+
+/**********************************************************************************************************************/
+
+static const ReactionFunc coma_thread_globals[] = {
+          NULL
+};
+
+static void
+thread_destructor( FusionObject *object, bool zombie, void *ctx )
+{
+     ComaThread *thread = (ComaThread*) object;
+
+     D_MAGIC_ASSERT( thread, ComaThread );
+
+     D_DEBUG_AT( Coma_Thread, "%s( %p [%lu] )%s\n", __FUNCTION__, thread, object->id, zombie ? " ZOMBIE!" : "" );
+
+     if (thread->mem)
+          SHFREE( thread->shmpool, thread->mem );
+
+     D_MAGIC_CLEAR( thread );
+
+     fusion_object_destroy( object );
+}
+
+FusionObjectPool *
+coma_thread_pool_create( Coma *coma )
+{
+     return fusion_object_pool_create( "Thread", sizeof(ComaThread), sizeof(void*),
+                                       thread_destructor, coma, coma_world(coma) );
+}
+
+/**********************************************************************************************************************/
+
+DirectResult
+coma_thread_init( ComaThread *thread,
+                  Coma       *coma )
+{
+     FusionWorld *world;
+
+     D_ASSERT( thread != NULL );
+     D_ASSERT( coma != NULL );
+
+     D_DEBUG_AT( Coma_Thread, "%s( %p, %p )\n", __FUNCTION__, thread, coma );
+
+     world = coma_world( coma );
+
+     thread->shmpool = coma_shmpool( coma );
+
+     /* Remember creator. */
+     thread->fusion_id = fusion_id( world );
+
+     D_MAGIC_SET( thread, ComaThread );
+
+     return DR_OK;
+}
+