src/auth/auth-master-connection.c

	auth-master-connection.c revision 6f71a6a4ed759df963587302976d7315346d11f8
/* Copyright (C) 2002 Timo Sirainen */

#include "common.h"
#include "buffer.h"
#include "hash.h"
#include "str.h"
#include "ioloop.h"
#include "istream.h"
#include "ostream.h"
#include "network.h"
#include "userdb.h"
#include "auth-request-handler.h"
#include "auth-request-balancer.h"
#include "auth-master-interface.h"
#include "auth-client-connection.h"
#include "auth-master-connection.h"

#include <unistd.h>
#include <stdlib.h>

#define MAX_INBUF_SIZE 1024
#define MAX_OUTBUF_SIZE (1024*50)

struct auth_listener {
    struct auth_master_connection *master;
    enum listener_type type;
    int fd;
    char *path;
    struct io *io;
};

struct master_userdb_request {
    struct auth_master_connection *conn;
    unsigned int id;
    struct auth_request *auth_request;
};

static int master_output(void *context);
static void auth_master_connection_close(struct auth_master_connection *conn);
static int auth_master_connection_unref(struct auth_master_connection *conn);
static void auth_listener_destroy(struct auth_listener *l);

void auth_master_request_callback(const char *reply, void *context)
{
    struct auth_master_connection *conn = context;
    struct const_iovec iov[2];

    iov[0].iov_base = reply;
    iov[0].iov_len = strlen(reply);
    iov[1].iov_base = "\n";
    iov[1].iov_len = 1;

    (void)o_stream_sendv(conn->output, iov, 2);
}

static int
master_input_request(struct auth_master_connection *conn, const char *args)
{
    struct auth_client_connection *client_conn;
    const char *const *list;
    unsigned int id, client_pid, client_id;

    /* <id> <client-pid> <client-id> */
    list = t_strsplit(args, "\t");
    if (list[0] == NULL || list[1] == NULL || list[2] == NULL) {
        i_error("BUG: Master sent broken REQUEST");
        return FALSE;
    }

    id = (unsigned int)strtoul(list[0], NULL, 10);
    client_pid = (unsigned int)strtoul(list[1], NULL, 10);
    client_id = (unsigned int)strtoul(list[2], NULL, 10);

    client_conn = auth_client_connection_lookup(conn, client_pid);
    if (client_conn == NULL) {
        i_error("Master requested auth for nonexisting client %u",
            client_pid);
        (void)o_stream_send_str(conn->output,
                    t_strdup_printf("NOTFOUND\t%u\n", id));
    } else {
        auth_request_handler_master_request(
            client_conn->request_handler, id, client_id);
    }
    return TRUE;
}

static int
master_input_die(struct auth_master_connection *conn)
{
    return TRUE;
}

static void master_input(void *context)
{
    struct auth_master_connection *conn = context;
    char *line;
    int ret;

    switch (i_stream_read(conn->input)) {
    case 0:
        return;
    case -1:
        /* disconnected */
                auth_master_connection_close(conn);
        return;
    case -2:
        /* buffer full */
        i_error("BUG: Master sent us more than %d bytes",
            (int)MAX_INBUF_SIZE);
                auth_master_connection_close(conn);
        return;
    }

    if (!conn->version_received) {
        line = i_stream_next_line(conn->input);
        if (line == NULL)
            return;

        /* make sure the major version matches */
        if (strncmp(line, "VERSION\t", 8) != 0 ||
            atoi(t_strcut(line + 8, '\t')) !=
            AUTH_MASTER_PROTOCOL_MAJOR_VERSION) {
            i_error("Master not compatible with this server "
                "(mixed old and new binaries?)");
            auth_master_connection_close(conn);
            return;
        }
        conn->version_received = TRUE;
    }

    while ((line = i_stream_next_line(conn->input)) != NULL) {
        t_push();
        if (strncmp(line, "REQUEST\t", 8) == 0)
            ret = master_input_request(conn, line + 8);
        else if (strcmp(line, "DIE") == 0)
            ret = master_input_die(conn);
        else {
            /* ignore unknown command */
            ret = TRUE;
        }
        t_pop();

        if (!ret) {
            auth_master_connection_close(conn);
            return;
        }
    }
}

static int master_output(void *context)
{
    struct auth_master_connection *conn = context;
    int ret;

    if ((ret = o_stream_flush(conn->output)) < 0) {
        /* transmit error, probably master died */
        auth_master_connection_close(conn);
        return 1;
    }

    if (o_stream_get_buffer_used_size(conn->output) <= MAX_OUTBUF_SIZE/2) {
        /* allow input again */
        conn->io = io_add(conn->fd, IO_READ, master_input, conn);
    }
    return 1;
}

static void
auth_master_connection_set_fd(struct auth_master_connection *conn, int fd)
{
    if (conn->input != NULL)
        i_stream_unref(conn->input);
    if (conn->output != NULL)
        o_stream_unref(conn->output);
    if (conn->io != NULL)
        io_remove(conn->io);

    conn->input = i_stream_create_file(fd, default_pool,
                       MAX_INBUF_SIZE, FALSE);
    conn->output = o_stream_create_file(fd, default_pool,
                        (size_t)-1, FALSE);
    o_stream_set_flush_callback(conn->output, master_output, conn);
    conn->io = io_add(fd, IO_READ, master_input, conn);

    conn->fd = fd;
}

struct auth_master_connection *
auth_master_connection_create(struct auth *auth, int fd)
{
    struct auth_master_connection *conn;

    conn = i_new(struct auth_master_connection, 1);
    conn->auth = auth;
    conn->refcount = 1;
    conn->pid = (unsigned int)getpid();
    conn->fd = fd;
    conn->listeners_buf = buffer_create_dynamic(default_pool, 64);
    if (fd != -1)
                auth_master_connection_set_fd(conn, fd);
    return conn;
}

void auth_master_connection_send_handshake(struct auth_master_connection *conn)
{
    const char *line;

    if (conn->output == NULL)
        return;

    line = t_strdup_printf("VERSION\t%u\t%u\nSPID\t%u\n",
                   AUTH_MASTER_PROTOCOL_MAJOR_VERSION,
                   AUTH_MASTER_PROTOCOL_MINOR_VERSION, conn->pid);
    (void)o_stream_send_str(conn->output, line);
}

static void auth_master_connection_close(struct auth_master_connection *conn)
{
    if (!standalone)
        io_loop_stop(ioloop);

    if (close(conn->fd) < 0)
        i_error("close(): %m");
    conn->fd = -1;

    o_stream_close(conn->output);
    conn->output = NULL;

    if (conn->io != NULL) {
        io_remove(conn->io);
        conn->io = NULL;
    }
}

void auth_master_connection_destroy(struct auth_master_connection *conn)
{
    struct auth_listener **l;

    if (conn->destroyed)
        return;
    conn->destroyed = TRUE;

    auth_client_connections_deinit(conn);

    if (conn->fd != -1)
        auth_master_connection_close(conn);

    while (conn->listeners_buf->used > 0) {
        l = buffer_get_modifyable_data(conn->listeners_buf, NULL);
        auth_listener_destroy(*l);
    }
    buffer_free(conn->listeners_buf);
    conn->listeners_buf = NULL;

    auth_master_connection_unref(conn);
}

static int auth_master_connection_unref(struct auth_master_connection *conn)
{
    if (--conn->refcount > 0)
        return TRUE;

    if (conn->output != NULL)
        o_stream_unref(conn->output);
    i_free(conn);
    return FALSE;
}

static void auth_accept(void *context)
{
    struct auth_listener *l = context;
    int fd;

    fd = net_accept(l->fd, NULL, NULL);
    if (fd < 0) {
        if (fd < -1)
            i_fatal("accept(type %d) failed: %m", l->type);
    } else {
        net_set_nonblock(fd, TRUE);
        switch (l->type) {
        case LISTENER_CLIENT:
            (void)auth_client_connection_create(l->master, fd);
            break;
        case LISTENER_MASTER:
            /* we'll just replace the previous master.. */
            auth_master_connection_set_fd(l->master, fd);
            auth_master_connection_send_handshake(l->master);
            break;
        case LISTENER_BALANCER:
            /* worker process connected to us */
            auth_request_balancer_add_child(fd);
            break;
        }
    }
}

void auth_master_connection_add_listener(struct auth_master_connection *conn,
                     int fd, const char *path,
                     enum listener_type type)
{
    struct auth_listener *l;

    l = i_new(struct auth_listener, 1);
    l->master = conn;
    l->type = type;
    l->fd = fd;
    l->path = i_strdup(path);
    l->io = io_add(fd, IO_READ, auth_accept, l);

    buffer_append(conn->listeners_buf, &l, sizeof(l));
}

static void auth_listener_destroy(struct auth_listener *l)
{
    struct auth_listener **lp;
    size_t i, size;

    lp = buffer_get_modifyable_data(l->master->listeners_buf, &size);
    size /= sizeof(*lp);

    for (i = 0; i < size; i++) {
        if (lp[i] == l) {
            buffer_delete(l->master->listeners_buf,
                      i * sizeof(l), sizeof(l));
            break;
        }
    }

    net_disconnect(l->fd);
    io_remove(l->io);
    if (l->path != NULL) {
        (void)unlink(l->path);
        i_free(l->path);
    }
    i_free(l);
}