blob: a71e9428c557eb4453aa842fc5cbba358d88cb50 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
/* Copyright (c) 2013-2018 Dovecot authors, see the included COPYING file */
#include "lib.h"
#include "auth-master.h"
#include "replicator-queue.h"
#define REPLICATOR_AUTH_SERVICE_NAME "replicator"
void replicator_queue_add_auth_users(struct replicator_queue *queue,
const char *auth_socket_path,
const char *usermask, time_t last_update)
{
struct auth_master_connection *auth_conn;
struct auth_master_user_list_ctx *ctx;
struct auth_user_info user_info;
struct replicator_user *user;
const char *username;
auth_conn = auth_master_init(auth_socket_path,
AUTH_MASTER_FLAG_NO_IDLE_TIMEOUT);
i_zero(&user_info);
user_info.service = REPLICATOR_AUTH_SERVICE_NAME;
/* add all users into replication queue, so that we can start doing
full syncs for everyone whose state can't be found */
ctx = auth_master_user_list_init(auth_conn, usermask, &user_info);
while ((username = auth_master_user_list_next(ctx)) != NULL) {
user = replicator_queue_add(queue, username,
REPLICATION_PRIORITY_NONE);
user->last_update = last_update;
}
if (auth_master_user_list_deinit(&ctx) < 0)
i_error("listing users failed, can't replicate existing data");
auth_master_deinit(&auth_conn);
}
|
