replicator: Queue handling was pretty broken

diff --git a/src/replication/replicator/replicator-queue.c b/src/replication/replicator/replicator-queue.c
index 94875389f743a3ffcba86ab5f3440487820ee6a9..accd30092587518af186bcb81d9498a3fa5e6e7f 100644 (file)
--- a/src/replication/replicator/replicator-queue.c
+++ b/src/replication/replicator/replicator-queue.c
@@ -111,6 +111,7 @@ replicator_queue_add_int(struct replicator_queue *queue, const char *username,
        if (user == NULL) {
                user = i_new(struct replicator_user, 1);
                user->username = i_strdup(username);
+               hash_table_insert(queue->user_hash, user->username, user);
        } else {
                if (user->priority > priority) {
                        /* user already has a higher priority than this */
@@ -237,6 +238,8 @@ replicator_queue_handle_sync_lookups(struct replicator_queue *queue,
 void replicator_queue_push(struct replicator_queue *queue,
                           struct replicator_user *user)
 {
+       i_assert(user->popped);
+
        priorityq_add(queue->user_queue, &user->item);
        user->popped = FALSE;