dovecot/core-2.2: src/director/login-connection.c annotate

annotate src/director/login-connection.c @ 21389:59437f8764c6

global: Replaced all instances of memset(p, 0, sizeof(*p)) with the new i_zero() macro. Used the following script: C_FILES=`git ls-files *.c` H_FILES=`git ls-files *.h` for F in "$C_FILES $H_FILES"; do echo "$F" perl -p -i -e 's/safe_memset$&\(?([^,]*)$?,\s*0,\s*sizeof$\g1$\)/i_zero_safe(&$1)/g' $F perl -p -i -e 's/safe_memset$([^,]*),\s*0,\s*sizeof\(\*\g1$\)/i_zero_safe($1)/g' $F perl -p -i -e 's/memset$&\(?([^,]*)$?,\s*0,\s*sizeof$\g1$\)/i_zero(&$1)/g' $F perl -p -i -e 's/memset$([^,]*),\s*0,\s*sizeof\(\*\g1$\)/i_zero($1)/g' $F done

author	Stephan Bosch <stephan.bosch@dovecot.fi>
date	Wed, 11 Jan 2017 01:57:46 +0100
parents	fa67f1a329da
children	2e2563132d5f

rev	line source
19552 0f22db71df7a global: freshen copyright Timo Sirainen <timo.sirainen@dovecot.fi> parents: 19438 diff changeset	1 /* Copyright (c) 2010-2016 Dovecot authors, see the included COPYING file */
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	2
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	3 #include "lib.h"
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	4 #include "ioloop.h"
15187 02451e967a06 Renamed network.[ch] to net.[ch]. Timo Sirainen <tss@iki.fi> parents: 14681 diff changeset	5 #include "net.h"
19310 7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	6 #include "str.h"
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	7 #include "istream.h"
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	8 #include "ostream.h"
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	9 #include "llist.h"
11430 c82a7922fca9 director: Update connection counts also on login connection deinit. Timo Sirainen <tss@iki.fi> parents: 11326 diff changeset	10 #include "master-service.h"
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	11 #include "director.h"
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	12 #include "director-request.h"
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	13 #include "auth-connection.h"
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	14 #include "login-connection.h"
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	15
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	16 #include <unistd.h>
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	17
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	18 #define AUTHREPLY_PROTOCOL_MAJOR_VERSION 1
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	19 #define AUTHREPLY_PROTOCOL_MINOR_VERSION 0
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	20
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	21 struct login_connection {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	22 struct login_connection prev, next;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	23
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	24 int refcount;
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	25 enum login_connection_type type;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	26
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	27 int fd;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	28 struct io *io;
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	29 struct istream *input;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	30 struct ostream *output;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	31 struct auth_connection *auth;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	32 struct director *dir;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	33
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	34 unsigned int handshaked:1;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	35 unsigned int destroyed:1;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	36 };
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	37
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	38 struct login_host_request {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	39 struct login_connection *conn;
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	40 char line, username;
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	41
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	42 struct ip_addr local_ip;
19035 aabfe48db1cf Changed type of internet port values to in_port_t everywhere. Stephan Bosch <stephan@rename-it.nl> parents: 18675 diff changeset	43 in_port_t local_port;
aabfe48db1cf Changed type of internet port values to in_port_t everywhere. Stephan Bosch <stephan@rename-it.nl> parents: 18675 diff changeset	44 in_port_t dest_port;
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	45 bool director_proxy_maybe;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	46 };
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	47
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	48 static struct login_connection *login_connections;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	49
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	50 static void auth_input_line(const char line, void context);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	51 static void login_connection_unref(struct login_connection **_conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	52
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	53 static void login_connection_input(struct login_connection *conn)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	54 {
18670 d54dc360cd3c director: Minor code cleanup - allow access to auth connection's ostream directly. Timo Sirainen <tss@iki.fi> parents: 18669 diff changeset	55 struct ostream *output;
18669 67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	56 unsigned char buf[4096];
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	57 ssize_t ret;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	58
18669 67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	59 ret = read(conn->fd, buf, sizeof(buf));
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	60 if (ret <= 0) {
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	61 if (ret < 0) {
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	62 if (errno == EAGAIN)
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	63 return;
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	64 if (errno != ECONNRESET)
67fdd6f962f5 director: Reverted previous e178413a905d commit after all - do it a bit differently. Timo Sirainen <tss@iki.fi> parents: 18666 diff changeset	65 i_error("read(login connection) failed: %m");
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	66 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	67 login_connection_deinit(&conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	68 return;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	69 }
18670 d54dc360cd3c director: Minor code cleanup - allow access to auth connection's ostream directly. Timo Sirainen <tss@iki.fi> parents: 18669 diff changeset	70 output = auth_connection_get_output(conn->auth);
d54dc360cd3c director: Minor code cleanup - allow access to auth connection's ostream directly. Timo Sirainen <tss@iki.fi> parents: 18669 diff changeset	71 o_stream_nsend(output, buf, ret);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	72 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	73
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	74 static void login_connection_authreply_input(struct login_connection *conn)
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	75 {
20693 fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	76 bool bail = FALSE;
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	77 const char *line;
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	78
20693 fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	79 while (!bail && (line = i_stream_read_next_line(conn->input)) != NULL) T_BEGIN {
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	80 if (!conn->handshaked) {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	81 if (!version_string_verify(line, "director-authreply-client",
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	82 AUTHREPLY_PROTOCOL_MAJOR_VERSION)) {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	83 i_error("authreply client sent invalid handshake: %s", line);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	84 login_connection_deinit(&conn);
20693 fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	85 bail = TRUE; /* don't return from within a T_BEGIN {...} T_END */
fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	86 } else {
fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	87 conn->handshaked = TRUE;
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	88 }
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	89 } else {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	90 auth_input_line(line, conn);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	91 }
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	92 } T_END;
20693 fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	93
fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	94 if (bail)
fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	95 return;
fa67f1a329da Fix control flow and T_BEGIN/T_END hygiene Phil Carmody <phil@dovecot.fi> parents: 19552 diff changeset	96
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	97 if (conn->input->eof) {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	98 if (conn->input->stream_errno != 0 &&
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	99 conn->input->stream_errno != ECONNRESET) {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	100 i_error("read(authreply connection) failed: %s",
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	101 i_stream_get_error(conn->input));
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	102 }
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	103 login_connection_deinit(&conn);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	104 }
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	105 }
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	106
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	107 static void
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	108 login_connection_send_line(struct login_connection conn, const char line)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	109 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	110 struct const_iovec iov[2];
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	111
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	112 if (conn->destroyed)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	113 return;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	114
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	115 iov[0].iov_base = line;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	116 iov[0].iov_len = strlen(line);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	117 iov[1].iov_base = "\n";
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	118 iov[1].iov_len = 1;
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14471 diff changeset	119 o_stream_nsendv(conn->output, iov, N_ELEMENTS(iov));
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	120 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	121
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	122 static bool login_host_request_is_self(struct login_host_request *request,
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	123 const struct ip_addr *dest_ip)
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	124 {
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	125 if (!net_ip_compare(dest_ip, &request->local_ip))
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	126 return FALSE;
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	127 if (request->dest_port != 0 && request->local_port != 0 &&
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	128 request->dest_port != request->local_port)
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	129 return FALSE;
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	130 return TRUE;
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	131 }
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	132
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	133 static void
19310 7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	134 login_host_callback(const struct ip_addr ip, const char hostname,
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	135 const char errormsg, void context)
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	136 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	137 struct login_host_request *request = context;
11325 2a5336ad86cd director: Tell login proxy to notify director of open connections every director_user_expire/2 secs. Timo Sirainen <tss@iki.fi> parents: 11321 diff changeset	138 struct director *dir = request->conn->dir;
16785 b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	139 const char line, line_params;
11325 2a5336ad86cd director: Tell login proxy to notify director of open connections every director_user_expire/2 secs. Timo Sirainen <tss@iki.fi> parents: 11321 diff changeset	140 unsigned int secs;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	141
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	142 if (ip == NULL) {
16785 b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	143 if (strncmp(request->line, "OK\t", 3) == 0)
b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	144 line_params = request->line + 3;
b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	145 else if (strncmp(request->line, "PASS\t", 5) == 0)
b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	146 line_params = request->line + 5;
b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	147 else
b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	148 i_panic("BUG: Unexpected line: %s", request->line);
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	149
c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	150 i_error("director: User %s host lookup failed: %s",
c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	151 request->username, errormsg);
16785 b135d723acf3 director: Don't assert-crash if PASS lookup fails. Timo Sirainen <tss@iki.fi> parents: 16614 diff changeset	152 line = t_strconcat("FAIL\t", t_strcut(line_params, '\t'),
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	153 "\ttemp", NULL);
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	154 } else if (request->director_proxy_maybe &&
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	155 login_host_request_is_self(request, ip)) {
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	156 line = request->line;
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	157 } else {
19310 7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	158 string_t *str = t_str_new(64);
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	159
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	160 secs = dir->set->director_user_expire / 2;
19310 7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	161 str_printfa(str, "%s\tproxy_refresh=%u\t", request->line, secs);
19438 f643e85f42ec director: Don't treat empty hostname the same as having it. Timo Sirainen <tss@iki.fi> parents: 19310 diff changeset	162 if (hostname == NULL \|\| hostname[0] == '\0')
19310 7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	163 str_printfa(str, "host=%s", net_ip2addr(ip));
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	164 else {
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	165 str_printfa(str, "host=%s\thostip=%s",
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	166 hostname, net_ip2addr(ip));
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	167 }
7f718c840aff director: Remember backends' hostnames and send them in login reply. Timo Sirainen <tss@iki.fi> parents: 19035 diff changeset	168 line = str_c(str);
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	169 }
c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	170 login_connection_send_line(request->conn, line);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	171
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	172 login_connection_unref(&request->conn);
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	173 i_free(request->username);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	174 i_free(request->line);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	175 i_free(request);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	176 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	177
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	178 static void auth_input_line(const char line, void context)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	179 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	180 struct login_connection *conn = context;
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	181 struct login_host_request *request, temp_request;
18067 a7e830b9b967 director: Added support for backend cluster "tags". Timo Sirainen <tss@iki.fi> parents: 17467 diff changeset	182 const char const args, line_params, username = NULL, *tag = "";
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	183 bool proxy = FALSE, host = FALSE;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	184
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	185 if (line == NULL) {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	186 /* auth connection died -> kill also this login connection */
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	187 login_connection_deinit(&conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	188 return;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	189 }
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	190 if (conn->type != LOGIN_CONNECTION_TYPE_USERDB &&
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	191 strncmp(line, "OK\t", 3) == 0)
11714 1683324ac632 director: Added support for LMTP proxying. Timo Sirainen <tss@iki.fi> parents: 11430 diff changeset	192 line_params = line + 3;
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	193 else if (conn->type == LOGIN_CONNECTION_TYPE_USERDB &&
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	194 strncmp(line, "PASS\t", 5) == 0)
11714 1683324ac632 director: Added support for LMTP proxying. Timo Sirainen <tss@iki.fi> parents: 11430 diff changeset	195 line_params = line + 5;
1683324ac632 director: Added support for LMTP proxying. Timo Sirainen <tss@iki.fi> parents: 11430 diff changeset	196 else {
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	197 login_connection_send_line(conn, line);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	198 return;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	199 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	200
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	201 /* OK <id> [<parameters>] */
14471 fc8031c5e691 Use t_strsplit_tab() wherever possible Timo Sirainen <tss@iki.fi> parents: 14133 diff changeset	202 args = t_strsplit_tab(line_params);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	203 if (*args != NULL) {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	204 /* we should always get here, but in case we don't just
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	205 forward as-is and let login process handle the error. */
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	206 args++;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	207 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	208
21389 59437f8764c6 global: Replaced all instances of memset(p, 0, sizeof(p)) with the new i_zero() macro. Stephan Bosch <stephan.bosch@dovecot.fi>* parents: 20693 diff changeset	209 i_zero(&temp_request);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	210 for (; *args != NULL; args++) {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	211 if (strncmp(*args, "proxy", 5) == 0 &&
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	212 ((args)[5] == '=' \|\| (args)[5] == '\0'))
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	213 proxy = TRUE;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	214 else if (strncmp(*args, "host=", 5) == 0)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	215 host = TRUE;
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	216 else if (strncmp(*args, "lip=", 4) == 0) {
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	217 if (net_addr2ip((*args) + 4, &temp_request.local_ip) < 0)
18503 333533e2d231 director: Log error if auth sends invalid lip/lport/port parameter. Timo Sirainen <tss@iki.fi> parents: 18498 diff changeset	218 i_error("auth sent invalid lip field: %s", (*args) + 6);
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	219 } else if (strncmp(*args, "lport=", 6) == 0) {
19035 aabfe48db1cf Changed type of internet port values to in_port_t everywhere. Stephan Bosch <stephan@rename-it.nl> parents: 18675 diff changeset	220 if (net_str2port((*args) + 6, &temp_request.local_port) < 0)
18503 333533e2d231 director: Log error if auth sends invalid lip/lport/port parameter. Timo Sirainen <tss@iki.fi> parents: 18498 diff changeset	221 i_error("auth sent invalid lport field: %s", (*args) + 6);
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	222 } else if (strncmp(*args, "port=", 5) == 0) {
19035 aabfe48db1cf Changed type of internet port values to in_port_t everywhere. Stephan Bosch <stephan@rename-it.nl> parents: 18675 diff changeset	223 if (net_str2port((*args) + 5, &temp_request.dest_port) < 0)
18503 333533e2d231 director: Log error if auth sends invalid lip/lport/port parameter. Timo Sirainen <tss@iki.fi> parents: 18498 diff changeset	224 i_error("auth sent invalid port field: %s", (*args) + 6);
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	225 } else if (strncmp(*args, "destuser=", 9) == 0)
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	226 username = *args + 9;
18067 a7e830b9b967 director: Added support for backend cluster "tags". Timo Sirainen <tss@iki.fi> parents: 17467 diff changeset	227 else if (strncmp(*args, "director_tag=", 13) == 0)
a7e830b9b967 director: Added support for backend cluster "tags". Timo Sirainen <tss@iki.fi> parents: 17467 diff changeset	228 tag = *args + 13;
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	229 else if (strncmp(*args, "director_proxy_maybe", 20) == 0 &&
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	230 ((args)[20] == '=' \|\| (args)[20] == '\0'))
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	231 temp_request.director_proxy_maybe = TRUE;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	232 else if (strncmp(*args, "user=", 5) == 0) {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	233 if (username == NULL)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	234 username = *args + 5;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	235 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	236 }
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	237 if ((!proxy && !temp_request.director_proxy_maybe) \|\|
c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	238 host \|\| username == NULL) {
17467 899cf87a687c director: Fixed crash if master_user_separator is set, but we didn't do a proxy lookup. Timo Sirainen <tss@iki.fi> parents: 17130 diff changeset	239 login_connection_send_line(conn, line);
899cf87a687c director: Fixed crash if master_user_separator is set, but we didn't do a proxy lookup. Timo Sirainen <tss@iki.fi> parents: 17130 diff changeset	240 return;
899cf87a687c director: Fixed crash if master_user_separator is set, but we didn't do a proxy lookup. Timo Sirainen <tss@iki.fi> parents: 17130 diff changeset	241 }
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	242 if (*conn->dir->set->master_user_separator != '\0') {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	243 /* with master user logins we still want to use only the
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	244 login username */
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	245 username = t_strcut(username,
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	246 *conn->dir->set->master_user_separator);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	247 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	248
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	249 /* we need to add the host. the lookup might be asynchronous */
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	250 request = i_new(struct login_host_request, 1);
18498 c5cdf42e398a director: Implemented director_proxy_maybe passdb extra field. Timo Sirainen <tss@iki.fi> parents: 18137 diff changeset	251 *request = temp_request;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	252 request->conn = conn;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	253 request->line = i_strdup(line);
13921 c70965e8b27d director: If request is timed out, log an error. Timo Sirainen <tss@iki.fi> parents: 12782 diff changeset	254 request->username = i_strdup(username);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	255
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	256 conn->refcount++;
18067 a7e830b9b967 director: Added support for backend cluster "tags". Timo Sirainen <tss@iki.fi> parents: 17467 diff changeset	257 director_request(conn->dir, username, tag, login_host_callback, request);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	258 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	259
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	260 struct login_connection *
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	261 login_connection_init(struct director *dir, int fd,
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	262 struct auth_connection *auth,
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	263 enum login_connection_type type)
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	264 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	265 struct login_connection *conn;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	266
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	267 conn = i_new(struct login_connection, 1);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	268 conn->refcount = 1;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	269 conn->fd = fd;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	270 conn->dir = dir;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	271 conn->output = o_stream_create_fd(conn->fd, (size_t)-1, FALSE);
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14471 diff changeset	272 o_stream_set_no_error_handling(conn->output, TRUE);
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	273 if (type != LOGIN_CONNECTION_TYPE_AUTHREPLY) {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	274 i_assert(auth != NULL);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	275 conn->auth = auth;
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	276 conn->io = io_add(conn->fd, IO_READ,
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	277 login_connection_input, conn);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	278 auth_connection_set_callback(conn->auth, auth_input_line, conn);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	279 } else {
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	280 i_assert(auth == NULL);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	281 conn->input = i_stream_create_fd(conn->fd, IO_BLOCK_SIZE, FALSE);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	282 conn->io = io_add(conn->fd, IO_READ,
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	283 login_connection_authreply_input, conn);
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	284 o_stream_nsend_str(conn->output, t_strdup_printf(
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	285 "VERSION\tdirector-authreply-server\t%d\t%d\n",
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	286 AUTHREPLY_PROTOCOL_MAJOR_VERSION,
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	287 AUTHREPLY_PROTOCOL_MINOR_VERSION));
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	288 }
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	289 conn->type = type;
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	290
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	291 DLLIST_PREPEND(&login_connections, conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	292 return conn;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	293 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	294
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	295 void login_connection_deinit(struct login_connection **_conn)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	296 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	297 struct login_connection conn = _conn;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	298
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	299 *_conn = NULL;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	300
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	301 if (conn->destroyed)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	302 return;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	303 conn->destroyed = TRUE;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	304
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	305 DLLIST_REMOVE(&login_connections, conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	306 io_remove(&conn->io);
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	307 if (conn->input != NULL)
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	308 i_stream_destroy(&conn->input);
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14471 diff changeset	309 o_stream_destroy(&conn->output);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	310 if (close(conn->fd) < 0)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	311 i_error("close(login connection) failed: %m");
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	312 conn->fd = -1;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	313
18675 52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	314 if (conn->auth != NULL)
52cdf321fa07 director: Added "authreply" socket type. Timo Sirainen <tss@iki.fi> parents: 18670 diff changeset	315 auth_connection_deinit(&conn->auth);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	316 login_connection_unref(&conn);
11430 c82a7922fca9 director: Update connection counts also on login connection deinit. Timo Sirainen <tss@iki.fi> parents: 11326 diff changeset	317
c82a7922fca9 director: Update connection counts also on login connection deinit. Timo Sirainen <tss@iki.fi> parents: 11326 diff changeset	318 master_service_client_connection_destroyed(master_service);
11321 5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	319 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	320
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	321 static void login_connection_unref(struct login_connection **_conn)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	322 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	323 struct login_connection conn = _conn;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	324
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	325 *_conn = NULL;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	326
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	327 i_assert(conn->refcount > 0);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	328 if (--conn->refcount == 0)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	329 i_free(conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	330 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	331
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	332 void login_connections_deinit(void)
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	333 {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	334 while (login_connections != NULL) {
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	335 struct login_connection *conn = login_connections;
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	336
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	337 login_connection_deinit(&conn);
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	338 }
5f350b5ff6d9 Added initial implementation of a director process (for NFS users). Timo Sirainen <tss@iki.fi> parents: diff changeset	339 }

Mercurial > dovecot > core-2.2

annotate src/director/login-connection.c @ 21389:59437f8764c6