2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

377dd19a90436b8f96902af741a3ea130bc3fe75Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "lib.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "ioloop.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "array.h"

bdd36cfdba3ff66d25570a9ff568d69e1eb543cfTimo Sirainen#include "net.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "istream.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "ostream.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "str.h"

09060303d565e15d54e42b4ef722f9d3c26f5336Timo Sirainen#include "strescape.h"

9224645cf699abae90fdd2cdf54247444f7acc18Timo Sirainen#include "time-util.h"

9522aa5f33cc37fe8ccd0d647cc51dd3ba6a9b55Timo Sirainen#include "master-service.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "mail-host.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "director.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "director-host.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "director-request.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include "director-connection.h"

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#include <unistd.h>

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen#include <sys/time.h>

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen#include <sys/resource.h>

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#define MAX_INBUF_SIZE 1024

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen#define OUTBUF_FLUSH_THRESHOLD (1024*128)

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen#define DIRECTOR_CONNECTION_CONNECT_TIMEOUT_MSECS (10*1000)

fe7f9298fb789717d26dc4cb6317a9d376acd8fcTimo Sirainen#define DIRECTOR_CONNECTION_ME_TIMEOUT_MSECS (10*1000)

5a5b39ce7c6ba6d6ff2218ae1679e0485bf43b47Timo Sirainen#define DIRECTOR_CONNECTION_SEND_USERS_TIMEOUT_MSECS (30*1000)

5c8dec7f648cb0de2293a13265873baa640aa0cfTimo Sirainen#define DIRECTOR_CONNECTION_DONE_TIMEOUT_MSECS (40*1000)

03fa2d644be0a9274e7e94fb4835cc374c539264Timo Sirainen#define DIRECTOR_CONNECTION_PING_INTERVAL_MSECS (15*1000)

f64b5bc9e73bedc63ba3c072c286542c29c69e43Timo Sirainen#define DIRECTOR_CONNECTION_PING_SYNC_INTERVAL_MSECS 1000

91b0bd6e7277646032d5001822f65575be75f062Timo Sirainen#define DIRECTOR_CONNECTION_PINGPONG_WARN_MSECS (5*1000)

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen#define DIRECTOR_SUCCESS_MIN_CONNECT_SECS 40

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen#define DIRECTOR_SKIP_RECENT_REFRESH_MAX_SECS 15

d8a93844f0b25be82da9c0ab79c321c110f5fb5fTimo Sirainen#define DIRECTOR_RECONNECT_AFTER_WRONG_CONNECT_MSECS 1000

9a656df90290a5fef45b3a1191ae75864f17602dTimo Sirainen#define DIRECTOR_WAIT_DISCONNECT_SECS 10

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen#define DIRECTOR_HANDSHAKE_WARN_SECS 29

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen#define DIRECTOR_HANDSHAKE_BYTES_LOG_MIN_SECS (60*30)

468c28dfb03613ab8d487b5aebc985a969193aceTimo Sirainen#define DIRECTOR_MAX_SYNC_SEQ_DUPLICATES 4

dfbd56c81cb8fb7fe70393c4682cc99e68fe06b6Timo Sirainen#define DIRECTOR_SYNC_STALE_TIMESTAMP_RESET_SECS (60*2)

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen#define DIRECTOR_MAX_CLOCK_DIFF_WARN_SECS 1

ad394c531ca4b7ca85f3741fa01f96c36c008c70Timo Sirainen#define DIRECTOR_HANDSHAKE_MAX_USERS_SENT_PER_FLUSH 10000

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

05b7b8f14426b5fe5d016940eb5916033f0bc841Timo Sirainen#define CMD_IS_USER_HANDSHAKE(minor_version, args) \

05b7b8f14426b5fe5d016940eb5916033f0bc841Timo Sirainen ((minor_version) < DIRECTOR_VERSION_HANDSHAKE_U_CMD && \

05b7b8f14426b5fe5d016940eb5916033f0bc841Timo Sirainen str_array_length(args) > 2)

377dd19a90436b8f96902af741a3ea130bc3fe75Timo Sirainen

eb209d12e3b1cfed564c35cf19fdb1bf7fcc6811Timo Sirainen#define DIRECTOR_OPT_CONSISTENT_HASHING "consistent-hashing"

eb209d12e3b1cfed564c35cf19fdb1bf7fcc6811Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainenstruct director_connection {

312213260e384239ac93c77951c2f1f5f3d3611eTimo Sirainen int refcount;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct director *dir;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen char *name;

7fd22d5521c8ecf84c40fbef553e70bf2553a663Timo Sirainen struct timeval created, connected_time, me_received_time;

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen struct timeval connected_user_cpu;

ee3362f3b78827a2c9a7e9ddee83f5a429c06213Timo Sirainen unsigned int minor_version;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

9224645cf699abae90fdd2cdf54247444f7acc18Timo Sirainen struct timeval last_input, last_output;

56139ffc94e481ca1940ffd8d8f7166879150665Timo Sirainen size_t peak_bytes_buffered;

9224645cf699abae90fdd2cdf54247444f7acc18Timo Sirainen

f1551f4a50a471f0adecd92dd1f94702beeed72dTimo Sirainen struct timeval ping_sent_time;

91b0bd6e7277646032d5001822f65575be75f062Timo Sirainen size_t ping_sent_buffer_size;

91b0bd6e7277646032d5001822f65575be75f062Timo Sirainen struct timeval ping_sent_user_cpu;

91b0bd6e7277646032d5001822f65575be75f062Timo Sirainen uoff_t ping_sent_input_offset, ping_sent_output_offset;

f1551f4a50a471f0adecd92dd1f94702beeed72dTimo Sirainen unsigned int last_ping_msecs;

f1551f4a50a471f0adecd92dd1f94702beeed72dTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen /* for incoming connections the director host isn't known until

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct director_host *host;

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen /* this is set only for wrong connections: */

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen struct director_host *connect_request_to;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen int fd;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct io *io;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct istream *input;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct ostream *output;

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen struct timeout *to_disconnect, *to_ping, *to_pong;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

1f7f4294207557edf83171642ef62ce4922ffc9dTimo Sirainen struct director_user_iter *user_iter;

58a102564ba58e2713e02ab86054978eb611cb81Timo Sirainen unsigned int users_received, handshake_users_received;

e5ef6fa616e0b0ed1bf545b39f0d9e8dea48c970Timo Sirainen unsigned int handshake_users_sent;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen /* set during command execution */

e8d44b65aab0a6723e7906756d0825e22ee85a82Timo Sirainen const char *cur_cmd, *const *cur_args;

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool in:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool connected:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool version_received:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool me_received:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool handshake_received:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool ignore_host_events:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool handshake_sending_hosts:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool ping_waiting:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool synced:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool wrong_host:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool verifying_left:1;

0dffa25d211be541ee3c953b23566a1a990789dfTimo Sirainen bool users_unsorted:1;

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen bool connected_user_cpu_set:1;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen};

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

312213260e384239ac93c77951c2f1f5f3d3611eTimo Sirainenstatic bool director_connection_unref(struct director_connection *conn);

a9ade104616bbb81c34cc6f8bfde5dab0571afacTimo Sirainenstatic void director_finish_sending_handshake(struct director_connection *conn);

d3ee83b4c24529fac4be5c1f30e254295e7addd9Timo Sirainenstatic void director_connection_disconnected(struct director_connection **conn,

d3ee83b4c24529fac4be5c1f30e254295e7addd9Timo Sirainen const char *reason);

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainenstatic void director_connection_reconnect(struct director_connection **conn,

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen const char *reason);

06fc82430569125dccb8cd20e122e77b44698c7eTimo Sirainenstatic void

d3ee83b4c24529fac4be5c1f30e254295e7addd9Timo Sirainendirector_connection_log_disconnect(struct director_connection *conn, int err,

d3ee83b4c24529fac4be5c1f30e254295e7addd9Timo Sirainen const char *errstr);

eb209d12e3b1cfed564c35cf19fdb1bf7fcc6811Timo Sirainenstatic int director_connection_send_done(struct director_connection *conn);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainenstatic void ATTR_FORMAT(2, 3)

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainendirector_cmd_error(struct director_connection *conn, const char *fmt, ...)

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen{

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen va_list args;

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen va_start(args, fmt);

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen i_error("director(%s): Command %s: %s (input: %s)", conn->name,

e8d44b65aab0a6723e7906756d0825e22ee85a82Timo Sirainen conn->cur_cmd, t_strdup_vprintf(fmt, args),

e8d44b65aab0a6723e7906756d0825e22ee85a82Timo Sirainen t_strarray_join(conn->cur_args, "\t"));

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen va_end(args);

4847d74a7442a3efabe76a8ad18dd464082d6581Timo Sirainen

34115224152b94328ffe3ec4ff4f30927c8f9aa1Timo Sirainen if (conn->host != NULL)

34115224152b94328ffe3ec4ff4f30927c8f9aa1Timo Sirainen conn->host->last_protocol_failure = ioloop_time;

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen}

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainenstatic void

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainendirector_connection_append_stats(struct director_connection *conn, string_t *str)

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen{

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen int input_msecs = timeval_diff_msecs(&ioloop_timeval, &conn->last_input);

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen int output_msecs = timeval_diff_msecs(&ioloop_timeval, &conn->last_output);

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen int connected_msecs = timeval_diff_msecs(&ioloop_timeval, &conn->connected_time);

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen struct rusage usage;

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen str_printfa(str, "bytes in=%"PRIuUOFF_T", bytes out=%"PRIuUOFF_T,

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen conn->input->v_offset, conn->output->offset);

58a102564ba58e2713e02ab86054978eb611cb81Timo Sirainen str_printfa(str, ", %u+%u USERs received",

58a102564ba58e2713e02ab86054978eb611cb81Timo Sirainen conn->handshake_users_received, conn->users_received);

e5ef6fa616e0b0ed1bf545b39f0d9e8dea48c970Timo Sirainen if (conn->handshake_users_sent > 0) {

e5ef6fa616e0b0ed1bf545b39f0d9e8dea48c970Timo Sirainen str_printfa(str, ", %u USERs sent in handshake",

e5ef6fa616e0b0ed1bf545b39f0d9e8dea48c970Timo Sirainen conn->handshake_users_sent);

e5ef6fa616e0b0ed1bf545b39f0d9e8dea48c970Timo Sirainen }

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen if (conn->last_input.tv_sec > 0) {

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen str_printfa(str, ", last input %u.%03u s ago",

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen input_msecs/1000, input_msecs%1000);

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen }

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen if (conn->last_output.tv_sec > 0) {

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen str_printfa(str, ", last output %u.%03u s ago",

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen output_msecs/1000, output_msecs%1000);

8a513c80e95a51c29f5af5c702fbf71ecbad41f4Timo Sirainen }

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen if (conn->connected) {

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_printfa(str, ", connected %u.%03u s ago",

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen connected_msecs/1000, connected_msecs%1000);

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen }

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen if (o_stream_get_buffer_used_size(conn->output) > 0) {

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_printfa(str, ", %"PRIuSIZE_T" bytes in output buffer",

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen o_stream_get_buffer_used_size(conn->output));

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen }

ef996cb0e68ea5474716058137308a98cfa0c324Timo Sirainen str_printfa(str, ", %zu peak output buffer size",

ef996cb0e68ea5474716058137308a98cfa0c324Timo Sirainen conn->peak_bytes_buffered);

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen if (conn->connected_user_cpu_set &&

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen getrusage(RUSAGE_SELF, &usage) == 0) {

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen /* this isn't measuring the CPU usage used by the connection

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen int diff = timeval_diff_msecs(&usage.ru_utime,

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen &conn->connected_user_cpu);

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen str_printfa(str, ", %d.%03d CPU secs since connected",

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen diff / 1000, diff % 1000);

f534eb971e3e40087ad81dcd080c1d69424df417Timo Sirainen }

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen}

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic void

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainendirector_connection_init_timeout(struct director_connection *conn)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen struct timeval start_time;

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen string_t *reason = t_str_new(128);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (!conn->connected) {

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen start_time = conn->created;

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_append(reason, "Connect timed out");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (!conn->me_received) {

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen start_time = conn->connected_time;

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_append(reason, "Handshaking ME timed out");

6ccc7f584c832a3212d70952881cb0eb2d6e2cb9Timo Sirainen } else if (!conn->in) {

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen start_time = conn->me_received_time;

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_append(reason, "Sending handshake timed out");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else {

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen start_time = conn->me_received_time;

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_append(reason, "Handshaking DONE timed out");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen int msecs = timeval_diff_msecs(&ioloop_timeval, &start_time);

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_printfa(reason, " (%u.%03u secs, ", msecs/1000, msecs%1000);

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen director_connection_append_stats(conn, reason);

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen str_append_c(reason, ')');

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen

1ef9754a5169dc886d15089e59b45a7017d647d7Timo Sirainen i_error("director(%s): %s", conn->name, str_c(reason));

d3ee83b4c24529fac4be5c1f30e254295e7addd9Timo Sirainen director_connection_disconnected(&conn, "Handshake timeout");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic void

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainendirector_connection_set_ping_timeout(struct director_connection *conn)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen unsigned int msecs;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen msecs = conn->synced || !conn->handshake_received ?

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen DIRECTOR_CONNECTION_PING_INTERVAL_MSECS :

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen DIRECTOR_CONNECTION_PING_SYNC_INTERVAL_MSECS;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen timeout_remove(&conn->to_ping);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->to_ping = timeout_add(msecs, director_connection_ping, conn);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainenstatic void director_connection_wait_timeout(struct director_connection *conn)

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen{

d3ee83b4c24529fac4be5c1f30e254295e7addd9Timo Sirainen director_connection_log_disconnect(conn, ETIMEDOUT, "");

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen director_connection_deinit(&conn,

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen "Timeout waiting for disconnect after CONNECT");

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen}

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic void director_connection_send_connect(struct director_connection *conn,

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen struct director_host *host)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen const char *connect_str;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen if (conn->to_disconnect != NULL)

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen return;

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen connect_str = t_strdup_printf("CONNECT\t%s\t%u\n",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen host->ip_str, host->port);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_send(conn, connect_str);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen o_stream_uncork(conn->output);

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen /* wait for a while for the remote to disconnect, so it will hopefully

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen conn->connect_request_to = host;

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen director_host_ref(conn->connect_request_to);

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen conn->to_disconnect =

9a656df90290a5fef45b3a1191ae75864f17602dTimo Sirainen timeout_add(DIRECTOR_WAIT_DISCONNECT_SECS*1000,

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen director_connection_wait_timeout, conn);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic void director_connection_assigned(struct director_connection *conn)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen struct director *dir = conn->dir;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (dir->left != NULL && dir->right != NULL) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* we're connected to both directors. see if the ring is

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->sync_seq++;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_set_ring_unsynced(dir);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_sync_send(dir, dir->self_host, dir->sync_seq,

abe29107f5dce932d28a00912d2d75a01021bef1Timo Sirainen DIRECTOR_VERSION_MINOR, ioloop_time,

abe29107f5dce932d28a00912d2d75a01021bef1Timo Sirainen mail_hosts_hash(dir->mail_hosts));

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_set_ping_timeout(conn);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic bool director_connection_assign_left(struct director_connection *conn)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen struct director *dir = conn->dir;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_assert(conn->in);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_assert(dir->left != conn);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* make sure this is the correct incoming connection */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (conn->host->self) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_error("Connection from self, dropping");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return FALSE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (dir->left == NULL) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* no conflicts yet */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (dir->left->host == conn->host) {

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen i_warning("Replacing left director connection %s with %s",

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen dir->left->host->name, conn->host->name);

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen director_connection_deinit(&dir->left, t_strdup_printf(

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen "Replacing with %s", conn->host->name));

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (dir->left->verifying_left) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* we're waiting to verify if our current left is still

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (director_host_cmp_to_self(dir->left->host, conn->host,

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->self_host) < 0) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* the old connection is the correct one.

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_send_connect(conn, dir->left->host);

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen return TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* this new connection is the correct one, but wait until the

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->left = conn;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_free(conn->name);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->name = i_strdup_printf("%s/left", conn->host->name);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_assigned(conn);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic void director_assign_left(struct director *dir)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen struct director_connection *conn, *const *connp;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen array_foreach(&dir->connections, connp) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn = *connp;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen if (conn->in && conn->handshake_received &&

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen conn->to_disconnect == NULL && conn != dir->left) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* either use this or disconnect it */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (!director_connection_assign_left(conn)) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* we don't want this */

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen director_connection_deinit(&conn,

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen "Unwanted incoming connection");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_assign_left(dir);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen break;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic bool director_has_outgoing_connections(struct director *dir)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen struct director_connection *const *connp;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen array_foreach(&dir->connections, connp) {

6cb8e7d726a7e9d157e87fb379982d52100b283fTimo Sirainen if (!(*connp)->in && (*connp)->to_disconnect == NULL)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return FALSE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainenstatic void director_send_delayed_syncs(struct director *dir)

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen{

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen struct director_host *const *hostp;

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen i_assert(dir->right != NULL);

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen dir_debug("director(%s): Sending delayed SYNCs", dir->right->name);

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen array_foreach(&dir->dir_hosts, hostp) {

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen if ((*hostp)->delayed_sync_seq == 0)

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen continue;

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen director_sync_send(dir, *hostp, (*hostp)->delayed_sync_seq,

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen (*hostp)->delayed_sync_minor_version,

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen (*hostp)->delayed_sync_timestamp,

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen (*hostp)->delayed_sync_hosts_hash);

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen (*hostp)->delayed_sync_seq = 0;

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen }

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen}

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainenstatic bool director_connection_assign_right(struct director_connection *conn)

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen{

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen struct director *dir = conn->dir;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_assert(!conn->in);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (dir->right != NULL) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* see if we should disconnect or keep the existing

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (director_host_cmp_to_self(conn->host, dir->right->host,

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->self_host) <= 0) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* the old connection is the correct one */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_warning("Aborting incorrect outgoing connection to %s "

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen "(already connected to correct one: %s)",

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->host->name, dir->right->host->name);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->wrong_host = TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return FALSE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen i_warning("Replacing right director connection %s with %s",

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen dir->right->host->name, conn->host->name);

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen director_connection_deinit(&dir->right, t_strdup_printf(

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen "Replacing with %s", conn->host->name));

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->right = conn;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_free(conn->name);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->name = i_strdup_printf("%s/right", conn->host->name);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_assigned(conn);

67cb14c7fb54a031818228522dc7255d5cd00f0aTimo Sirainen director_send_delayed_syncs(dir);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen return TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen}

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainenstatic bool

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainendirector_args_parse_ip_port(struct director_connection *conn,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen const char *const *args,

009217abb57a24a4076092e8e4e165545747839eStephan Bosch struct ip_addr *ip_r, in_port_t *port_r)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen if (args[0] == NULL || args[1] == NULL) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Missing IP+port parameters");

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen return FALSE;

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (net_addr2ip(args[0], ip_r) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid IP address: %s", args[0]);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

009217abb57a24a4076092e8e4e165545747839eStephan Bosch if (net_str2port(args[1], port_r) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid port: %s", args[1]);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen}

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainenstatic bool director_cmd_me(struct director_connection *conn,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen const char *const *args)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct director *dir = conn->dir;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen const char *connect_str;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct ip_addr ip;

009217abb57a24a4076092e8e4e165545747839eStephan Bosch in_port_t port;

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen time_t next_comm_attempt;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (!director_args_parse_ip_port(conn, args, &ip, &port))

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

377dd19a90436b8f96902af741a3ea130bc3fe75Timo Sirainen if (conn->me_received) {

377dd19a90436b8f96902af741a3ea130bc3fe75Timo Sirainen director_cmd_error(conn, "Duplicate ME");

377dd19a90436b8f96902af741a3ea130bc3fe75Timo Sirainen return FALSE;

377dd19a90436b8f96902af741a3ea130bc3fe75Timo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (!conn->in && (!net_ip_compare(&conn->host->ip, &ip) ||

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen conn->host->port != port)) {

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen i_error("Remote director thinks it's someone else "

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen "(connected to %s:%u, remote says it's %s:%u)",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen conn->host->ip_str, conn->host->port,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen net_ip2addr(&ip), port);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen conn->me_received = TRUE;

7fd22d5521c8ecf84c40fbef553e70bf2553a663Timo Sirainen conn->me_received_time = ioloop_timeval;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen if (args[2] != NULL) {

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen time_t remote_time;

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen int diff;

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen if (str_to_time(args[2], &remote_time) < 0) {

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen director_cmd_error(conn, "Invalid ME timestamp");

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen return FALSE;

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen }

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen diff = ioloop_time - remote_time;

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen if (diff > DIRECTOR_MAX_CLOCK_DIFF_WARN_SECS ||

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen (diff < 0 && -diff > DIRECTOR_MAX_CLOCK_DIFF_WARN_SECS)) {

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen i_warning("Director %s clock differs from ours by %d secs",

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen conn->name, diff);

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen }

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen }

9054b5f92a7e5666c6beaa04916699a1408bf021Timo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen timeout_remove(&conn->to_ping);

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen if (conn->in) {

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen conn->to_ping = timeout_add(DIRECTOR_CONNECTION_DONE_TIMEOUT_MSECS,

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen director_connection_init_timeout, conn);

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen } else {

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen conn->to_ping = timeout_add(DIRECTOR_CONNECTION_SEND_USERS_TIMEOUT_MSECS,

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen director_connection_init_timeout, conn);

5a530f778cc3eae05e70d13b8e5d7d501e7ba0b3Timo Sirainen }

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (!conn->in)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* Incoming connection:

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen i_assert(conn->host == NULL);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->host = director_host_get(dir, &ip, port);

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen /* the host shouldn't be removed at this point, but if for some

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen conn->host->removed = FALSE;

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen director_host_ref(conn->host);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* make sure we don't keep old sequence values across restarts */

ce28adabf2c47d3af9ef197787cdb5139424c69cTimo Sirainen director_host_restarted(conn->host);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen next_comm_attempt = conn->host->last_protocol_failure +

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen DIRECTOR_PROTOCOL_FAILURE_RETRY_SECS;

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen if (next_comm_attempt > ioloop_time) {

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen /* the director recently sent invalid protocol data,

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen i_error("director(%s): Remote sent invalid protocol data recently, "

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen "waiting %u secs before allowing further communication",

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen conn->name, (unsigned int)(next_comm_attempt-ioloop_time));

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen return FALSE;

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen } else if (dir->left == NULL) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* a) - just in case the left is also our right side reset

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen conn->host->last_network_failure = 0;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen if (!director_has_outgoing_connections(dir))

e2fdcdb4ee53ab769123e27997713aaea34910e1Timo Sirainen director_connect(dir, "Connecting to left");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (dir->left->host == conn->host) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* b) */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen i_assert(dir->left != conn);

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen director_connection_deinit(&dir->left,

dff32d11a411a24f3b76003c1ae22c5a960f180eTimo Sirainen "Replacing with new incoming connection");

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen } else if (director_host_cmp_to_self(conn->host, dir->left->host,

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->self_host) < 0) {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* c) */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen connect_str = t_strdup_printf("CONNECT\t%s\t%u\n",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen conn->host->ip_str,

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen conn->host->port);

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_send(dir->left, connect_str);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen } else {

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen /* d) */

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen dir->left->verifying_left = TRUE;

5f5713d6468dca1acf3d350dd8a33057331f78c5Timo Sirainen director_connection_ping(dir->left);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen}

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainenstatic inline bool

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainenuser_need_refresh(struct director *dir, struct user *user,

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen time_t timestamp, bool unknown_timestamp)

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen{

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen if (timestamp <= (time_t)user->timestamp) {

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen /* we already have this timestamp */

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen return FALSE;

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen }

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen if (unknown_timestamp) {

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen /* Old director sent USER command without timestamp. We don't

70a88f28adfd52040d483b62ef6fd164db89b015Josef 'Jeff' Sipek time_t skip_recent_secs =

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen I_MIN(dir->set->director_user_expire/4,

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen DIRECTOR_SKIP_RECENT_REFRESH_MAX_SECS);

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen if ((time_t)user->timestamp + skip_recent_secs >= timestamp)

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen return FALSE;

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen }

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen return TRUE;

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen}

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainenstatic int

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainendirector_user_refresh(struct director_connection *conn,

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen unsigned int username_hash, struct mail_host *host,

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen time_t timestamp, bool weak, bool *forced_r,

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen struct user **user_r)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen struct director *dir = conn->dir;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct user *user;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen bool ret = FALSE, unset_weak_user = FALSE;

b44033e45e9f48f8a6e1ac5905234fec5de6d6ccAki Tuomi struct user_directory *users = host->tag->users;

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen bool unknown_timestamp = (timestamp == (time_t)-1);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen *forced_r = FALSE;

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen if (unknown_timestamp) {

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen /* Old director version sent USER without timestamp. */

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen timestamp = ioloop_time;

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen }

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen

154f91726624265fce15097eb4bbbf6e55f8c477Timo Sirainen if (timestamp + (time_t)dir->set->director_user_expire <= ioloop_time) {

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen /* Ignore this refresh entirely, regardless of whether the

154f91726624265fce15097eb4bbbf6e55f8c477Timo Sirainen dir_debug("user refresh: %u has expired timestamp %"PRIdTIME_T,

154f91726624265fce15097eb4bbbf6e55f8c477Timo Sirainen username_hash, timestamp);

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen return -1;

154f91726624265fce15097eb4bbbf6e55f8c477Timo Sirainen }

154f91726624265fce15097eb4bbbf6e55f8c477Timo Sirainen

68d87d8fb8f23ffed031ddfd9c410f3c929777faTimo Sirainen user = user_directory_lookup(users, username_hash);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (user == NULL) {

68d87d8fb8f23ffed031ddfd9c410f3c929777faTimo Sirainen *user_r = user_directory_add(users, username_hash,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen host, timestamp);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen (*user_r)->weak = weak;

1df39b899804fd1dbc560f75382364822935c857Timo Sirainen dir_debug("user refresh: %u added", username_hash);

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen return 1;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (user->weak) {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (!weak) {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* removing user's weakness */

1df39b899804fd1dbc560f75382364822935c857Timo Sirainen dir_debug("user refresh: %u weakness removed",

1df39b899804fd1dbc560f75382364822935c857Timo Sirainen username_hash);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen unset_weak_user = TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen user->weak = FALSE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen ret = TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen } else {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* weak user marked again as weak */

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen } else if (weak &&

68d87d8fb8f23ffed031ddfd9c410f3c929777faTimo Sirainen !user_directory_user_is_recently_updated(users, user)) {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* mark the user as weak */

1df39b899804fd1dbc560f75382364822935c857Timo Sirainen dir_debug("user refresh: %u set weak", username_hash);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen user->weak = TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen ret = TRUE;

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen } else if (weak) {

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen dir_debug("user refresh: %u weak update to %s ignored, "

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen "we recently changed it to %s",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen username_hash, host->ip_str,

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen user->host->ip_str);

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen host = user->host;

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen ret = TRUE;

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen } else if (user->host == host) {

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen /* update to the same host */

68d87d8fb8f23ffed031ddfd9c410f3c929777faTimo Sirainen } else if (user_directory_user_is_near_expiring(users, user)) {

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen /* host conflict for a user that is already near expiring. we can

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen dir_debug("user refresh: %u is nearly expired, "

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen "replacing host %s with %s", username_hash,

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen user->host->ip_str, host->ip_str);

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen ret = TRUE;

79ee504bdf920f01e12e28f238799bf2616489dfTimo Sirainen } else if (USER_IS_BEING_KILLED(user)) {

5c1733e9e572e242598b8b2f12a0068897caf5b7Timo Sirainen /* user is still being moved - ignore conflicting host updates

5c1733e9e572e242598b8b2f12a0068897caf5b7Timo Sirainen dir_debug("user refresh: %u is being moved, "

5c1733e9e572e242598b8b2f12a0068897caf5b7Timo Sirainen "preserve its host %s instead of replacing with %s",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen username_hash, user->host->ip_str, host->ip_str);

5c1733e9e572e242598b8b2f12a0068897caf5b7Timo Sirainen host = user->host;

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen } else {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* non-weak user received a non-weak update with

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen string_t *str = t_str_new(128);

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen str_printfa(str, "User hash %u "

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen "is being redirected to two hosts: %s and %s",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen username_hash, user->host->ip_str, host->ip_str);

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen str_printfa(str, " (old_ts=%ld", (long)user->timestamp);

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen if (!conn->handshake_received) {

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen str_printfa(str, ",handshaking,recv_ts=%ld",

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen (long)timestamp);

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen }

79ee504bdf920f01e12e28f238799bf2616489dfTimo Sirainen if (USER_IS_BEING_KILLED(user)) {

1b7cd57585d8c2f133dd612d2d5d9c775595659fTimo Sirainen if (user->kill_ctx->to_move != NULL)

1b7cd57585d8c2f133dd612d2d5d9c775595659fTimo Sirainen str_append(str, ",moving");

ade4a0e1a8f4bc3467f4fcff9c219558fe348abfTimo Sirainen str_printfa(str, ",kill_state=%s",

1b7cd57585d8c2f133dd612d2d5d9c775595659fTimo Sirainen user_kill_state_names[user->kill_ctx->kill_state]);

ade4a0e1a8f4bc3467f4fcff9c219558fe348abfTimo Sirainen }

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen str_append_c(str, ')');

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen i_error("%s", str_c(str));

36a687c1ed3ce55520bdf28cd2fa1f653360068dTimo Sirainen

242abe3ad2423776e9cf05e1304eb8fda4831b23Timo Sirainen /* we want all the directors to redirect the user to same

242abe3ad2423776e9cf05e1304eb8fda4831b23Timo Sirainen if (net_ip_cmp(&user->host->ip, &host->ip) > 0) {

242abe3ad2423776e9cf05e1304eb8fda4831b23Timo Sirainen /* change the host. we'll also need to remove the user

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen *forced_r = TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen } else {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* keep the host */

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen host = user->host;

242abe3ad2423776e9cf05e1304eb8fda4831b23Timo Sirainen }

36e091dc733c6cd690c5aae6e411e41adb1eca73Timo Sirainen /* especially IMAP connections can take a long time to die.

36e091dc733c6cd690c5aae6e411e41adb1eca73Timo Sirainen director_kick_user_hash(dir, dir->self_host, NULL,

36e091dc733c6cd690c5aae6e411e41adb1eca73Timo Sirainen username_hash, &host->ip);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen ret = TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (user->host != host) {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen user->host->user_count--;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen user->host = host;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen user->host->user_count++;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen ret = TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen /* Update user's timestamp if it's higher than the current one. Note

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen if (user_need_refresh(dir, user, timestamp, unknown_timestamp)) {

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen /* NOTE: This makes the users list somewhat out-of-order.

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen dir_debug("user refresh: %u refreshed timestamp from %u to %"PRIdTIME_T,

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen username_hash, user->timestamp, timestamp);

68d87d8fb8f23ffed031ddfd9c410f3c929777faTimo Sirainen user_directory_refresh(users, user);

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen user->timestamp = timestamp;

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen ret = TRUE;

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen } else {

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen dir_debug("user refresh: %u ignored timestamp %"PRIdTIME_T" (we have %u)",

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen username_hash, timestamp, user->timestamp);

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (unset_weak_user) {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* user is no longer weak. handle pending requests for

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen director_set_state_changed(conn->dir);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen *user_r = user;

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen return ret ? 1 : 0;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen}

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainenstatic bool

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainendirector_handshake_cmd_user(struct director_connection *conn,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen const char *const *args)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen unsigned int username_hash, timestamp;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct ip_addr ip;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct mail_host *host;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct user *user;

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen bool weak, forced;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (str_array_length(args) < 3 ||

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen str_to_uint(args[0], &username_hash) < 0 ||

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen net_addr2ip(args[1], &ip) < 0 ||

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen str_to_uint(args[2], &timestamp) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid parameters");

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen weak = args[3] != NULL && args[3][0] == 'w';

58a102564ba58e2713e02ab86054978eb611cb81Timo Sirainen conn->handshake_users_received++;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

cf9d67e4a9bfee31cf3be05244555d51a3d1b9feTimo Sirainen host = mail_host_lookup(conn->dir->mail_hosts, &ip);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (host == NULL) {

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen i_error("director(%s): USER used unknown host %s in handshake",

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen conn->name, args[1]);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

70a88f28adfd52040d483b62ef6fd164db89b015Josef 'Jeff' Sipek if ((time_t)timestamp > ioloop_time) {

94fb15fffc814d7dcecabf8d90691502311d4b88Timo Sirainen /* The other director's clock seems to be into the future

04c8a9554e34ad1afed9291e673cd452ee93e849Timo Sirainen timestamp = ioloop_time;

04c8a9554e34ad1afed9291e673cd452ee93e849Timo Sirainen }

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen conn->dir->num_incoming_requests++;

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen if (director_user_refresh(conn, username_hash, host,

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen timestamp, weak, &forced, &user) < 0) {

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen /* user expired - ignore */

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen return TRUE;

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen }

94fb15fffc814d7dcecabf8d90691502311d4b88Timo Sirainen /* Possibilities:

94fb15fffc814d7dcecabf8d90691502311d4b88Timo Sirainen if (user->timestamp < timestamp)

8621be3846dc097420cce325ad36d1b646f72a09Timo Sirainen user->timestamp = timestamp;

94fb15fffc814d7dcecabf8d90691502311d4b88Timo Sirainen /* always sort users after handshaking to make sure the order

94fb15fffc814d7dcecabf8d90691502311d4b88Timo Sirainen conn->users_unsorted = TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen}

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainenstatic bool

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainendirector_cmd_user(struct director_connection *conn,

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen const char *const *args)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen{

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen unsigned int username_hash;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct ip_addr ip;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct mail_host *host;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct user *user;

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen bool forced;

edaa9f5c32594e7af8c0b862cd3a0c188d55ac7bTimo Sirainen time_t timestamp = (time_t)-1;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen if (str_array_length(args) < 2 ||

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen str_to_uint(args[0], &username_hash) < 0 ||

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen net_addr2ip(args[1], &ip) < 0 ||

b3e36790ca9e16d022118012b46ed50f73a45046Timo Sirainen (args[2] != NULL && str_to_time(args[2], &timestamp) < 0)) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid parameters");

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return FALSE;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen }

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen /* could this before it's potentially ignored */

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen conn->dir->num_incoming_requests++;

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen

58a102564ba58e2713e02ab86054978eb611cb81Timo Sirainen conn->users_received++;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen host = mail_host_lookup(conn->dir->mail_hosts, &ip);

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen if (host == NULL) {

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen /* we probably just removed this host. */

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return TRUE;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen }

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

4f2b533808371b3b8a8187819cd4c3d90e1ca8eeTimo Sirainen if (director_user_refresh(conn, username_hash,

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen host, timestamp, FALSE, &forced, &user) > 0) {

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen /* user changed - forward the USER in the ring */

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen struct director_host *src_host =

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen forced ? conn->dir->self_host : conn->host;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen i_assert(!user->weak);

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen director_update_user(conn->dir, src_host, user);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return TRUE;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen}

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainenstatic bool director_cmd_director(struct director_connection *conn,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen const char *const *args)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct director_host *host;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct ip_addr ip;

009217abb57a24a4076092e8e4e165545747839eStephan Bosch in_port_t port;

027f58ea63a1822bbf13d99ee5572e5f8b9e8d8bTimo Sirainen bool log_add = FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (!director_args_parse_ip_port(conn, args, &ip, &port))

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen host = director_host_lookup(conn->dir, &ip, port);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (host != NULL) {

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen if (host == conn->dir->self_host) {

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen /* ignore updates to ourself */

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen return TRUE;

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen }

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen if (host->removed) {

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen /* ignore re-adds of removed directors */

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen return TRUE;

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen }

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen

8c2b4a45f17a5cb13bb01058ca37798cf48d91baTimo Sirainen /* already have this. just reset its last_network_failure

e588e0b3f3119ba2cc98b338ee9868f8f0297f49Timo Sirainen if (conn->handshake_received)

e588e0b3f3119ba2cc98b338ee9868f8f0297f49Timo Sirainen host->last_network_failure = 0;

88cb1595bf0ad84846b9c611a1afbca35fcfe460Timo Sirainen /* it also may have been restarted, reset its state */

88cb1595bf0ad84846b9c611a1afbca35fcfe460Timo Sirainen director_host_restarted(host);

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen } else {

c9b08dc8d71bd655e5648daf8a09ff4b728cae81Timo Sirainen /* save the director and forward it */

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen host = director_host_add(conn->dir, &ip, port);

027f58ea63a1822bbf13d99ee5572e5f8b9e8d8bTimo Sirainen log_add = TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

88cb1595bf0ad84846b9c611a1afbca35fcfe460Timo Sirainen /* just forward this to the entire ring until it reaches back to

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen if (conn->dir->right != NULL &&

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen director_host_cmp_to_self(host, conn->dir->right->host,

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen conn->dir->self_host) > 0) {

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen dir_debug("Received DIRECTOR update for a host where we should be connected to. "

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen "Not forwarding it since it's probably crashed.");

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen } else {

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen director_notify_ring_added(host,

027f58ea63a1822bbf13d99ee5572e5f8b9e8d8bTimo Sirainen director_connection_get_host(conn), log_add);

336cdc9993838d967bbaf214a671975c2e7e5942Timo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen}

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainenstatic bool director_cmd_director_remove(struct director_connection *conn,

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen const char *const *args)

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen{

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen struct director_host *host;

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen struct ip_addr ip;

009217abb57a24a4076092e8e4e165545747839eStephan Bosch in_port_t port;

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen if (!director_args_parse_ip_port(conn, args, &ip, &port))

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen return FALSE;

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen host = director_host_lookup(conn->dir, &ip, port);

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen if (host != NULL && !host->removed)

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen director_ring_remove(host, director_connection_get_host(conn));

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen return TRUE;

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen}

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainenstatic bool

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainendirector_cmd_host_hand_start(struct director_connection *conn,

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen const char *const *args)

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen{

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen const ARRAY_TYPE(mail_host) *hosts;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen struct mail_host *const *hostp;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen unsigned int remote_ring_completed;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen if (args[0] == NULL ||

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen str_to_uint(args[0], &remote_ring_completed) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid parameters");

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen return FALSE;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen }

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen

23bdbb7b1831785c6ba6df190f6369da882d2b9dTimo Sirainen if (remote_ring_completed != 0 && !conn->dir->ring_handshaked) {

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen /* clear everything we have and use only what remote sends us */

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen dir_debug("%s: We're joining a ring - replace all hosts",

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen conn->name);

cf9d67e4a9bfee31cf3be05244555d51a3d1b9feTimo Sirainen hosts = mail_hosts_get(conn->dir->mail_hosts);

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen while (array_count(hosts) > 0) {

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen hostp = array_idx(hosts, 0);

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen director_remove_host(conn->dir, NULL, NULL, *hostp);

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen }

23bdbb7b1831785c6ba6df190f6369da882d2b9dTimo Sirainen } else if (remote_ring_completed == 0 && conn->dir->ring_handshaked) {

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen /* ignore whatever remote sends */

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen dir_debug("%s: Remote is joining our ring - "

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen "ignore all remote HOSTs", conn->name);

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen conn->ignore_host_events = TRUE;

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen } else {

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen dir_debug("%s: Merge rings' hosts", conn->name);

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen }

242abe3ad2423776e9cf05e1304eb8fda4831b23Timo Sirainen conn->handshake_sending_hosts = TRUE;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen return TRUE;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen}

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainenstatic int

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainendirector_cmd_is_seen_full(struct director_connection *conn,

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen const char *const **_args, unsigned int *seq_r,

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen struct director_host **host_r)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen{

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen const char *const *args = *_args;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct ip_addr ip;

009217abb57a24a4076092e8e4e165545747839eStephan Bosch in_port_t port;

009217abb57a24a4076092e8e4e165545747839eStephan Bosch unsigned int seq;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct director_host *host;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen if (str_array_length(args) < 3 ||

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen net_addr2ip(args[0], &ip) < 0 ||

009217abb57a24a4076092e8e4e165545747839eStephan Bosch net_str2port(args[1], &port) < 0 ||

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen str_to_uint(args[2], &seq) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid parameters");

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return -1;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen }

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen *_args = args + 3;

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen *seq_r = seq;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen host = director_host_lookup(conn->dir, &ip, port);

e4194f4703eeec32b432371ae30fc8f25ab720d8Timo Sirainen if (host == NULL || host->removed) {

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen /* director is already gone, but we can't be sure if this

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen *host_r = NULL;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen } else {

c1b9c4531186c6a7cd92d2c353273a834f8ee66fTimo Sirainen *host_r = host;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen if (seq <= host->last_seq) {

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen /* already seen this */

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return 1;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen }

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen host->last_seq = seq;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen }

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return 0;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen}

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainenstatic int

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainendirector_cmd_is_seen(struct director_connection *conn,

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen const char *const **_args,

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen struct director_host **host_r)

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen{

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen unsigned int seq;

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen return director_cmd_is_seen_full(conn, _args, &seq, host_r);

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen}

0874d7a4fa15322318c71291f0134ff7cc49bbb8Timo Sirainen

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainenstatic bool

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainendirector_cmd_user_weak(struct director_connection *conn,

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen const char *const *args)

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen{

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen struct director_host *dir_host;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen struct ip_addr ip;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen unsigned int username_hash;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen struct mail_host *host;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen struct user *user;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen struct director_host *src_host = conn->host;

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen bool weak = TRUE, weak_forward = FALSE, forced;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen int ret;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

d3211a8014c08677e1c1bbd84e98ad51b5744448Timo Sirainen /* note that unlike other commands we don't want to just ignore

d3211a8014c08677e1c1bbd84e98ad51b5744448Timo Sirainen if ((ret = director_cmd_is_seen(conn, &args, &dir_host)) < 0)

38eee54ced2034a4772958f96a737bd368d5e5e0Timo Sirainen return FALSE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen /* could this before it's potentially ignored */

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen conn->dir->num_incoming_requests++;

dd19de9b6382c9a47b65df6b2396789df37a19fbTimo Sirainen

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (str_array_length(args) != 2 ||

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen str_to_uint(args[0], &username_hash) < 0 ||

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen net_addr2ip(args[1], &ip) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid parameters");

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen return FALSE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen host = mail_host_lookup(conn->dir->mail_hosts, &ip);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (host == NULL) {

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen /* we probably just removed this host. */

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen return TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

f8c57c39abd8d987fdbc90dff5289b420017a700Timo Sirainen if (ret == 0) {

f8c57c39abd8d987fdbc90dff5289b420017a700Timo Sirainen /* First time we're seeing this - forward it to others also.

f8c57c39abd8d987fdbc90dff5289b420017a700Timo Sirainen weak_forward = TRUE;

f8c57c39abd8d987fdbc90dff5289b420017a700Timo Sirainen } else if (dir_host == conn->dir->self_host) {

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen /* We originated this USER-WEAK request. The entire ring has seen

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen dir_debug("user refresh: %u Our USER-WEAK seen by the entire ring",

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen username_hash);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen src_host = conn->dir->self_host;

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen weak = FALSE;

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen } else {

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen /* The original USER-WEAK sender will send a new non-weak USER

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen dir_debug("user refresh: %u Remote USER-WEAK from %s seen by the entire ring, ignoring",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen username_hash, dir_host->ip_str);

c6a5305674d2aa59ee52dc101ef87bbcb04f04efTimo Sirainen weak_forward = TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen ret = director_user_refresh(conn, username_hash,

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen host, ioloop_time, weak, &forced, &user);

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen /* user is refreshed with ioloop_time, it can't be expired already */

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen i_assert(ret >= 0);

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen if (ret > 0 || weak_forward) {

0bd3eb7c8139cfb80f46dc596c5fe7cdbb1d2aeeTimo Sirainen /* user changed, or we've decided that we need to forward

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen if (forced)

fb9dfa9ea15abdbf248021cfb7bf2846410116e6Timo Sirainen src_host = conn->dir->self_host;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen if (!user->weak)

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen director_update_user(conn->dir, src_host, user);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen else {

ab779efe68458cf6fdcaa4f99527685d5563df0aTimo Sirainen director_update_user_weak(conn->dir, src_host, conn,

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen dir_host, user);

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen }

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen return TRUE;

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen}

b6b9c99fefbbc662bd9a0006566133c4480bf0e8Timo Sirainen

a10ed8c47534b4c6b6bf2711ccfe577e720a47b4Timo Sirainenstatic bool ATTR_NULL(3)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainendirector_cmd_host_int(struct director_connection *conn, const char *const *args,

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct director_host *dir_host)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen struct director_host *src_host = conn->host;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct mail_host *host;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct ip_addr ip;

093b42b11c1236a687d3da564b26a324e2189ae6Timo Sirainen const char *tag = "", *host_tag, *hostname = NULL;

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen unsigned int arg_count, vhost_count;

a5ddfd7a8b473f73135b93d5e081e470a87f0f7eTimo Sirainen bool update, down = FALSE;

a5ddfd7a8b473f73135b93d5e081e470a87f0f7eTimo Sirainen time_t last_updown_change = 0;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen arg_count = str_array_length(args);

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen if (arg_count < 2 ||

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen net_addr2ip(args[0], &ip) < 0 ||

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen str_to_uint(args[1], &vhost_count) < 0) {

98d5941dc28754f32432edc38578b946ba71dd0bTimo Sirainen director_cmd_error(conn, "Invalid parameters");

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return FALSE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen if (arg_count >= 3)

09060303d565e15d54e42b4ef722f9d3c26f5336Timo Sirainen tag = args[2];

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen if (arg_count >= 4) {

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen if ((args[3][0] != 'D' && args[3][0] != 'U') ||

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen str_to_time(args[3]+1, &last_updown_change) < 0) {

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen director_cmd_error(conn, "Invalid updown parameters");

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen return FALSE;

a5ddfd7a8b473f73135b93d5e081e470a87f0f7eTimo Sirainen }

c5279d575d40f7c4c6cd4b44dbf8fba55e156d90Timo Sirainen down = args[3][0] == 'D';

a5ddfd7a8b473f73135b93d5e081e470a87f0f7eTimo Sirainen }

9de5eb9e1ac3a07c4197a60fdefd412d6cc78eb2Timo Sirainen if (arg_count >= 5)

9de5eb9e1ac3a07c4197a60fdefd412d6cc78eb2Timo Sirainen hostname = args[4];

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen if (conn->ignore_host_events) {

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen /* remote is sending hosts in a handshake, but it doesn't have

242abe3ad2423776e9cf05e1304eb8fda4831b23Timo Sirainen i_assert(conn->handshake_sending_hosts);

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen return TRUE;

8d63b0ab4dea920a4dd6a4469289950eef50a063Timo Sirainen }

ae32667c54480d329eed994b3defab89cd76c077Timo Sirainen if (tag[0] != '\0' && conn->minor_version < DIRECTOR_VERSION_TAGS_V2) {

ae32667c54480d329eed994b3defab89cd76c077Timo Sirainen director_cmd_error(conn, "Received a host tag from older director version with incompatible tagging support");

ae32667c54480d329eed994b3defab89cd76c077Timo Sirainen return FALSE;

ae32667c54480d329eed994b3defab89cd76c077Timo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

cf9d67e4a9bfee31cf3be05244555d51a3d1b9feTimo Sirainen host = mail_host_lookup(conn->dir->mail_hosts, &ip);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (host == NULL) {

9de5eb9e1ac3a07c4197a60fdefd412d6cc78eb2Timo Sirainen host = mail_host_add_hostname(conn->dir->mail_hosts,

9de5eb9e1ac3a07c4197a60fdefd412d6cc78eb2Timo Sirainen hostname, &ip, tag);

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen update = TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen } else {

a5ddfd7a8b473f73135b93d5e081e470a87f0f7eTimo Sirainen update = host->vhost_count != vhost_count ||

ed4a4d9b8289061627d5236da31b1a989b0fd6b1Timo Sirainen host->down != down;

1574df6b0bc965212f1152e480e7a762cdaa8226Timo Sirainen

093b42b11c1236a687d3da564b26a324e2189ae6Timo Sirainen host_tag = mail_host_get_tag(host);

093b42b11c1236a687d3da564b26a324e2189ae6Timo Sirainen if (strcmp(tag, host_tag) != 0) {

09060303d565e15d54e42b4ef722f9d3c26f5336Timo Sirainen i_error("director(%s): Host %s changed tag from '%s' to '%s'",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen conn->name, host->ip_str,

093b42b11c1236a687d3da564b26a324e2189ae6Timo Sirainen host_tag, tag);

09060303d565e15d54e42b4ef722f9d3c26f5336Timo Sirainen mail_host_set_tag(host, tag);

09060303d565e15d54e42b4ef722f9d3c26f5336Timo Sirainen update = TRUE;

09060303d565e15d54e42b4ef722f9d3c26f5336Timo Sirainen }

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen if (update && host->desynced) {

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen string_t *str = t_str_new(128);

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_printfa(str, "director(%s): Host %s is being updated before previous update had finished (",

bd4bbe6478a97e3fab77b05257dd1397c7c090eaTimo Sirainen conn->name, host->ip_str);

12f8ffba02e99b53ee71cd44f9947c6a59ff9ea4Timo Sirainen if (host->down != down &&

12f8ffba02e99b53ee71cd44f9947c6a59ff9ea4Timo Sirainen host->last_updown_change > last_updown_change) {

12f8ffba02e99b53ee71cd44f9947c6a59ff9ea4Timo Sirainen /* our host has a newer change. preserve it. */

12f8ffba02e99b53ee71cd44f9947c6a59ff9ea4Timo Sirainen down = host->down;

12f8ffba02e99b53ee71cd44f9947c6a59ff9ea4Timo Sirainen }

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen if (host->down != down) {

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen if (host->down)

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_append(str, "down -> up");

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen else

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_append(str, "up -> down");

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen }

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen if (host->vhost_count != vhost_count) {

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen if (host->down != down)

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_append(str, ", ");

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_printfa(str, "vhosts %u -> %u",

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen host->vhost_count, vhost_count);

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen }

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_append(str, ") - ");

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen vhost_count = I_MIN(vhost_count, host->vhost_count);

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen last_updown_change = I_MAX(last_updown_change,

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen host->last_updown_change);

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen str_printfa(str, "setting to state=%s vhosts=%u",

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen down ? "down" : "up", vhost_count);

78a6431465ac6ee6e870352a68ea1d7a8170376aTimo Sirainen i_warning("%s", str_c(str));

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen /* make the change appear to come from us, so it

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen dir_host = NULL;

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen src_host = conn->dir->self_host;

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (update) {

b3abfd0ac256ffa0cbfd74c3793eac4e83d41f78Martti Rannanjärvi const char *log_prefix = t_strdup_printf("director(%s): ",

b3abfd0ac256ffa0cbfd74c3793eac4e83d41f78Martti Rannanjärvi conn->name);

b3abfd0ac256ffa0cbfd74c3793eac4e83d41f78Martti Rannanjärvi mail_host_set_down(host, down, last_updown_change, log_prefix);

b3abfd0ac256ffa0cbfd74c3793eac4e83d41f78Martti Rannanjärvi mail_host_set_vhost_count(host, vhost_count, log_prefix);

8752573c44bcd139ae3ecc6d8e917c2c60bcb89fTimo Sirainen director_update_host(conn->dir, src_host, dir_host, host);

1574df6b0bc965212f1152e480e7a762cdaa8226Timo Sirainen } else {

1574df6b0bc965212f1152e480e7a762cdaa8226Timo Sirainen dir_debug("Ignoring host %s update vhost_count=%u "

1574df6b0bc965212f1152e480e7a762cdaa8226Timo Sirainen "down=%d last_updown_change=%ld (hosts_hash=%u)",

f0339f522dc9c8e2e8a29ef9a3f937c431c6bd1bTimo Sirainen net_ip2addr(&ip), vhost_count, down ? 1 : 0,

1574df6b0bc965212f1152e480e7a762cdaa8226Timo Sirainen (long)last_updown_change,

1574df6b0bc965212f1152e480e7a762cdaa8226Timo Sirainen mail_hosts_hash(conn->dir->mail_hosts));

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen }

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen return TRUE;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen}

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainenstatic bool

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainendirector_cmd_host_handshake(struct director_connection *conn,

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen const char *const *args)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen{

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return director_cmd_host_int(conn, args, NULL);

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen}

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainenstatic bool

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainendirector_cmd_host(struct director_connection *conn, const char *const *args)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen{

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct director_host *dir_host;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen int ret;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen if ((ret = director_cmd_is_seen(conn, &args, &dir_host)) != 0)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return ret > 0;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return director_cmd_host_int(conn, args, dir_host);

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen}

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainenstatic bool

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainendirector_cmd_host_remove(struct director_connection *conn,

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen const char *const *args)

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen{

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen struct director_host *dir_host;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct mail_host *host;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen struct ip_addr ip;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen int ret;

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen if ((ret = director_cmd_is_seen(conn, &args, &dir_host)) != 0)

0a53eb0283d7ec28c6105f61e118b96fce8ecb95Timo Sirainen return ret > 0;

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen

2670cd577aa57eb9f915a4f4220ae48c9b4fc5fbTimo Sirainen if (str_array_length(args) != 1 ||