[Telepathy-commits] [telepathy-glib/master] TpMessageMixin: add tp_message_mixin_set_rescued

[Simon McVittie]

---
 telepathy-glib/message-mixin.c |   24 ++++++++++++++++++++++++
 telepathy-glib/message-mixin.h |    2 ++
 2 files changed, 26 insertions(+), 0 deletions(-)

diff --git a/telepathy-glib/message-mixin.c b/telepathy-glib/message-mixin.c
index 5a0bbba..3fca55c 100644
--- a/telepathy-glib/message-mixin.c
+++ b/telepathy-glib/message-mixin.c
@@ -1407,6 +1407,30 @@ tp_message_mixin_has_pending_messages (GObject *object,
 
 
 /**
+ * tp_message_mixin_set_rescued:
+ * @obj: An object with this mixin
+ *
+ * Mark all pending messages as having been "rescued" from a channel that
+ * previously closed.
+ */
+void
+tp_message_mixin_set_rescued (GObject *obj)
+{
+  TpMessageMixin *mixin = TP_MESSAGE_MIXIN (obj);
+  GList *cur;
+
+  for (cur = g_queue_peek_head_link (mixin->priv->pending);
+       cur != NULL;
+       cur = cur->next)
+    {
+      TpMessage *msg = cur->data;
+
+      tp_message_set_boolean (msg, 0, "rescued", TRUE);
+    }
+}
+
+
+/**
  * TpMessageMixinOutgoingMessage:
  * @flags: Flags indicating how this message should be sent
  * @parts: The parts that make up the message (an array of #GHashTable,
diff --git a/telepathy-glib/message-mixin.h b/telepathy-glib/message-mixin.h
index 9fd2bc8..d29a705 100644
--- a/telepathy-glib/message-mixin.h
+++ b/telepathy-glib/message-mixin.h
@@ -83,6 +83,8 @@ guint tp_message_mixin_take_received (GObject *object, TpMessage *message);
 gboolean tp_message_mixin_has_pending_messages (GObject *object,
     TpHandle *first_sender);
 
+void tp_message_mixin_set_rescued (GObject *obj);
+
 
 /* Sending */
 
-- 
1.5.6.5