diff options
Diffstat (limited to 'camel/tests/folder/test8.c')
| -rw-r--r-- | camel/tests/folder/test8.c | 222 |
1 files changed, 222 insertions, 0 deletions
diff --git a/camel/tests/folder/test8.c b/camel/tests/folder/test8.c new file mode 100644 index 0000000000..30552cf782 --- /dev/null +++ b/camel/tests/folder/test8.c @@ -0,0 +1,222 @@ +/* threaded folder testing */ + +#include "camel-test.h" +#include "folders.h" +#include "messages.h" + +#include <camel/camel-exception.h> +#include <camel/camel-service.h> +#include <camel/camel-session.h> +#include <camel/camel-store.h> + +#define MAX_MESSAGES (100) +#define MAX_THREADS (10) + +#define d(x) + +#ifndef ENABLE_THREADS +int main(int argc, char **argv) +{ + printf("Test %s is only compiled with threads enabled\n", argv[0]); + return 77; +} +#else + +#include <pthread.h> + +/* god, who designed this horrid interface */ +static char *auth_callback(CamelAuthCallbackMode mode, + char *data, gboolean secret, + CamelService *service, char *item, + CamelException *ex) +{ + return NULL; +} + +#define ARRAY_LEN(x) (sizeof(x)/sizeof(x[0])) + +static char *local_providers[] = { + "mbox", + "mh", + "maildir" +}; + +static void +test_add_message(CamelFolder *folder, int j) +{ + CamelMimeMessage *msg; + char *content; + char *subject; + CamelException ex; + + camel_exception_init(&ex); + + push("creating message %d\n", j); + msg = test_message_create_simple(); + content = g_strdup_printf("Test message %d contents\n\n", j); + test_message_set_content_simple((CamelMimePart *)msg, 0, "text/plain", + content, strlen(content)); + test_free(content); + subject = g_strdup_printf("Test message %d subject", j); + camel_mime_message_set_subject(msg, subject); + pull(); + + push("appending simple message %d", j); + camel_folder_append_message(folder, msg, NULL, &ex); + check_msg(!camel_exception_is_set(&ex), "%s", camel_exception_get_description(&ex)); + pull(); + + check_unref(msg, 1); +} + +struct _threadinfo { + int id; + CamelFolder *folder; +}; + +static void * +worker(void *d) +{ + struct _threadinfo *info = d; + int i, j, id = info->id; + char *sub, *content; + GPtrArray *res; + CamelException *ex = camel_exception_new(); + CamelMimeMessage *msg; + + /* we add a message, search for it, twiddle some flags, delete it */ + /* and flat out */ + for (i=0;i<MAX_MESSAGES;i++) { + d(printf("Thread %ld message %i\n", pthread_self(), i)); + test_add_message(info->folder, id+i); + + sub = g_strdup_printf("(match-all (header-contains \"subject\" \"message %d subject\"))", id+i); + + push("searching for message %d\n\tusing: %s", id+i, sub); + res = camel_folder_search_by_expression(info->folder, sub, ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + check_msg(res->len == 1, "res->len = %d", res->len); + pull(); + + push("getting message '%s'", res->pdata[0]); + msg = camel_folder_get_message(info->folder, (char *)res->pdata[0], ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + pull(); + + push("comparing content"); + content = g_strdup_printf("Test message %d contents\n\n", id+i); + test_message_compare_content(camel_medium_get_content_object((CamelMedium *)msg), content, strlen(content)); + test_free(content); + + push("deleting message, cleanup"); + j=(100.0*rand()/(RAND_MAX+1.0)); + if (j<=70) { + camel_folder_delete_message(info->folder, res->pdata[0]); + } + + camel_folder_search_free(info->folder, res); + res = NULL; + test_free(sub); + + check_unref(msg, 1); + pull(); + + /* about 1-in 100 calls will expunge */ + j=(200.0*rand()/(RAND_MAX+1.0)); + if (j<=2) { + d(printf("Forcing an expuge\n")); + push("expunging folder"); + camel_folder_expunge(info->folder, ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + pull(); + } + } + + camel_exception_free(ex); + + return info; +} + +int main(int argc, char **argv) +{ + CamelSession *session; + CamelException *ex; + int i, j, index; + char *path; + CamelStore *store; + pthread_t threads[MAX_THREADS]; + struct _threadinfo *info; + CamelFolder *folder; + GPtrArray *uids; + + camel_test_init(argc, argv); + + ex = camel_exception_new(); + + /* clear out any camel-test data */ + system("/bin/rm -rf /tmp/camel-test"); + + session = camel_session_new("/tmp/camel-test", auth_callback, NULL, NULL); + + for (j=0;j<ARRAY_LEN(local_providers);j++) { + for (index=0;index<2;index++) { + path = g_strdup_printf("method %s %s", local_providers[j], index?"indexed":"nonindexed"); + camel_test_start(path); + test_free(path); + + push("trying %s index %d", local_providers[j], index); + path = g_strdup_printf("%s:///tmp/camel-test/%s", local_providers[j], local_providers[j]); + store = camel_session_get_store(session, path, ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + test_free(path); + + if (index == 0) + folder = camel_store_get_folder(store, "testbox", CAMEL_STORE_FOLDER_CREATE, ex); + else + folder = camel_store_get_folder(store, "testbox", + CAMEL_STORE_FOLDER_CREATE|CAMEL_STORE_FOLDER_BODY_INDEX, ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + + for (i=0;i<MAX_THREADS;i++) { + info = g_malloc(sizeof(*info)); + info->id = i*MAX_MESSAGES; + info->folder = folder; + pthread_create(&threads[i], 0, worker, info); + } + + for (i=0;i<MAX_THREADS;i++) { + pthread_join(threads[i], (void **)&info); + g_free(info); + } + pull(); + + push("deleting remaining messages"); + uids = camel_folder_get_uids(folder); + for (i=0;i<uids->len;i++) { + camel_folder_delete_message(folder, uids->pdata[i]); + } + camel_folder_free_uids(folder, uids); + + camel_folder_expunge(folder, ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + + check_unref(folder, 1); + + camel_store_delete_folder(store, "testbox", ex); + check_msg(!camel_exception_is_set(ex), "%s", camel_exception_get_description(ex)); + + check_unref(store, 1); + + pull(); + + camel_test_end(); + } + } + + camel_object_unref((CamelObject *)session); + camel_exception_free(ex); + + return 0; +} + +#endif /* ENABLE_THREADS */ |