mirror of
https://git.notmuchmail.org/git/notmuch
synced 2024-11-24 20:08:10 +01:00
cli: change the data structure for notmuch address deduplication
Currently we key the address hash table with the case sensitive "name <address>". Switch to case insensitive keying with just address, and store the case sensitive name and address in linked lists. This will be helpful in adding support for different deduplication schemes in the future. There will be a slight performance penalty for the current full case sensitive name + address deduplication, but this is simpler as a whole when other deduplication schemes are added, and I expect the schemes to be added to become more popular than the current default. Aparet from the possible performance penalty, the only user visible change should be the change in the output ordering for --output=count. The order is not guaranteed (and is based on hash table traversal) currently anyway, so this should be of no consequence.
This commit is contained in:
parent
bcb695a716
commit
b8f4e7da3d
2 changed files with 66 additions and 15 deletions
|
@ -48,6 +48,7 @@ typedef GMimeCryptoContext notmuch_crypto_context_t;
|
|||
#include <dirent.h>
|
||||
#include <errno.h>
|
||||
#include <signal.h>
|
||||
#include <ctype.h>
|
||||
|
||||
#include "talloc-extra.h"
|
||||
|
||||
|
|
|
@ -265,30 +265,70 @@ static mailbox_t *new_mailbox (void *ctx, const char *name, const char *addr)
|
|||
return mailbox;
|
||||
}
|
||||
|
||||
static int mailbox_compare (const void *v1, const void *v2)
|
||||
{
|
||||
const mailbox_t *m1 = v1, *m2 = v2;
|
||||
int ret;
|
||||
|
||||
ret = strcmp_null (m1->name, m2->name);
|
||||
if (! ret)
|
||||
ret = strcmp (m1->addr, m2->addr);
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
/* Returns TRUE iff name and addr is duplicate. If not, stores the
|
||||
* name/addr pair in order to detect subsequent duplicates. */
|
||||
static notmuch_bool_t
|
||||
is_duplicate (const search_context_t *ctx, const char *name, const char *addr)
|
||||
{
|
||||
char *key;
|
||||
GList *list, *l;
|
||||
mailbox_t *mailbox;
|
||||
|
||||
key = talloc_asprintf (ctx->format, "%s <%s>", name, addr);
|
||||
list = g_hash_table_lookup (ctx->addresses, addr);
|
||||
if (list) {
|
||||
mailbox_t find = {
|
||||
.name = name,
|
||||
.addr = addr,
|
||||
};
|
||||
|
||||
l = g_list_find_custom (list, &find, mailbox_compare);
|
||||
if (l) {
|
||||
mailbox = l->data;
|
||||
mailbox->count++;
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
mailbox = new_mailbox (ctx->format, name, addr);
|
||||
if (! mailbox)
|
||||
return FALSE;
|
||||
|
||||
/*
|
||||
* XXX: It would be more efficient to prepend to the list, but
|
||||
* then we'd have to store the changed list head back to the
|
||||
* hash table. This check is here just to avoid the compiler
|
||||
* warning for unused result.
|
||||
*/
|
||||
if (list != g_list_append (list, mailbox))
|
||||
INTERNAL_ERROR ("appending to list changed list head\n");
|
||||
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
key = talloc_strdup (ctx->format, addr);
|
||||
if (! key)
|
||||
return FALSE;
|
||||
|
||||
mailbox = g_hash_table_lookup (ctx->addresses, key);
|
||||
if (mailbox) {
|
||||
mailbox->count++;
|
||||
talloc_free (key);
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
mailbox = new_mailbox (ctx->format, name, addr);
|
||||
if (! mailbox)
|
||||
return FALSE;
|
||||
|
||||
g_hash_table_insert (ctx->addresses, key, mailbox);
|
||||
list = g_list_append (NULL, mailbox);
|
||||
if (! list)
|
||||
return FALSE;
|
||||
|
||||
g_hash_table_insert (ctx->addresses, key, list);
|
||||
|
||||
return FALSE;
|
||||
}
|
||||
|
@ -401,12 +441,21 @@ _talloc_free_for_g_hash (void *ptr)
|
|||
}
|
||||
|
||||
static void
|
||||
print_hash_value (unused (gpointer key), gpointer value, gpointer user_data)
|
||||
_list_free_for_g_hash (void *ptr)
|
||||
{
|
||||
const mailbox_t *mailbox = value;
|
||||
search_context_t *ctx = user_data;
|
||||
g_list_free_full (ptr, _talloc_free_for_g_hash);
|
||||
}
|
||||
|
||||
print_mailbox (ctx, mailbox);
|
||||
static void
|
||||
print_list_value (void *mailbox, void *context)
|
||||
{
|
||||
print_mailbox (context, mailbox);
|
||||
}
|
||||
|
||||
static void
|
||||
print_hash_value (unused (void *key), void *list, void *context)
|
||||
{
|
||||
g_list_foreach (list, print_list_value, context);
|
||||
}
|
||||
|
||||
static int
|
||||
|
@ -794,8 +843,9 @@ notmuch_address_command (notmuch_config_t *config, int argc, char *argv[])
|
|||
argc - opt_index, argv + opt_index))
|
||||
return EXIT_FAILURE;
|
||||
|
||||
ctx->addresses = g_hash_table_new_full (g_str_hash, g_str_equal,
|
||||
_talloc_free_for_g_hash, _talloc_free_for_g_hash);
|
||||
ctx->addresses = g_hash_table_new_full (strcase_hash, strcase_equal,
|
||||
_talloc_free_for_g_hash,
|
||||
_list_free_for_g_hash);
|
||||
|
||||
ret = do_search_messages (ctx);
|
||||
|
||||
|
|
Loading…
Reference in a new issue