Merge with camel-async.

svn path=/trunk/; revision=4687

1 files changed, 126 insertions, 3 deletions

diff --git a/mail/message-thread.c b/mail/message-thread.c
index f199c27341..fa362f04ee 100644
--- a/mail/message-thread.c
+++ b/mail/message-thread.c
@@ -31,9 +31,15 @@
 #include <ctype.h>
 
 #include "message-thread.h"
+#include "mail-tools.h"
+#include "mail-threads.h"
 
 #define d(x)
 
+static struct _container *thread_messages(CamelFolder *folder, GPtrArray *uids);
+static void thread_messages_free(struct _container *);
+
+/* for debug only */
 int dump_tree(struct _container *c, int depth);
 
 static void
@@ -331,7 +337,7 @@ dump_tree(struct _container *c, int depth)
 	return count;
 }
 
-void thread_messages_free(struct _container *c)
+static void thread_messages_free(struct _container *c)
 {
 	struct _container *n;
 
@@ -407,7 +413,7 @@ sort_thread(struct _container **cp)
 	*cp = head;
 }
 
-struct _container *
+static struct _container *
 thread_messages(CamelFolder *folder, GPtrArray *uids)
 {
 	GHashTable *id_table, *no_id_table;
@@ -419,13 +425,20 @@ thread_messages(CamelFolder *folder, GPtrArray *uids)
 	no_id_table = g_hash_table_new(NULL, NULL);
 	for (i=0;i<uids->len;i++) {
 		const CamelMessageInfo *mi;
+		mail_tool_camel_lock_up ();
 		mi = camel_folder_get_message_info (folder, uids->pdata[i]);
+		mail_tool_camel_lock_down ();
 
 		if (mi == NULL) {
 			g_warning("Folder doesn't contain uid %s", (char *)uids->pdata[i]);
 			continue;
 		}
 
+		if (mi == NULL) {
+			g_warning("Folder doesn't contain uid %s", uids->pdata[i]);
+			continue;
+		}
+
 		if (mi->message_id) {
 			d(printf("doing : %s\n", mi->message_id));
 			c = g_hash_table_lookup(id_table, mi->message_id);
@@ -495,6 +508,116 @@ thread_messages(CamelFolder *folder, GPtrArray *uids)
 	return head;
 }
 
+/* ** THREAD MESSAGES ***************************************************** */
+
+typedef struct thread_messages_input_s {
+	MessageList *ml;
+	GPtrArray *uids;
+	gboolean use_camel_uidfree;
+	void (*build) (MessageList *, ETreePath *, 
+		       struct _container *, int *);
+} thread_messages_input_t;
+
+typedef struct thread_messages_data_s {
+	struct _container *container;
+	int row;
+} thread_messages_data_t;
+
+static gchar *describe_thread_messages (gpointer in_data, gboolean gerund);
+static void setup_thread_messages   (gpointer in_data, gpointer op_data, CamelException *ex);
+static void do_thread_messages      (gpointer in_data, gpointer op_data, CamelException *ex);
+static void cleanup_thread_messages (gpointer in_data, gpointer op_data, CamelException *ex);
+
+static gchar *describe_thread_messages (gpointer in_data, gboolean gerund)
+{
+	if (gerund)
+		return g_strdup ("Threading message list");
+	else
+		return g_strdup ("Thread message list");
+}
+
+static void setup_thread_messages (gpointer in_data, gpointer op_data, CamelException *ex)
+{
+	thread_messages_input_t *input = (thread_messages_input_t *) in_data;
+
+	if (!IS_MESSAGE_LIST (input->ml)) {
+		camel_exception_set (ex, CAMEL_EXCEPTION_INVALID_PARAM,
+				     "No messagelist to thread was provided to thread_messages");
+		return;
+	}
+
+	if (!input->uids) {
+		camel_exception_set (ex, CAMEL_EXCEPTION_INVALID_PARAM,
+				     "No uids were provided to thread_messages");
+		return;
+	}
+
+	if (!input->build) {
+		camel_exception_set (ex, CAMEL_EXCEPTION_INVALID_PARAM,
+				     "No build callback provided to thread_messages");
+		return;
+	}
+
+	gtk_object_ref (GTK_OBJECT (input->ml));
+}
+
+static void do_thread_messages (gpointer in_data, gpointer op_data, CamelException *ex)
+{
+	thread_messages_input_t *input = (thread_messages_input_t *) in_data;
+	thread_messages_data_t *data = (thread_messages_data_t *) op_data;
+
+	data->container = thread_messages (input->ml->folder, input->uids);
+	data->row = 0;
+}
+
+static void cleanup_thread_messages (gpointer in_data, gpointer op_data, CamelException *ex)
+{
+	thread_messages_input_t *input = (thread_messages_input_t *) in_data;
+	thread_messages_data_t *data = (thread_messages_data_t *) op_data;
+
+	(input->build) (input->ml, input->ml->tree_root, 
+			data->container, &(data->row));
+	thread_messages_free (data->container);
+
+	if (input->use_camel_uidfree) {
+		mail_tool_camel_lock_up ();
+		camel_folder_free_uids (input->ml->folder, input->uids);
+		mail_tool_camel_lock_down ();
+	} else {
+		g_strfreev ((char **)input->uids->pdata);
+		g_ptr_array_free (input->uids, FALSE);
+	}
+
+	gtk_object_unref (GTK_OBJECT (input->ml));
+}
+
+static const mail_operation_spec op_thread_messages =
+{
+	describe_thread_messages,
+	sizeof (thread_messages_data_t),
+	setup_thread_messages,
+	do_thread_messages,
+	cleanup_thread_messages
+};
+
+void mail_do_thread_messages (MessageList *ml, GPtrArray *uids, 
+			      gboolean use_camel_uidfree,
+			      void (*build) (MessageList *, ETreePath *,
+					     struct _container *, int *))
+{
+	thread_messages_input_t *input;
+
+	input = g_new (thread_messages_input_t, 1);
+	input->ml = ml;
+	input->uids = uids;
+	input->use_camel_uidfree = use_camel_uidfree;
+	input->build = build;
+
+	mail_operation_queue (&op_thread_messages, input, TRUE);
+}
+
+/* ************************************************************************ */
+
 #ifdef STANDALONE
 
 static char *
@@ -546,7 +669,7 @@ main (int argc, char**argv)
 	}
 #endif
 
-	summary = camel_folder_get_summary(folder, ex);
+	summary = camel_folder_get_summary(folder);
 	thread_messages((CamelMessageInfo **)summary->pdata, summary->len);
 
 	return 0;