summaryrefslogtreecommitdiff
path: root/libzeitgeist/queued-proxy-wrapper.vala
diff options
context:
space:
mode:
authorSiegfried-Angel Gevatter Pujals <rainct@ubuntu.com>2012-07-09 17:40:20 +0200
committerSiegfried-Angel Gevatter Pujals <rainct@ubuntu.com>2012-07-09 17:42:08 +0200
commit001999894184178e26ad347a3112af8c26c32c1c (patch)
treeba4d003f3b55fbaf93e986d18e1eae1aef08b907 /libzeitgeist/queued-proxy-wrapper.vala
parent894871095f944addadd8c8b1edd97b5d635cf99e (diff)
downloadzeitgeist-001999894184178e26ad347a3112af8c26c32c1c.tar.gz
Style fix
Diffstat (limited to 'libzeitgeist/queued-proxy-wrapper.vala')
-rw-r--r--libzeitgeist/queued-proxy-wrapper.vala16
1 files changed, 12 insertions, 4 deletions
diff --git a/libzeitgeist/queued-proxy-wrapper.vala b/libzeitgeist/queued-proxy-wrapper.vala
index de7578b2..1dd72660 100644
--- a/libzeitgeist/queued-proxy-wrapper.vala
+++ b/libzeitgeist/queued-proxy-wrapper.vala
@@ -44,7 +44,8 @@ public abstract class QueuedProxyWrapper : Object
}
- protected void proxy_acquired(Object proxy) {
+ protected void proxy_acquired(Object proxy)
+ {
is_connected = true;
proxy_created = true;
proxy.notify["g-name-owner"].connect (name_owner_changed);
@@ -52,13 +53,19 @@ public abstract class QueuedProxyWrapper : Object
process_queued_methods ();
}
- protected void proxy_unavailable() {
+ protected void proxy_unavailable()
+ {
+ // Zeitgeist couldn't be auto-started. We'll run the callbacks
+ // anyway giving them an error.
+ method_dispatch_queue_reverse ();
+ foreach (QueuedMethod m in method_dispatch_queue)
+ {
+ }
// FIXME: process_queued_methods() with manual error callbacks
}
protected void process_queued_methods ()
{
- warning ("Processing queued methods...");
method_dispatch_queue.reverse ();
foreach (QueuedMethod m in method_dispatch_queue)
m.queued_method ();
@@ -79,7 +86,8 @@ public abstract class QueuedProxyWrapper : Object
protected abstract void on_connection_established ();
protected abstract void on_connection_lost ();
- protected async void wait_for_proxy (SourceFunc callback) {
+ protected async void wait_for_proxy (SourceFunc callback)
+ {
if (likely (proxy_created))
return;
if (method_dispatch_queue == null)