Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/olpcgames/dbusproxy.py
blob: a103e28bbb7cc00fa5900dea5873540e3d541392 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
"""Spike test for a safer networking system for DBUS-based objects"""
from olpcgames import eventwrap, util
from dbus import proxies
import logging 
log = logging.getLogger( 'dbus' )
log.setLevel( logging.DEBUG )

def wrap( value, tube=None,path=None ):
    """Wrap object with any required pygame-side proxies"""
    if isinstance( value,proxies._ProxyMethod ):
        return DBUSMethod( value, tube=tube, path=path )
    elif isinstance( value, proxies._DeferredMethod ):
        value._proxy_method = DBUSMethod( value._proxy_method, tube=tube, path=path )
        return value 
    elif isinstance( value, proxies.ProxyObject ):
        return DBUSProxy( value, tube=tube, path=path )
    else:
        return value 

class DBUSProxy( object ):
    """Proxy for the DBUS Proxy object"""
    def __init__( self, proxy, tube=None, path=None ):
        log.info( 'Creating Pygame-side proxy for %s (%s)', proxy,path )
        self.__proxy = proxy
        self.__tube = tube
        self.__path = path
    def __getattr__( self, key ):
        """Retrieve attribute of given key"""
        from dbus import proxies
        return wrap( getattr( self.__proxy, key ) )
    def add_signal_receiver( self, callback, eventName, interface, path=None, sender_keyword='sender'):
        """Add a new signal handler (which will be called many times) for given signal 
        """
        log.info( """Setting signal receiver %s for event %s on interface %s (object path %s) with sender_keyword = %r""",
            callback, eventName, interface, path, sender_keyword,
        )
        log.debug( """proxy: %s proxy.tube: %s""", self.__proxy, self.__proxy.tube )
        self.__tube.add_signal_receiver(
            Callback( callback ),
            eventName,
            interface,
            path = path or self.__path, 
            sender_keyword = sender_keyword,
        )

class DBUSMethod( object ):
    """DBUS method which does callbacks in the Pygame (eventwrapper) thread"""
    def __init__( self, proxy, tube,path ):
        log.info( 'Creating Pygame-side method proxy for %s', proxy )
        self.__proxy = proxy
        self.__tube = tube 
        self.__path = path
    def __call__( self, *args, **named ):
        """Perform the asynchronous call"""
        log.info( 'Calling proxy for %s with *%s, **%s', self.__proxy, args, named )
        callback, errback = named.get( 'reply_handler'), named.get( 'error_handler' )
        if not callback:
            raise TypeError( """Require a reply_handler named argument to do any asynchronous call""" )
        else:
            callback = Callback( callback )
        if not errback:
            errback = defaultErrback
        else:
            errback = Callback( errback )
        named['reply_handler'] = callback
        named['error_handler'] = errback
        return self.__proxy( *args, **named )

def defaultErrback( error ):
    """Log the error to stderr/log"""
    log.error( """Failure in DBUS call: %s""", error )

class Callback( object ):
    """PyGTK-side callback which generates a CallbackResult to process on the Pygame side"""
    def __init__( self, callable, callContext = None):
        """Initialize the callback to process results"""
        self.callable = callable
        if callContext is None:
            callContext = util.get_traceback( None )
        self.callContext = callContext
    def __call__( self, *args, **named ):
        """PyGTK-side callback operation"""
        log.info( 'Callback %s return value *%s, **%s', self.callable, args, named )
        from olpcgames import eventwrap
        args = [wrap(a) for a in args]
        named = dict([
            (k,wrap(v)) for k,v in named.items()
        ])
        eventwrap.post( 
            eventwrap.CallbackResult( 
                self.callable, args, named, callContext = self.callContext 
            )
        )