From 6a766351410912acde101b6fa01488338efca5c8 Mon Sep 17 00:00:00 2001 From: NotZed Date: Thu, 23 Mar 2000 19:57:31 +0000 Subject: Added async search api. 2000-03-22 NotZed * camel-folder.[ch]: Added async search api. * providers/mbox/camel-mbox-search.c (camel_mbox_folder_search_by_expression): Changed to use an asynchronous interface. (camel_mbox_folder_search_cancel): Cancel function for async interface. svn path=/trunk/; revision=2155 --- camel/providers/mbox/camel-mbox-search.c | 120 ++++++++++++++++++++++++------- 1 file changed, 96 insertions(+), 24 deletions(-) (limited to 'camel/providers/mbox/camel-mbox-search.c') diff --git a/camel/providers/mbox/camel-mbox-search.c b/camel/providers/mbox/camel-mbox-search.c index 47d4012c4c..22aa599709 100644 --- a/camel/providers/mbox/camel-mbox-search.c +++ b/camel/providers/mbox/camel-mbox-search.c @@ -76,7 +76,8 @@ struct _searchcontext { - int whatever; + int id; /* id of this search */ + int cancelled; /* search cancelled? */ CamelFolder *folder; @@ -268,11 +269,11 @@ static struct { { "header-contains", func_header_contains, 0 }, }; -GList * -camel_mbox_folder_search_by_expression(CamelFolder *folder, const char *expression, CamelException *ex) +int camel_mbox_folder_search_by_expression(CamelFolder *folder, const char *expression, + CamelSearchFunc *func, void *data, CamelException *ex) { int i; - struct _searchcontext ctx; + struct _searchcontext *ctx; GList *matches = NULL; ESExp *f; ESExpResult *r; @@ -280,31 +281,39 @@ camel_mbox_folder_search_by_expression(CamelFolder *folder, const char *expressi /* setup our expression evaluator */ f = e_sexp_new(); + ctx = g_malloc0(sizeof(*ctx)); + + ctx->id = ((CamelMboxFolder *)folder)->search_id++; + /* setup out context */ - ctx.folder = folder; - ctx.summary = camel_folder_get_summary(folder, ex); - gtk_object_ref((GtkObject *)ctx.summary); + ctx->folder = folder; + ctx->summary = camel_folder_get_summary(folder, ex); - if (camel_exception_get_id (ex)) { + if (ctx->summary == NULL || camel_exception_get_id (ex)) { printf ("Cannot get summary\n" "Full description : %s\n", camel_exception_get_description (ex)); - /* FIXME: free shit */ - return NULL; + g_free(ctx); + gtk_object_unref((GtkObject *)f); + return -1; } + gtk_object_ref((GtkObject *)ctx->summary); - ctx.message_info = camel_folder_summary_get_message_info_list(ctx.summary); - ctx.message_current = NULL; - ctx.index = ibex_open(CAMEL_MBOX_FOLDER(folder)->index_file_path, FALSE); - if (!ctx.index) { - perror("Cannot open index file"); + /* FIXME: the index should be global to the folder */ + ctx->message_info = camel_folder_summary_get_message_info_list(ctx->summary); + ctx->message_current = NULL; + ctx->index = ibex_open(CAMEL_MBOX_FOLDER(folder)->index_file_path, FALSE); + if (!ctx->index) { + perror("Cannot open index file (ignored)"); } + ((CamelMboxFolder *)folder)->searches = g_list_append(((CamelMboxFolder *)folder)->searches, ctx); + for(i=0;ivalue.ptrarray, i))); matches = g_list_prepend(matches, g_strdup(g_ptr_array_index(r->value.ptrarray, i))); } + if (!ctx->cancelled) { + func(folder, ctx->id, TRUE, matches, data); + } + g_list_free(matches); e_sexp_result_free(r); } else { printf("no result!\n"); } - if (ctx.index) - ibex_close(ctx.index); + if (ctx->index) + ibex_close(ctx->index); - gtk_object_unref((GtkObject *)ctx.summary); + gtk_object_unref((GtkObject *)ctx->summary); gtk_object_unref((GtkObject *)f); + i = ctx->id; - return matches; + ((CamelMboxFolder *)folder)->searches = g_list_remove(((CamelMboxFolder *)folder)->searches, ctx); + + g_free(ctx); + + return i; +} + +static struct _searchcontext * +find_context(CamelMboxFolder *f, int id) +{ + struct _searchcontext *ctx; + GList *l; + + l = f->searches; + while (l) { + ctx = l->data; + if (ctx->id == id) { + return ctx; + } + l = g_list_next(l); + } + + return NULL; +} + +gboolean camel_mbox_folder_search_complete(CamelFolder *folder, int searchid, int wait, CamelException *ex) +{ + struct _searchcontext *ctx; + + ctx = find_context((CamelMboxFolder *)folder, searchid); + + if (ctx) + return ctx->cancelled; + + /* if its been removed, its complete ... */ + return TRUE; +} + +void camel_mbox_folder_search_cancel(CamelFolder *folder, int searchid, CamelException *ex) +{ + struct _searchcontext *ctx; + + ctx = find_context((CamelMboxFolder *)folder, searchid); + if (ctx) { + ctx->cancelled = TRUE; + return; + } + + /* FIXME: set exception, return */ } #else /* HAVE_FILTER */ -GList * -camel_mbox_folder_search_by_expression(CamelFolder *folder, const char *expression, CamelException *ex) +int camel_mbox_folder_search_by_expression(CamelFolder *folder, const char *expression, + CamelSearchFunc *func, void *data, CamelException *ex) { - return NULL; + return -1; +} + +gboolean camel_mbox_folder_search_complete(CamelFolder *folder, int searchid, int wait, CamelException *ex) +{ + return TRUE; +} + +void camel_mbox_folder_search_cancel(CamelFolder *folder, int searchid, CamelException *ex) +{ + /* empty */ } #endif /*! HAVE_FILTER */ -- cgit v1.2.3