diff options
Diffstat (limited to 'Source/FusionDale/src/coma/icomacomponent.c')
| -rwxr-xr-x | Source/FusionDale/src/coma/icomacomponent.c | 340 |
1 files changed, 340 insertions, 0 deletions
diff --git a/Source/FusionDale/src/coma/icomacomponent.c b/Source/FusionDale/src/coma/icomacomponent.c new file mode 100755 index 0000000..a0bc3b2 --- /dev/null +++ b/Source/FusionDale/src/coma/icomacomponent.c @@ -0,0 +1,340 @@ +/* + (c) Copyright 2006-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 <unistd.h> + +#include <fusiondale.h> + +#include <direct/interface.h> +#include <direct/mem.h> + +#include <fusion/shmalloc.h> + +#include <coma/coma.h> +#include <coma/component.h> + +#include "icomacomponent.h" + +/**********************************************************************************************************************/ + +static ReactionResult IComaComponent_ListenerReaction( const void *msg_data, + void *ctx ); + +/**********************************************************************************************************************/ + +static void +IComaComponent_Destruct( IComaComponent *thiz ) +{ + int i; + IComaComponent_data *data = thiz->priv; + + for (i=0; i<data->num_notifications; i++) { + if (data->listeners[i].func) + coma_component_detach( data->component, &data->listeners[i].reaction ); + } + + coma_component_unref( data->component ); + + DIRECT_DEALLOCATE_INTERFACE( thiz ); +} + +static DirectResult +IComaComponent_AddRef( IComaComponent *thiz ) +{ + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + data->ref++; + + return DR_OK; +} + +static DirectResult +IComaComponent_Release( IComaComponent *thiz ) +{ + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + if (--data->ref == 0) + IComaComponent_Destruct( thiz ); + + return DR_OK; +} + +static DirectResult +IComaComponent_InitNotification( IComaComponent *thiz, + ComaNotificationID id, + ComaNotifyFunc func, + void *ctx, + ComaNotificationFlags flags ) +{ + DirectResult ret; + + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + coma_component_lock( data->component ); + + ret = coma_component_init_notification( data->component, id, func, ctx, flags ); + + coma_component_unlock( data->component ); + + return ret; +} + +static DirectResult +IComaComponent_InitNotifications( IComaComponent *thiz, + const ComaNotificationInit *inits, + int num_inits, + void *ctx ) +{ + int i; + DirectResult ret = DR_INVARG; + + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + if (!inits || num_inits < 1) + return DR_INVARG; + + coma_component_lock( data->component ); + + for (i=0; i<num_inits; i++) { + ret = coma_component_init_notification( data->component, inits[i].id, + inits[i].func, inits[i].ctx ? : ctx, + inits[i].flags ); + if (ret) + break; + } + + coma_component_unlock( data->component ); + + return ret; +} + +static DirectResult +IComaComponent_Call( IComaComponent *thiz, + ComaMethodID method, + void *arg, + int *ret_val ) +{ + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + return coma_component_call( data->component, method, arg, ret_val ); +} + +static DirectResult +IComaComponent_Return( IComaComponent *thiz, + int val, + unsigned int magic ) +{ + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + return coma_component_return( data->component, magic, val ); +} + +static DirectResult +IComaComponent_Notify( IComaComponent *thiz, + ComaNotificationID id, + void *arg ) +{ + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + if (id < 0 || id >= data->num_notifications) + return DR_LIMITEXCEEDED; + + return coma_component_notify( data->component, id, arg ); +} + +static DirectResult +IComaComponent_Listen( IComaComponent *thiz, + ComaNotificationID id, + ComaListenerFunc func, + void *ctx ) +{ + DirectResult ret; + ComaListener *listener; + + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + if (id < 0 || id >= data->num_notifications) + return DR_LIMITEXCEEDED; + + listener = &data->listeners[id]; + + if (listener->func) + return DR_BUSY; + + ret = coma_component_attach_channel( data->component, id, + IComaComponent_ListenerReaction, + listener, &listener->reaction ); + if (ret) + return ret; + + listener->func = func; + listener->ctx = ctx; + + return DR_OK; +} + +static DirectResult +IComaComponent_InitListeners( IComaComponent *thiz, + const ComaListenerInit *inits, + int num_inits, + void *ctx ) +{ + int i; + DirectResult ret; + ComaListener *listener; + + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + if (!inits || num_inits < 1) + return DR_INVARG; + + for (i=0; i<num_inits; i++) { + if (inits[i].id < 0 || inits[i].id >= data->num_notifications) + return DR_LIMITEXCEEDED; + + listener = &data->listeners[inits[i].id]; + + if (listener->func) + return DR_BUSY; + + ret = coma_component_attach_channel( data->component, inits[i].id, + IComaComponent_ListenerReaction, + listener, &listener->reaction ); + if (ret) + return ret; + + listener->func = inits[i].func; + listener->ctx = inits[i].ctx ? : ctx; + } + + return DR_OK; +} + +static DirectResult +IComaComponent_Unlisten( IComaComponent *thiz, + ComaNotificationID id ) +{ + ComaListener *listener; + + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + if (id < 0 || id >= data->num_notifications) + return DR_LIMITEXCEEDED; + + listener = &data->listeners[id]; + + if (!listener->func) + return DR_ITEMNOTFOUND; + + coma_component_detach( data->component, &listener->reaction ); + + listener->func = NULL; + + return DR_OK; +} + +static DirectResult +IComaComponent_Activate( IComaComponent *thiz ) +{ + DirectResult ret; + + DIRECT_INTERFACE_GET_DATA (IComaComponent) + + coma_component_lock( data->component ); + + ret = coma_component_activate( data->component ); + + coma_component_unlock( data->component ); + + return ret; +} + +DirectResult +IComaComponent_Construct( IComaComponent *thiz, + Coma *coma, + ComaComponent *component, + int num_notifications ) +{ + DirectResult ret; + + /* Allocate interface data. */ + DIRECT_ALLOCATE_INTERFACE_DATA( thiz, IComaComponent ); + + ret = coma_component_ref( component ); + if (ret) { + DIRECT_DEALLOCATE_INTERFACE( thiz ); + return ret; + } + + /* Initialize interface data. */ + data->ref = 1; + data->coma = coma; + data->component = component; + data->num_notifications = num_notifications; + data->listeners = D_CALLOC( num_notifications, sizeof(ComaListener) ); + + if (!data->listeners) { + D_OOM(); + coma_component_unref( component ); + DIRECT_DEALLOCATE_INTERFACE( thiz ); + return DR_NOLOCALMEMORY; + } + + /* Assign interface pointers. */ + thiz->AddRef = IComaComponent_AddRef; + thiz->Release = IComaComponent_Release; + thiz->InitNotification = IComaComponent_InitNotification; + thiz->InitNotifications = IComaComponent_InitNotifications; + thiz->Call = IComaComponent_Call; + thiz->Return = IComaComponent_Return; + thiz->Notify = IComaComponent_Notify; + thiz->Listen = IComaComponent_Listen; + thiz->InitListeners = IComaComponent_InitListeners; + thiz->Unlisten = IComaComponent_Unlisten; + thiz->Activate = IComaComponent_Activate; + + return DR_OK; +} + +/**********************************************************************************************************************/ + +static ReactionResult +IComaComponent_ListenerReaction( const void *msg_data, + void *ctx ) +{ + void * const *p_arg = msg_data; + ComaListener *listener = ctx; + + D_ASSERT( msg_data != NULL ); + D_ASSERT( ctx != NULL ); + + D_ASSUME( listener->func != NULL ); + + if (listener->func) + listener->func( listener->ctx, *p_arg ); + + return RS_OK; +} + |