summaryrefslogtreecommitdiff
path: root/Source/DirectFB/lib/fusion/shm/shm.c
diff options
context:
space:
mode:
Diffstat (limited to 'Source/DirectFB/lib/fusion/shm/shm.c')
-rwxr-xr-xSource/DirectFB/lib/fusion/shm/shm.c337
1 files changed, 337 insertions, 0 deletions
diff --git a/Source/DirectFB/lib/fusion/shm/shm.c b/Source/DirectFB/lib/fusion/shm/shm.c
new file mode 100755
index 0000000..21c7f42
--- /dev/null
+++ b/Source/DirectFB/lib/fusion/shm/shm.c
@@ -0,0 +1,337 @@
+/*
+ (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.
+*/
+
+#include <config.h>
+
+#include <string.h>
+#include <unistd.h>
+
+#include <sys/param.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/vfs.h>
+
+#include <direct/debug.h>
+#include <direct/list.h>
+#include <direct/signals.h>
+#include <direct/messages.h>
+#include <direct/util.h>
+
+#include <fusion/conf.h>
+#include <fusion/fusion_internal.h>
+
+#include <fusion/shm/pool.h>
+#include <fusion/shm/shm.h>
+#include <fusion/shm/shm_internal.h>
+
+
+/**********************************************************************************************************************/
+
+static int
+find_tmpfs( char *name, int len )
+{
+ int largest = 0;
+ char buffer[1024];
+ FILE *mounts_handle;
+
+ mounts_handle = fopen( "/proc/mounts", "r" );
+ if (!mounts_handle)
+ return 0;
+
+ while (fgets( buffer, sizeof(buffer), mounts_handle )) {
+ char *mount_point;
+ char *mount_fs;
+ char *pointer = buffer;
+
+ strsep( &pointer, " " );
+
+ mount_point = strsep( &pointer, " " );
+ mount_fs = strsep( &pointer, " " );
+
+ if (mount_fs && mount_point && !access( mount_point, W_OK ) &&
+ (!strcmp( mount_fs, "tmpfs" ) || !strcmp( mount_fs, "shmfs" ) || !strcmp( mount_fs, "ramfs" )))
+ {
+ struct statfs stat;
+ int bytes;
+
+ if (statfs( mount_point, &stat )) {
+ D_PERROR( "Fusion/SHM: statfs on '%s' failed!\n", mount_point );
+ continue;
+ }
+
+ bytes = stat.f_blocks * stat.f_bsize;
+
+ if (bytes > largest || (bytes == largest && !strcmp(mount_point,"/dev/shm"))) {
+ largest = bytes;
+
+ direct_snputs( name, mount_point, len );
+ }
+ }
+ }
+
+ fclose( mounts_handle );
+
+ return largest;
+}
+
+/**********************************************************************************************************************/
+
+DirectResult
+fusion_shm_init( FusionWorld *world )
+{
+ int i;
+ int num;
+ DirectResult ret;
+ FusionSHM *shm;
+ FusionSHMShared *shared;
+
+ D_MAGIC_ASSERT( world, FusionWorld );
+ D_MAGIC_ASSERT( world->shared, FusionWorldShared );
+
+ shm = &world->shm;
+ shared = &world->shared->shm;
+
+ /* Initialize local data. */
+ memset( shm, 0, sizeof(FusionSHM) );
+
+ shm->world = world;
+ shm->shared = shared;
+
+ /* Initialize shared data. */
+ if (fusion_master( world )) {
+ memset( shared, 0, sizeof(FusionSHMShared) );
+
+ if (fusion_config->tmpfs) {
+ snprintf( shared->tmpfs, FUSION_SHM_TMPFS_PATH_NAME_LEN, fusion_config->tmpfs );
+ }
+ else if (!find_tmpfs( shared->tmpfs, FUSION_SHM_TMPFS_PATH_NAME_LEN )) {
+ D_ERROR( "Fusion/SHM: Could not find tmpfs mount point, falling back to /dev/shm!\n" );
+ snprintf( shared->tmpfs, FUSION_SHM_TMPFS_PATH_NAME_LEN, "/dev/shm" );
+ }
+
+ shared->world = world->shared;
+
+ /* Initialize shared lock. */
+ ret = fusion_skirmish_init( &shared->lock, "Fusion SHM", world );
+ if (ret) {
+ D_DERROR( ret, "Fusion/SHM: Failed to create skirmish!\n" );
+ return ret;
+ }
+
+ /* Initialize static pool array. */
+ for (i=0; i<FUSION_SHM_MAX_POOLS; i++)
+ shared->pools[i].index = i;
+
+ D_MAGIC_SET( shm, FusionSHM );
+ D_MAGIC_SET( shared, FusionSHMShared );
+ }
+ else {
+ D_MAGIC_ASSERT( shared, FusionSHMShared );
+
+ ret = fusion_skirmish_prevail( &shared->lock );
+ if (ret)
+ return ret;
+
+ D_MAGIC_SET( shm, FusionSHM );
+
+ for (i=0, num=0; i<FUSION_SHM_MAX_POOLS; i++) {
+ if (shared->pools[i].active) {
+ D_MAGIC_ASSERT( &shared->pools[i], FusionSHMPoolShared );
+
+ ret = fusion_shm_pool_attach( shm, &shared->pools[i] );
+ if (ret) {
+ for (--i; i>=0; i--) {
+ if (shared->pools[i].active)
+ fusion_shm_pool_detach( shm, &shared->pools[i] );
+ }
+
+ fusion_skirmish_dismiss( &shared->lock );
+
+ D_MAGIC_CLEAR( shm );
+
+ return ret;
+ }
+
+ num++;
+ }
+ }
+
+ D_ASSERT( num == shared->num_pools );
+
+ fusion_skirmish_dismiss( &shared->lock );
+ }
+
+ return DR_OK;
+}
+
+DirectResult
+fusion_shm_deinit( FusionWorld *world )
+{
+ int i;
+ DirectResult ret;
+ FusionSHM *shm;
+ FusionSHMShared *shared;
+
+ D_MAGIC_ASSERT( world, FusionWorld );
+
+ shm = &world->shm;
+
+ D_MAGIC_ASSERT( shm, FusionSHM );
+
+ shared = shm->shared;
+
+ D_MAGIC_ASSERT( shared, FusionSHMShared );
+
+ ret = fusion_skirmish_prevail( &shared->lock );
+ if (ret)
+ return ret;
+
+ /* Deinitialize shared data. */
+ if (fusion_master( world )) {
+ D_ASSUME( shared->num_pools == 0 );
+
+ for (i=0; i<FUSION_SHM_MAX_POOLS; i++) {
+ if (shared->pools[i].active) {
+ D_MAGIC_ASSERT( &shared->pools[i], FusionSHMPoolShared );
+ D_MAGIC_ASSERT( &shm->pools[i], FusionSHMPool );
+
+ D_WARN( "destroying remaining '%s'", shared->pools[i].name );
+
+ fusion_shm_pool_destroy( world, &shared->pools[i] );
+ }
+ }
+
+ /* Destroy shared lock. */
+ fusion_skirmish_destroy( &shared->lock );
+
+ D_MAGIC_CLEAR( shared );
+ }
+ else {
+ for (i=0; i<FUSION_SHM_MAX_POOLS; i++) {
+ if (shared->pools[i].active) {
+ D_MAGIC_ASSERT( &shared->pools[i], FusionSHMPoolShared );
+ D_MAGIC_ASSERT( &shm->pools[i], FusionSHMPool );
+
+ fusion_shm_pool_detach( shm, &shared->pools[i] );
+ }
+ }
+
+ fusion_skirmish_dismiss( &shared->lock );
+ }
+
+ D_MAGIC_CLEAR( shm );
+
+ return DR_OK;
+}
+
+DirectResult
+fusion_shm_attach_unattached( FusionWorld *world )
+{
+ int i;
+ DirectResult ret;
+ FusionSHM *shm;
+ FusionSHMShared *shared;
+
+ D_MAGIC_ASSERT( world, FusionWorld );
+ D_MAGIC_ASSERT( world->shared, FusionWorldShared );
+
+ shm = &world->shm;
+ shared = &world->shared->shm;
+
+ D_MAGIC_ASSERT( shm, FusionSHM );
+ D_MAGIC_ASSERT( shared, FusionSHMShared );
+
+ ret = fusion_skirmish_prevail( &shared->lock );
+ if (ret)
+ return ret;
+
+ for (i=0; i<FUSION_SHM_MAX_POOLS; i++) {
+ if (!shared->pools[i].active)
+ continue;
+
+ D_MAGIC_ASSERT( &shared->pools[i], FusionSHMPoolShared );
+
+ if (!shm->pools[i].attached) {
+ ret = fusion_shm_pool_attach( shm, &shared->pools[i] );
+ if (ret)
+ D_DERROR( ret, "fusion_shm_pool_attach( '%s' ) failed!\n", shared->pools[i].name );
+ }
+ else
+ D_MAGIC_ASSERT( &shm->pools[i], FusionSHMPool );
+ }
+
+ fusion_skirmish_dismiss( &shared->lock );
+
+ return DR_OK;
+}
+
+DirectResult
+fusion_shm_enum_pools( FusionWorld *world,
+ FusionSHMPoolCallback callback,
+ void *ctx )
+{
+ int i;
+ DirectResult ret;
+ FusionSHM *shm;
+ FusionSHMShared *shared;
+
+ D_MAGIC_ASSERT( world, FusionWorld );
+ D_MAGIC_ASSERT( world->shared, FusionWorldShared );
+ D_ASSERT( callback != NULL );
+
+ shm = &world->shm;
+ shared = &world->shared->shm;
+
+ D_MAGIC_ASSERT( shm, FusionSHM );
+ D_MAGIC_ASSERT( shared, FusionSHMShared );
+
+ ret = fusion_skirmish_prevail( &shared->lock );
+ if (ret)
+ return ret;
+
+ for (i=0; i<FUSION_SHM_MAX_POOLS; i++) {
+ if (!shared->pools[i].active)
+ continue;
+
+ if (!shm->pools[i].attached) {
+ D_BUG( "not attached to pool" );
+ continue;
+ }
+
+ D_MAGIC_ASSERT( &shm->pools[i], FusionSHMPool );
+ D_MAGIC_ASSERT( &shared->pools[i], FusionSHMPoolShared );
+
+ if (callback( &shm->pools[i], ctx ) == DENUM_CANCEL)
+ break;
+ }
+
+ fusion_skirmish_dismiss( &shared->lock );
+
+ return DR_OK;
+}
+
generated by cgit (git 2.34.1) at 2024-04-20 04:54:52 +0000