doveadm-connection.c revision 892e25e1c0caad62ced087d9eba2741a59e3d9ce
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen/* Copyright (c) 2010-2016 Dovecot authors, see the included COPYING file */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "lib.h"
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen#include "ioloop.h"
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen#include "net.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "istream.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "ostream.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "array.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "str.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "strescape.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "llist.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "master-service.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "user-directory.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "mail-host.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "director.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "director-host.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "director-request.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "director-connection.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "doveadm-connection.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include <unistd.h>
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#define DOVEADM_PROTOCOL_VERSION_MAJOR 1
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#define DOVEADM_HANDSHAKE "VERSION\tdirector-doveadm\t1\t0\n"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#define MAX_VALID_VHOST_COUNT 1000
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstruct doveadm_connection {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct doveadm_connection *prev, *next;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen int fd;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct io *io;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct istream *input;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct ostream *output;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct director *dir;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen bool handshaked:1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen};
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic struct doveadm_connection *doveadm_connections;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void doveadm_connection_deinit(struct doveadm_connection **_conn);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void doveadm_cmd_host_list(struct doveadm_connection *conn)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_host *const *hostp;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen string_t *str = t_str_new(1024);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen array_foreach(mail_hosts_get(conn->dir->mail_hosts), hostp) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_printfa(str, "%s\t%u\t%u\t",
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen net_ip2addr(&(*hostp)->ip), (*hostp)->vhost_count,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen (*hostp)->user_count);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_append_tabescaped(str, mail_host_get_tag(*hostp));
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_printfa(str, "\t%c\t%ld", (*hostp)->down ? 'D' : 'U',
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen (long)(*hostp)->last_updown_change);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_append_c(str, '\n');
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_append_c(str, '\n');
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend(conn->output, str_data(str), str_len(str));
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen}
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void doveadm_cmd_host_list_removed(struct doveadm_connection *conn)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_host_list *orig_hosts_list;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_host *const *orig_hosts, *const *cur_hosts;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen unsigned int i, j, orig_hosts_count, cur_hosts_count;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen string_t *str = t_str_new(1024);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen int ret;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen orig_hosts_list = mail_hosts_init(conn->dir->set->director_consistent_hashing);
8aacc9e7c84f8376822823ec98c2f551d4919b2eTimo Sirainen (void)mail_hosts_parse_and_add(orig_hosts_list,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen conn->dir->set->director_mail_servers);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen orig_hosts = array_get(mail_hosts_get(orig_hosts_list),
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen &orig_hosts_count);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen cur_hosts = array_get(mail_hosts_get(conn->dir->mail_hosts),
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen &cur_hosts_count);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen /* the hosts are sorted by IP */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen for (i = j = 0; i < orig_hosts_count && j < cur_hosts_count; ) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen ret = net_ip_cmp(&orig_hosts[i]->ip, &cur_hosts[j]->ip);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (ret == 0)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen i++, j++;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else if (ret > 0)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen j++;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_printfa(str, "%s\n",
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen net_ip2addr(&orig_hosts[i]->ip));
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen i++;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen for (; i < orig_hosts_count; i++)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_printfa(str, "%s\n", net_ip2addr(&orig_hosts[i]->ip));
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_append_c(str, '\n');
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend(conn->output, str_data(str), str_len(str));
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen mail_hosts_deinit(&orig_hosts_list);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen}
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainenstatic void doveadm_director_append_status(struct director *dir, string_t *str)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen{
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (!dir->ring_handshaked)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_append(str, "handshaking");
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else if (dir->ring_synced)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_append(str, "synced");
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else {
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_printfa(str, "syncing - last sync %d secs ago",
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen (int)(ioloop_time - dir->ring_last_sync_time));
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen}
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainenstatic void
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainendoveadm_director_connection_append_status(struct director_connection *conn,
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen string_t *str)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen{
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (!director_connection_is_handshaked(conn))
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_append(str, "handshaking");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen else if (director_connection_is_synced(conn))
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_append(str, "synced");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen else
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_append(str, "syncing");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainendoveadm_director_host_append_status(struct director *dir,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const struct director_host *host,
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen string_t *str)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct director_connection *conn = NULL;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (dir->left != NULL &&
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen director_connection_get_host(dir->left) == host)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen conn = dir->left;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else if (dir->right != NULL &&
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen director_connection_get_host(dir->right) == host)
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen conn = dir->right;
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen else {
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen /* we might have a connection that is being connected */
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen struct director_connection *const *connp;
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen array_foreach(&dir->connections, connp) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (director_connection_get_host(*connp) == host) {
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen conn = *connp;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen break;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (conn != NULL)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen doveadm_director_connection_append_status(conn, str);
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainenstatic void doveadm_cmd_director_list(struct doveadm_connection *conn)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen struct director *dir = conn->dir;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct director_host *const *hostp;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen string_t *str = t_str_new(1024);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *type;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen bool left, right;
a40d26f83af808a0ea1e212c001d682a96d870b0Timo Sirainen time_t last_failed;
56f45b3f3ae20e5c933701f4657dda5ef1916855Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen array_foreach(&dir->dir_hosts, hostp) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const struct director_host *host = *hostp;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen left = dir->left != NULL &&
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen director_connection_get_host(dir->left) == host;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen right = dir->right != NULL &&
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen director_connection_get_host(dir->right) == host;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (host->removed)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen type = "removed";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else if (dir->self_host == host)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen type = "self";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else if (left)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen type = right ? "l+r" : "left";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else if (right)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen type = "right";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen type = "";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen last_failed = I_MAX(host->last_network_failure,
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen host->last_protocol_failure);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen str_printfa(str, "%s\t%u\t%s\t%lu\t",
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen net_ip2addr(&host->ip), host->port, type,
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen (unsigned long)last_failed);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (dir->self_host == host)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen doveadm_director_append_status(dir, str);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen doveadm_director_host_append_status(dir, host, str);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_append_c(str, '\n');
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_append_c(str, '\n');
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen o_stream_nsend(conn->output, str_data(str), str_len(str));
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic int
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainendoveadm_cmd_director_add(struct doveadm_connection *conn,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *const *args)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen struct director_host *host;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen struct ip_addr ip;
d565eaa943f29a49b97230ced57eec40ee65b4f9Timo Sirainen in_port_t port = conn->dir->self_port;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (args[0] == NULL ||
da5d50534cfca45d0aaaf0bdac17b287b4588809Timo Sirainen net_addr2ip(args[0], &ip) < 0 ||
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen (args[1] != NULL && net_str2port(args[1], &port) < 0)) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen i_error("doveadm sent invalid DIRECTOR-ADD parameters");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (director_host_lookup(conn->dir, &ip, port) == NULL) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen host = director_host_add(conn->dir, &ip, port);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen director_notify_ring_added(host, conn->dir->self_host);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen o_stream_nsend(conn->output, "OK\n", 3);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen return 1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic int
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainendoveadm_cmd_director_remove(struct doveadm_connection *conn,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *const *args)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct director_host *host;
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen struct ip_addr ip;
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen in_port_t port = 0;
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen if (args[0] == NULL ||
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen net_addr2ip(args[0], &ip) < 0 ||
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen (args[1] != NULL && net_str2port(args[1], &port) < 0)) {
da5d50534cfca45d0aaaf0bdac17b287b4588809Timo Sirainen i_error("doveadm sent invalid DIRECTOR-REMOVE parameters");
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen host = port != 0 ?
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen director_host_lookup(conn->dir, &ip, port) :
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen director_host_lookup_ip(conn->dir, &ip);
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen if (host == NULL)
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen o_stream_nsend_str(conn->output, "NOTFOUND\n");
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen else {
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen director_ring_remove(host, conn->dir->self_host);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend(conn->output, "OK\n", 3);
65689cffc97a4e7338d83e95624cd4996770d197Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen return 1;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen}
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainenstatic int
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainendoveadm_cmd_host_set_or_update(struct doveadm_connection *conn,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *const *args, bool update)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
da5d50534cfca45d0aaaf0bdac17b287b4588809Timo Sirainen struct director *dir = conn->dir;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *ip_str, *tag = "";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_host *host;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct ip_addr ip;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen unsigned int vhost_count = UINT_MAX;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen ip_str = args[0];
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen if (ip_str != NULL) {
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen tag = strchr(ip_str, '@');
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen if (tag == NULL)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen tag = "";
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen ip_str = t_strdup_until(ip_str, tag++);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen if (ip_str == NULL || net_addr2ip(ip_str, &ip) < 0 ||
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen (args[1] != NULL && str_to_uint(args[1], &vhost_count) < 0) ||
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen (args[1] == NULL && update)) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen i_error("doveadm sent invalid %s parameters",
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen update ? "HOST-UPDATE" : "HOST-SET");
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen }
ba482d3624ca4f1b3d638e6e8470ba5134f21493Timo Sirainen if (vhost_count > MAX_VALID_VHOST_COUNT && vhost_count != UINT_MAX) {
ba482d3624ca4f1b3d638e6e8470ba5134f21493Timo Sirainen o_stream_nsend_str(conn->output, "vhost count too large\n");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen return 1;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen host = mail_host_lookup(dir->mail_hosts, &ip);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (host == NULL) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (update) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend_str(conn->output, "NOTFOUND\n");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen return 1;
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen }
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen host = mail_host_add_ip(dir->mail_hosts, &ip, tag);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen } else if (tag[0] != '\0' && strcmp(mail_host_get_tag(host), tag) != 0) {
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen o_stream_nsend_str(conn->output, "host tag can't be changed\n");
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen return 1;
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen } else if (host->desynced) {
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen o_stream_nsend_str(conn->output,
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen "host is already being updated - try again later\n");
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen return 1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen if (vhost_count != UINT_MAX)
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen mail_host_set_vhost_count(host, vhost_count);
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen /* NOTE: we don't support changing a tag for an existing host.
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen it needs to be removed first. otherwise it would be a bit ugly to
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen handle. */
fd2f5fbc1f07aa93e2214a28cdf02437fb7d06c8Timo Sirainen director_update_host(dir, dir->self_host, NULL, host);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen o_stream_nsend(conn->output, "OK\n", 3);
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen return 1;
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen}
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic int
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainendoveadm_cmd_host_set(struct doveadm_connection *conn, const char *const *args)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen return doveadm_cmd_host_set_or_update(conn, args, FALSE);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainenstatic int
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainendoveadm_cmd_host_update(struct doveadm_connection *conn, const char *const *args)
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen{
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen return doveadm_cmd_host_set_or_update(conn, args, TRUE);
089756ceca55966f1a70e8591f6086026e51015cTimo Sirainen}
089756ceca55966f1a70e8591f6086026e51015cTimo Sirainen
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainenstatic int
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainendoveadm_cmd_host_updown(struct doveadm_connection *conn, bool down,
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen const char *const *args)
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen{
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen struct mail_host *host;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct ip_addr ip;
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen if (args[0] == NULL || net_addr2ip(args[0], &ip) < 0) {
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen i_error("doveadm sent invalid %s parameters: %s",
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen down ? "HOST-DOWN" : "HOST-UP",
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen args[0] == NULL ? "" : args[0]);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen host = mail_host_lookup(conn->dir->mail_hosts, &ip);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (host == NULL) {
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen o_stream_nsend_str(conn->output, "NOTFOUND\n");
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen return 1;
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen }
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen if (host->down == down)
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen ;
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen else if (host->desynced) {
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen o_stream_nsend_str(conn->output,
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen "host is already being updated - try again later\n");
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen return 1;
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen } else {
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen mail_host_set_down(host, down, ioloop_time);
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen director_update_host(conn->dir, conn->dir->self_host,
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen NULL, host);
72cbf33ae81fde08384d30c779ff540752d9256cTimo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend(conn->output, "OK\n", 3);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return 1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic int
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainendoveadm_cmd_host_remove(struct doveadm_connection *conn,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *const *args)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_host *host;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct ip_addr ip;
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen if (args[0] == NULL || net_addr2ip(args[0], &ip) < 0) {
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen i_error("doveadm sent invalid HOST-REMOVE parameters");
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen host = mail_host_lookup(conn->dir->mail_hosts, &ip);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (host == NULL)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend_str(conn->output, "NOTFOUND\n");
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen else {
e015e2f7e7f48874495f9df8b0dd192b7ffcb5ccTimo Sirainen director_remove_host(conn->dir, conn->dir->self_host,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen NULL, host);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen o_stream_nsend(conn->output, "OK\n", 3);
}
return 1;
}
static void
doveadm_cmd_host_flush_all(struct doveadm_connection *conn)
{
struct mail_host *const *hostp;
unsigned int total_user_count = 0;
array_foreach(mail_hosts_get(conn->dir->mail_hosts), hostp) {
total_user_count += (*hostp)->user_count;
director_flush_host(conn->dir, conn->dir->self_host,
NULL, *hostp);
}
i_warning("Flushed all backend hosts with %u users. This is an unsafe "
"operation and may cause the same users to end up in multiple backends.",
total_user_count);
o_stream_nsend(conn->output, "OK\n", 3);
}
static int
doveadm_cmd_host_flush(struct doveadm_connection *conn, const char *const *args)
{
struct mail_host *host;
struct ip_addr ip;
if (args[0] == NULL || args[0][0] == '\0') {
doveadm_cmd_host_flush_all(conn);
return 1;
}
if (net_addr2ip(args[0], &ip) < 0) {
i_error("doveadm sent invalid HOST-FLUSH parameters");
return -1;
}
host = mail_host_lookup(conn->dir->mail_hosts, &ip);
if (host == NULL)
o_stream_nsend_str(conn->output, "NOTFOUND\n");
else {
director_flush_host(conn->dir, conn->dir->self_host,
NULL, host);
o_stream_nsend(conn->output, "OK\n", 3);
}
return 1;
}
static void
director_host_reset_users(struct director *dir, struct director_host *src,
struct mail_host *host)
{
struct user_directory_iter *iter;
struct user *user;
struct mail_host *new_host;
if (dir->right != NULL)
director_connection_cork(dir->right);
iter = user_directory_iter_init(dir->users);
while ((user = user_directory_iter_next(iter)) != NULL) {
if (user->host != host)
continue;
new_host = mail_host_get_by_hash(dir->mail_hosts,
user->username_hash,
mail_host_get_tag(host));
if (new_host != host) T_BEGIN {
director_move_user(dir, src, NULL,
user->username_hash, new_host);
} T_END;
}
user_directory_iter_deinit(&iter);
if (dir->right != NULL)
director_connection_uncork(dir->right);
}
static void
doveadm_cmd_host_reset_users_all(struct doveadm_connection *conn)
{
struct mail_host *const *hostp;
array_foreach(mail_hosts_get(conn->dir->mail_hosts), hostp)
director_host_reset_users(conn->dir, conn->dir->self_host, *hostp);
o_stream_nsend(conn->output, "OK\n", 3);
}
static int
doveadm_cmd_host_reset_users(struct doveadm_connection *conn,
const char *const *args)
{
struct mail_host *host;
struct ip_addr ip;
if (args[0] == NULL || args[0][0] == '\0') {
doveadm_cmd_host_reset_users_all(conn);
return 1;
}
if (net_addr2ip(args[0], &ip) < 0) {
i_error("doveadm sent invalid HOST-RESET-USERS parameters");
return -1;
}
host = mail_host_lookup(conn->dir->mail_hosts, &ip);
if (host == NULL)
o_stream_nsend_str(conn->output, "NOTFOUND\n");
else {
director_host_reset_users(conn->dir, conn->dir->self_host, host);
o_stream_nsend(conn->output, "OK\n", 3);
}
return 1;
}
static int
doveadm_cmd_user_lookup(struct doveadm_connection *conn,
const char *const *args)
{
struct user *user;
struct mail_host *host;
const char *username, *tag;
unsigned int username_hash;
string_t *str = t_str_new(256);
if (args[0] == NULL) {
username = "";
tag = "";
} else {
username = args[0];
tag = args[1] != NULL ? args[1] : "";
}
if (str_to_uint(username, &username_hash) < 0)
username_hash = user_directory_get_username_hash(conn->dir->users, username);
/* get user's current host */
user = user_directory_lookup(conn->dir->users, username_hash);
if (user == NULL)
str_append(str, "\t0");
else {
str_printfa(str, "%s\t%u", net_ip2addr(&user->host->ip),
user->timestamp +
conn->dir->set->director_user_expire);
}
/* get host if it wasn't in user directory */
host = mail_host_get_by_hash(conn->dir->mail_hosts, username_hash, tag);
if (host == NULL)
str_append(str, "\t");
else
str_printfa(str, "\t%s", net_ip2addr(&host->ip));
/* get host with default configuration */
host = mail_host_get_by_hash(conn->dir->orig_config_hosts,
username_hash, tag);
if (host == NULL)
str_append(str, "\t\n");
else
str_printfa(str, "\t%s\n", net_ip2addr(&host->ip));
o_stream_nsend(conn->output, str_data(str), str_len(str));
return 1;
}
static int
doveadm_cmd_user_list(struct doveadm_connection *conn, const char *const *args)
{
struct user_directory_iter *iter;
struct user *user;
struct ip_addr ip;
if (args[0] != NULL && args[0][0] != '\0') {
if (net_addr2ip(args[0], &ip) < 0) {
i_error("doveadm sent invalid USER-LIST parameters");
return -1;
}
} else {
ip.family = 0;
}
iter = user_directory_iter_init(conn->dir->users);
while ((user = user_directory_iter_next(iter)) != NULL) {
if (ip.family == 0 ||
net_ip_compare(&ip, &user->host->ip)) T_BEGIN {
unsigned int expire_time = user->timestamp +
conn->dir->set->director_user_expire;
o_stream_nsend_str(conn->output, t_strdup_printf(
"%u\t%u\t%s\n",
user->username_hash, expire_time,
net_ip2addr(&user->host->ip)));
} T_END;
}
user_directory_iter_deinit(&iter);
o_stream_nsend(conn->output, "\n", 1);
return 1;
}
static int
doveadm_cmd_user_move(struct doveadm_connection *conn, const char *const *args)
{
unsigned int username_hash;
struct user *user;
struct mail_host *host;
struct ip_addr ip;
if (args[0] == NULL || args[1] == NULL ||
net_addr2ip(args[1], &ip) < 0) {
i_error("doveadm sent invalid USER-MOVE parameters");
return -1;
}
host = mail_host_lookup(conn->dir->mail_hosts, &ip);
if (host == NULL) {
o_stream_nsend_str(conn->output, "NOTFOUND\n");
return 1;
}
if (str_to_uint(args[0], &username_hash) < 0)
username_hash = user_directory_get_username_hash(conn->dir->users, args[0]);
user = user_directory_lookup(conn->dir->users, username_hash);
if (user != NULL && user->kill_state != USER_KILL_STATE_NONE) {
o_stream_nsend_str(conn->output, "TRYAGAIN\n");
return 1;
}
director_move_user(conn->dir, conn->dir->self_host, NULL,
username_hash, host);
o_stream_nsend(conn->output, "OK\n", 3);
return 1;
}
static int
doveadm_cmd_user_kick(struct doveadm_connection *conn, const char *const *args)
{
if (args[0] == NULL) {
i_error("doveadm sent invalid USER-KICK parameters");
return -1;
}
director_kick_user(conn->dir, conn->dir->self_host, NULL, args[0]);
o_stream_nsend(conn->output, "OK\n", 3);
return 1;
}
static int
doveadm_connection_cmd(struct doveadm_connection *conn, const char *line)
{
const char *cmd, *const *args;
int ret = 1;
args = t_strsplit_tabescaped(line);
if (args[0] == NULL) {
i_error("doveadm sent empty command line");
return -1;
}
cmd = args[0];
args++;
if (strcmp(cmd, "HOST-LIST") == 0)
doveadm_cmd_host_list(conn);
else if (strcmp(cmd, "HOST-LIST-REMOVED") == 0)
doveadm_cmd_host_list_removed(conn);
else if (strcmp(cmd, "DIRECTOR-LIST") == 0)
doveadm_cmd_director_list(conn);
else if (strcmp(cmd, "DIRECTOR-ADD") == 0)
ret = doveadm_cmd_director_add(conn, args);
else if (strcmp(cmd, "DIRECTOR-REMOVE") == 0)
ret = doveadm_cmd_director_remove(conn, args);
else if (strcmp(cmd, "HOST-SET") == 0)
ret = doveadm_cmd_host_set(conn, args);
else if (strcmp(cmd, "HOST-UPDATE") == 0)
ret = doveadm_cmd_host_update(conn, args);
else if (strcmp(cmd, "HOST-UP") == 0)
ret = doveadm_cmd_host_updown(conn, FALSE, args);
else if (strcmp(cmd, "HOST-DOWN") == 0)
ret = doveadm_cmd_host_updown(conn, TRUE, args);
else if (strcmp(cmd, "HOST-REMOVE") == 0)
ret = doveadm_cmd_host_remove(conn, args);
else if (strcmp(cmd, "HOST-FLUSH") == 0)
ret = doveadm_cmd_host_flush(conn, args);
else if (strcmp(cmd, "HOST-RESET-USERS") == 0)
ret = doveadm_cmd_host_reset_users(conn, args);
else if (strcmp(cmd, "USER-LOOKUP") == 0)
ret = doveadm_cmd_user_lookup(conn, args);
else if (strcmp(cmd, "USER-LIST") == 0)
ret = doveadm_cmd_user_list(conn, args);
else if (strcmp(cmd, "USER-MOVE") == 0)
ret = doveadm_cmd_user_move(conn, args);
else if (strcmp(cmd, "USER-KICK") == 0)
ret = doveadm_cmd_user_kick(conn, args);
else {
i_error("doveadm sent unknown command: %s", line);
ret = -1;
}
return ret;
}
static void doveadm_connection_input(struct doveadm_connection *conn)
{
const char *line;
int ret = 1;
if (!conn->handshaked) {
if ((line = i_stream_read_next_line(conn->input)) == NULL) {
if (conn->input->eof || conn->input->stream_errno != 0)
doveadm_connection_deinit(&conn);
return;
}
if (!version_string_verify(line, "director-doveadm",
DOVEADM_PROTOCOL_VERSION_MAJOR)) {
i_error("doveadm not compatible with this server "
"(mixed old and new binaries?)");
doveadm_connection_deinit(&conn);
return;
}
conn->handshaked = TRUE;
}
while ((line = i_stream_read_next_line(conn->input)) != NULL && ret > 0) {
T_BEGIN {
ret = doveadm_connection_cmd(conn, line);
} T_END;
}
if (conn->input->eof || conn->input->stream_errno != 0 || ret < 0)
doveadm_connection_deinit(&conn);
}
struct doveadm_connection *
doveadm_connection_init(struct director *dir, int fd)
{
struct doveadm_connection *conn;
conn = i_new(struct doveadm_connection, 1);
conn->fd = fd;
conn->dir = dir;
conn->input = i_stream_create_fd(conn->fd, 1024);
conn->output = o_stream_create_fd(conn->fd, (size_t)-1);
o_stream_set_no_error_handling(conn->output, TRUE);
conn->io = io_add(conn->fd, IO_READ, doveadm_connection_input, conn);
o_stream_nsend_str(conn->output, DOVEADM_HANDSHAKE);
DLLIST_PREPEND(&doveadm_connections, conn);
return conn;
}
static void doveadm_connection_deinit(struct doveadm_connection **_conn)
{
struct doveadm_connection *conn = *_conn;
*_conn = NULL;
DLLIST_REMOVE(&doveadm_connections, conn);
io_remove(&conn->io);
i_stream_unref(&conn->input);
o_stream_unref(&conn->output);
if (close(conn->fd) < 0)
i_error("close(doveadm connection) failed: %m");
i_free(conn);
master_service_client_connection_destroyed(master_service);
}
void doveadm_connections_deinit(void)
{
while (doveadm_connections != NULL) {
struct doveadm_connection *conn = doveadm_connections;
doveadm_connection_deinit(&conn);
}
}