TplActionChain: add _tpl_action_chain_start()

2 files changed, 20 insertions, 1 deletions

diff --git a/libempathy/action-chain-internal.h b/libempathy/action-chain-internal.h
index 674cc2b06..d2395d172 100644
--- a/libempathy/action-chain-internal.h
+++ b/libempathy/action-chain-internal.h
@@ -27,6 +27,7 @@
 typedef struct {
     GQueue *chain;
     GSimpleAsyncResult *simple;
+    gboolean running;
 } TplActionChain;
 
 TplActionChain *_tpl_action_chain_new_async (GObject *obj,
@@ -38,8 +39,10 @@ void _tpl_action_chain_append (TplActionChain *self, TplPendingAction func,
     gpointer user_data);
 void _tpl_action_chain_prepend (TplActionChain *self, TplPendingAction func,
     gpointer user_data);
+void _tpl_action_chain_start (TplActionChain *self);
 void _tpl_action_chain_continue (TplActionChain *self);
 void _tpl_action_chain_terminate (TplActionChain *self, const GError *error);
+
 gpointer _tpl_action_chain_get_object (TplActionChain *self);
 gboolean _tpl_action_chain_new_finish (GObject *source,
     GAsyncResult *result, GError **error);
diff --git a/libempathy/action-chain.c b/libempathy/action-chain.c
index df792e548..30217ddc5 100644
--- a/libempathy/action-chain.c
+++ b/libempathy/action-chain.c
@@ -104,18 +104,34 @@ _tpl_action_chain_append (TplActionChain *self,
   g_queue_push_tail (self->chain, l);
 }
 
+void
+_tpl_action_chain_start (TplActionChain *self)
+{
+  g_return_if_fail (!g_queue_is_empty (self->chain));
+
+  if (self->running)
+    return;
+
+  _tpl_action_chain_continue (self);
+}
 
 void
 _tpl_action_chain_continue (TplActionChain *self)
 {
   if (g_queue_is_empty (self->chain))
-    g_simple_async_result_complete (self->simple);
+    {
+      self->running = FALSE;
+      g_simple_async_result_complete (self->simple);
+    }
   else
     {
       TplActionLink *l = g_queue_pop_head (self->chain);
 
+      self->running = TRUE;
       l->action (self, l->user_data);
       link_free (l);
+      if (g_queue_is_empty (self->chain))
+        self->running = FALSE;
     }
 }