diff options
Diffstat (limited to 'Source/DirectFB/lib/fusion/fusion_internal.h')
| -rwxr-xr-x | Source/DirectFB/lib/fusion/fusion_internal.h | 185 |
1 files changed, 185 insertions, 0 deletions
diff --git a/Source/DirectFB/lib/fusion/fusion_internal.h b/Source/DirectFB/lib/fusion/fusion_internal.h new file mode 100755 index 0000000..5e7c474 --- /dev/null +++ b/Source/DirectFB/lib/fusion/fusion_internal.h @@ -0,0 +1,185 @@ +/* + (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>. + + 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. +*/ + +#ifndef __FUSION__FUSION_INTERNAL_H__ +#define __FUSION__FUSION_INTERNAL_H__ + +#include <sys/types.h> +#include <sys/param.h> + +#include <string.h> + +#include <direct/list.h> + +#include <fusion/build.h> +#include <fusion/fusion.h> +#include <fusion/lock.h> +#include <fusion/ref.h> +#include <fusion/shm/shm_internal.h> + +#if FUSION_BUILD_MULTI +# if FUSION_BUILD_KERNEL +# include <sys/ioctl.h> +# include <linux/fusion.h> +# else +# include <fusion/protocol.h> +# endif +#endif + +#define FUSION_MAX_WORLDS 8 + +/*************************************** + * Fusion internal type declarations * + ***************************************/ + +struct __Fusion_FusionWorldShared { + int magic; + + int refs; /* Increased by the master on fork(). */ + + int world_index; + + int world_abi; + + struct timeval start_time; + + DirectLink *arenas; + FusionSkirmish arenas_lock; + + FusionSkirmish reactor_globals; + + FusionSHMShared shm; + + FusionSHMPoolShared *main_pool; + + DirectLink *fusionees; /* Connected fusionees. */ + FusionSkirmish fusionees_lock; + + unsigned int call_ids; /* Generates call ids. */ + unsigned int lock_ids; /* Generates locks ids. */ + unsigned int ref_ids; /* Generates refs ids. */ + unsigned int reactor_ids; /* Generates reactors ids. */ + unsigned int pool_ids; /* Generates pools ids. */ + + void *pool_base; /* SHM pool allocation base. */ + void *pool_max; /* SHM pool max address. */ +}; + +struct __Fusion_FusionWorld { + int magic; + + int refs; + + FusionWorldShared *shared; + + int fusion_fd; + FusionID fusion_id; + + DirectThread *dispatch_loop; + bool dispatch_stop; + + /* + * List of reactors with at least one local reaction attached. + */ + DirectLink *reactor_nodes; + pthread_mutex_t reactor_nodes_lock; + + FusionSHM shm; + + FusionForkAction fork_action; + FusionForkCallback fork_callback; + + void *fusionee; +}; + +/******************************************* + * Fusion internal function declarations * + *******************************************/ + +int _fusion_fd( const FusionWorldShared *shared ); +FusionID _fusion_id( const FusionWorldShared *shared ); + +FusionWorld *_fusion_world( const FusionWorldShared *shared ); + +/* + * from reactor.c + */ +void _fusion_reactor_free_all ( FusionWorld *world ); +void _fusion_reactor_process_message( FusionWorld *world, + int reactor_id, + int channel, + const void *msg_data ); + + +#if FUSION_BUILD_MULTI +/* + * from call.c + */ +void _fusion_call_process( FusionWorld *world, + int call_id, + FusionCallMessage *call ); + +#if FUSION_BUILD_KERNEL +/* + * from shm.c + */ +void _fusion_shmpool_process( FusionWorld *world, + int pool_id, + FusionSHMPoolMessage *msg ); +#else +/* + * form fusion.c + */ +void _fusion_add_local( FusionWorld *world, + FusionRef *ref, + int add ); + +void _fusion_check_locals( FusionWorld *world, + FusionRef *ref ); + +void _fusion_remove_all_locals( FusionWorld *world, + const FusionRef *ref ); + +DirectResult _fusion_send_message( int fd, + const void *msg, + size_t msg_size, + struct sockaddr_un *addr ); +DirectResult _fusion_recv_message( int fd, + void *msg, + size_t msg_size, + struct sockaddr_un *addr ); + +/* + * from ref.c + */ +DirectResult _fusion_ref_change( FusionRef *ref, int add, bool global ); + +#endif /* FUSION_BUILD_KERNEL */ +#endif /* FUSION_BUILD_MULTI */ + +#endif |