From 912528253fcf1fc43c1a2d02ffe6e540fe60d8e7 Mon Sep 17 00:00:00 2001
From: Vincent Vinet <vince.vinet@gmail.com>
Date: Mon, 19 Oct 2009 20:15:41 +0000
Subject: Merge the TProbe Integration and fix merging induced bugs

---
(limited to 'tutorius/dbustools.py')

diff --git a/tutorius/dbustools.py b/tutorius/dbustools.py
new file mode 100644
index 0000000..1b685d7
--- /dev/null
+++ b/tutorius/dbustools.py
@@ -0,0 +1,41 @@
+import logging
+LOGGER = logging.getLogger("sugar.tutorius.dbustools")
+
+def save_args(callable, *xargs, **xkwargs):
+    def __call(*args, **kwargs):
+        kw = dict()
+        kw.update(kwargs)
+        kw.update(xkwargs)
+        return callable(*(xargs+args), **kw) 
+    return __call
+
+def ignore(*args):
+    LOGGER.debug("Unhandled asynchronous dbus call response with arguments: %s", str(args))
+
+def logError(error):
+    LOGGER.error("Unhandled asynchronous dbus call error: %s", error)
+
+def remote_call(callable, args, return_cb=None, error_cb=None, block=False):
+    reply_cb = return_cb or ignore
+    errhandler_cb = error_cb or logError
+    if block:
+        try:
+            ret_val = callable(*args)
+            LOGGER.debug("remote_call return arguments: %s", str(ret_val))
+        except Exception, e:
+            #Use the specified error handler even for blocking calls
+            errhandler_cb(e)
+
+        #Return value signature might be :
+        if ret_val is None:
+            #Nothing
+            return reply_cb()
+        elif type(ret_val) in (list, tuple):
+            #Several parameters
+            return reply_cb(*ret_val)
+        else:
+            #One parameter
+            return reply_cb(ret_val)
+    else:
+        callable(*args, reply_handler=reply_cb, error_handler=errhandler_cb)
+
--
cgit v0.9.1