src/director/director.h

	director.h revision d3bae1f9d2448e5c398145ea250849ec12583845
#ifndef DIRECTOR_H
#define DIRECTOR_H

#include "net.h"
#include "director-settings.h"

#define DIRECTOR_VERSION_NAME "director"
#define DIRECTOR_VERSION_MAJOR 1
#define DIRECTOR_VERSION_MINOR 8

/* weak users supported in protocol */
#define DIRECTOR_VERSION_WEAK_USERS 1
/* director ring remove supported */
#define DIRECTOR_VERSION_RING_REMOVE 2
/* quit reason supported */
#define DIRECTOR_VERSION_QUIT 3
/* user-kick supported */
#define DIRECTOR_VERSION_USER_KICK 4
/* options supported in handshake */
#define DIRECTOR_VERSION_OPTIONS 5
/* user tags supported */
#define DIRECTOR_VERSION_TAGS 5
/* up/down state is tracked */
#define DIRECTOR_VERSION_UPDOWN 6
/* user tag version 2 supported */
#define DIRECTOR_VERSION_TAGS_V2 7
/* user-kick-alt supported */
#define DIRECTOR_VERSION_USER_KICK_ALT 8

/* Minimum time between even attempting to communicate with a director that
   failed due to a protocol error. */
#define DIRECTOR_PROTOCOL_FAILURE_RETRY_SECS 60

struct director;
struct mail_host;
struct user;

typedef void director_state_change_callback_t(struct director *dir);

struct director {
    const struct director_settings *set;

    /* IP and port of this director. self_host->ip/port must equal these. */
    struct ip_addr self_ip;
    in_port_t self_port;

    in_port_t test_port;

    struct director_host *self_host;
    /* left and right connections are set only after they have finished
       handshaking. until then they're in the connections list, although
       updates are still sent to them during handshaking if the USER list
       is long. */
    struct director_connection *left, *right;
    /* all director connections */
    ARRAY(struct director_connection *) connections;
    struct timeout *to_reconnect;
    struct timeout *to_sync;
    struct timeout *to_callback;

    /* current mail hosts */
    struct mail_host_list *mail_hosts;
    /* original mail hosts configured in config file.
       this is used only for doveadm lookups */
    struct mail_host_list *orig_config_hosts;
    /* temporary user -> host associations */
    struct user_directory *users;
    /* Number of users currently being moved */
    unsigned int users_moving_count;

    /* these requests are waiting for directors to be in synced */
    ARRAY(struct director_request *) pending_requests;
    struct timeout *to_request;
    struct timeout *to_handshake_warning;

    director_state_change_callback_t *state_change_callback;

    /* director hosts are sorted by IP (and port) */
    ARRAY(struct director_host *) dir_hosts;
    struct timeout *to_remove_dirs;

    struct ipc_client *ipc_proxy;
    unsigned int sync_seq;
    unsigned int ring_change_counter;
    unsigned int last_sync_sent_ring_change_counter;
    /* the lowest minor version supported by the ring */
    unsigned int ring_min_version;
    time_t ring_last_sync_time;

    time_t ring_first_alone;

    uint64_t num_requests;
    uint64_t ring_traffic_input, ring_traffic_output;

    /* director ring handshaking is complete.
       director can start serving clients. */
    bool ring_handshaked:1;
    bool ring_handshake_warning_sent:1;
    bool ring_synced:1;
    bool sync_frozen:1;
    bool sync_pending:1;
};

extern bool director_debug;
extern struct director *director; /* FIXME: shouldn't be global */

/* Create a new director. If listen_ip specifies an actual IP, it's used with
   listen_port for finding ourself from the director_servers setting.
   listen_port is used regardless by director_host_add_from_string() for hosts
   without specified port. */
struct director *
director_init(const struct director_settings *set,
          const struct ip_addr *listen_ip, in_port_t listen_port,
          director_state_change_callback_t *callback);
void director_deinit(struct director **dir);
void director_find_self(struct director *dir);

/* Start connecting to other directors */
void director_connect(struct director *dir);

void director_set_ring_handshaked(struct director *dir);
void director_set_ring_synced(struct director *dir);
void director_set_ring_unsynced(struct director *dir);
void director_set_state_changed(struct director *dir);
void director_sync_send(struct director *dir, struct director_host *host,
            uint32_t seq, unsigned int minor_version,
            unsigned int timestamp, unsigned int hosts_hash);
bool director_resend_sync(struct director *dir);

void director_notify_ring_added(struct director_host *added_host,
                struct director_host *src);
void director_ring_remove(struct director_host *removed_host,
              struct director_host *src);

void director_update_host(struct director *dir, struct director_host *src,
              struct director_host *orig_src,
              struct mail_host *host) ATTR_NULL(3);
void director_resend_hosts(struct director *dir);
void director_remove_host(struct director *dir, struct director_host *src,
              struct director_host *orig_src,
              struct mail_host *host) ATTR_NULL(2, 3);
void director_flush_host(struct director *dir, struct director_host *src,
             struct director_host *orig_src,
             struct mail_host *host) ATTR_NULL(3);
void director_update_user(struct director *dir, struct director_host *src,
              struct user *user);
void director_update_user_weak(struct director *dir, struct director_host *src,
                   struct director_connection *src_conn,
                   struct director_host *orig_src,
                   struct user *user) ATTR_NULL(3);
void director_move_user(struct director *dir, struct director_host *src,
            struct director_host *orig_src,
            unsigned int username_hash, struct mail_host *host)
    ATTR_NULL(3);
void director_kick_user(struct director *dir, struct director_host *src,
            struct director_host *orig_src, const char *username)
    ATTR_NULL(3);
void director_kick_user_alt(struct director *dir, struct director_host *src,
                struct director_host *orig_src,
                const char *field, const char *value)
    ATTR_NULL(3);
void director_kick_user_hash(struct director *dir, struct director_host *src,
                 struct director_host *orig_src,
                 unsigned int username_hash,
                 const struct ip_addr *except_ip)
    ATTR_NULL(3);
void director_user_killed(struct director *dir, unsigned int username_hash);
void director_user_killed_everywhere(struct director *dir,
                     struct director_host *src,
                     struct director_host *orig_src,
                     unsigned int username_hash) ATTR_NULL(3);
void director_user_weak(struct director *dir, struct user *user);

void director_sync_freeze(struct director *dir);
void director_sync_thaw(struct director *dir);

/* Send data to all directors using both left and right connections
   (unless they're the same). */
void director_update_send(struct director *dir, struct director_host *src,
              const char *cmd);
void director_update_send_version(struct director *dir,
                  struct director_host *src,
                  unsigned int min_version, const char *cmd);

int director_connect_host(struct director *dir, struct director_host *host);

void directors_init(void);
void directors_deinit(void);

void dir_debug(const char *fmt, ...) ATTR_FORMAT(1, 2);

#endif