From 7fe60435bce6595a9c58a9bfd8244d74b5320e96 Mon Sep 17 00:00:00 2001
From: Benjamin Franzke <benjaminfranzke@googlemail.com>
Date: Tue, 15 Jan 2013 08:46:13 +0100
Subject: Import DirectFB141_2k11R3_beta5

---
 Source/DirectFB/tests/fusion_fork.c | 172 ++++++++++++++++++++++++++++++++++++
 1 file changed, 172 insertions(+)
 create mode 100755 Source/DirectFB/tests/fusion_fork.c

(limited to 'Source/DirectFB/tests/fusion_fork.c')

diff --git a/Source/DirectFB/tests/fusion_fork.c b/Source/DirectFB/tests/fusion_fork.c
new file mode 100755
index 0000000..f6cb2ae
--- /dev/null
+++ b/Source/DirectFB/tests/fusion_fork.c
@@ -0,0 +1,172 @@
+/*
+   (c) Copyright 2001-2009  The world wide DirectFB Open Source Community (directfb.org)
+   (c) Copyright 2000-2004  Convergence (integrated media) GmbH
+
+   All rights reserved.
+
+   Written by Denis Oliver Kropp <dok@directfb.org>,
+              Andreas Hundt <andi@fischlustig.de>,
+              Sven Neumann <neo@directfb.org>,
+              Ville Syrjälä <syrjala@sci.fi> and
+              Claudio Ciccani <klan@users.sf.net>.
+
+   All rights reserved.
+
+   This file is subject to the terms and conditions of the MIT License:
+
+   Permission is hereby granted, free of charge, to any person
+   obtaining a copy of this software and associated documentation
+   files (the "Software"), to deal in the Software without restriction,
+   including without limitation the rights to use, copy, modify, merge,
+   publish, distribute, sublicense, and/or sell copies of the Software,
+   and to permit persons to whom the Software is furnished to do so,
+   subject to the following conditions:
+
+   The above copyright notice and this permission notice shall be
+   included in all copies or substantial portions of the Software.
+
+   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+   EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+   MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
+   IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
+   CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
+   TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
+   SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+*/
+
+#include <config.h>
+
+#include <sys/types.h>
+#include <unistd.h>
+#include <stddef.h>
+
+#include <directfb.h>
+
+#include <direct/log.h>
+#include <direct/messages.h>
+
+#include <fusion/fusion.h>
+#include <fusion/reactor.h>
+#include <fusion/ref.h>
+
+
+#define MSG(x...)                       \
+do {                                    \
+     direct_log_printf( NULL, "- " x ); \
+} while (0)
+
+
+typedef struct {
+     unsigned int foo;
+} TestMessage;
+
+
+static FusionWorld   *m_world;
+static FusionRef      m_ref;
+static FusionReactor *m_reactor;
+static Reaction       m_reaction;
+
+
+static ReactionResult
+reaction_callback( const void *msg_data,
+                   void       *ctx )
+{
+     MSG( "Received message (FusionID %lu, pid %d)!\n", fusion_id( m_world ), getpid() );
+
+     return RS_OK;
+}
+
+
+int
+main( int argc, char *argv[] )
+{
+     DirectResult ret;
+     pid_t        child_pid;
+     TestMessage  message = {0};
+
+     DirectFBInit( &argc, &argv );
+
+     ret = fusion_enter( -1, 0, FER_MASTER, &m_world );
+     if (ret) {
+          D_DERROR( ret, "fusion_enter() failed" );
+          return ret;
+     }
+
+     MSG( "Entered world %d as master (FusionID %lu, pid %d)\n",
+          fusion_world_index( m_world ), fusion_id( m_world ), getpid() );
+
+
+     ret = fusion_ref_init( &m_ref, "Test", m_world );
+     if (ret) {
+          D_DERROR( ret, "fusion_ref_init() failed" );
+          return -1;
+     }
+
+
+     MSG( "Adding local reference...\n" );
+
+     fusion_ref_up( &m_ref, false );
+
+
+     m_reactor = fusion_reactor_new( sizeof(TestMessage), "Test", m_world );
+     if (!m_reactor) {
+          D_ERROR( "fusion_reactor_new() failed\n" );
+          return -1;
+     }
+
+
+     MSG( "Attaching to reactor...\n" );
+
+     ret = fusion_reactor_attach( m_reactor, reaction_callback, NULL, &m_reaction );
+     if (ret) {
+          D_DERROR( ret, "fusion_reactor_attach() failed" );
+          return ret;
+     }
+
+
+     MSG( ".........FORKING NOW.........\n" );
+
+     fusion_world_set_fork_action( m_world, FFA_FORK );
+     child_pid = fork();
+     fusion_world_set_fork_action( m_world, FFA_CLOSE );
+
+     switch (child_pid) {
+          case -1:
+               D_PERROR( "fork() failed" );
+               break;
+
+          case 0:
+               setsid();
+               MSG( "...arrived after fork() in child (pid %d)..\n", getpid() );
+               MSG( "..child (FusionID %lu).\n", fusion_id( m_world ) );
+               break;
+
+          default:
+               usleep( 200000 );
+               MSG( "...returned from fork() in parent, child pid %d.\n", child_pid );
+               break;
+     }
+
+
+     MSG( "Sending message via reactor...\n" );
+
+     fusion_reactor_dispatch( m_reactor, &message, true, NULL );
+
+     usleep( 200000 );
+
+
+     MSG( "Removing local reference...\n" );
+
+     fusion_ref_down( &m_ref, false );
+
+     usleep( 200000 );
+
+
+     MSG( "Exiting from world %d (FusionID %lu, pid %d)...\n",
+          fusion_world_index( m_world ), fusion_id( m_world ), getpid() );
+
+     fusion_exit( m_world, false );
+
+     return 0;
+}
+
-- 
cgit