diff options
Diffstat (limited to 'Source/DirectFB/tests/fusion_reactor.c')
-rwxr-xr-x | Source/DirectFB/tests/fusion_reactor.c | 199 |
1 files changed, 199 insertions, 0 deletions
diff --git a/Source/DirectFB/tests/fusion_reactor.c b/Source/DirectFB/tests/fusion_reactor.c new file mode 100755 index 0000000..28d4ce1 --- /dev/null +++ b/Source/DirectFB/tests/fusion_reactor.c @@ -0,0 +1,199 @@ +/* + (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/build.h> +#include <direct/debug.h> +#include <direct/log.h> +#include <direct/messages.h> + +#include <fusion/fusion.h> +#include <fusion/reactor.h> +#include <fusion/ref.h> + + +#if DIRECT_BUILD_DEBUGS +#define MSG(x...) \ +do { \ + direct_debug( x ); \ +} while (0) +#else +#define MSG(x...) \ +do { \ +} while (0) +#endif + + +typedef struct { + unsigned int foo; +} TestMessage; + +static FusionWorld *m_world; + +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_REMOVE; +} + +static FusionCallHandlerResult +dispatch_callback (int caller, + int call_arg, + void *call_ptr, + void *ctx, + unsigned int serial, + int *ret_val ) +{ + MSG( "Got dispatch callback (FusionID %lu, pid %d)!\n", fusion_id( m_world ), getpid() ); + + return FCHR_RETURN; +} + +int +main( int argc, char *argv[] ) +{ + DirectResult ret; + pid_t child_pid; + TestMessage message = {0}; + FusionReactor *reactor; + Reaction reaction; + FusionCall call; + + 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() ); + + + reactor = fusion_reactor_new( sizeof(TestMessage), "Test", m_world ); + if (!reactor) { + D_ERROR( "fusion_reactor_new() failed\n" ); + return -1; + } + + + MSG( "Attaching to reactor...\n" ); + + ret = fusion_reactor_attach( reactor, reaction_callback, NULL, &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 ) ); + usleep( 400000 ); + break; + + default: + usleep( 100000 ); + MSG( "...returned from fork() in parent, child pid %d.\n", child_pid ); + + MSG( "Initializing dispatch callback...\n" ); + + ret = fusion_call_init( &call, dispatch_callback, NULL, m_world ); + if (ret) { + D_DERROR( ret, "fusion_call_init() failed" ); + return ret; + } + + MSG( "Setting dispatch callback...\n" ); + + ret = fusion_reactor_set_dispatch_callback( reactor, &call, NULL ); + if (ret) { + D_DERROR( ret, "fusion_reactor_set_dispatch_callback() failed" ); + return ret; + } + + + MSG( "Sending message via reactor...\n" ); + fusion_reactor_dispatch( reactor, &message, true, NULL ); + + usleep( 100000 ); + + MSG( "Destroying reactor...\n" ); + fusion_reactor_destroy( reactor ); + MSG( "...destroyed reactor!\n" ); + + usleep( 400000 ); + + MSG( "Freeing reactor...\n" ); + fusion_reactor_free( reactor ); + MSG( "...freed reactor!\n" ); + + break; + } + + + + 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; +} + |