blob: 48dabe89864d3d6f5b2abb14eba8f844fcfd0bc2 [file] [log] [blame]
Willy Tarreaubaaee002006-06-26 02:48:02 +02001/*
Willy Tarreau03fa5df2010-05-24 21:02:37 +02002 * Frontend variables and functions.
Willy Tarreaubaaee002006-06-26 02:48:02 +02003 *
Willy Tarreaud6896bc2013-01-07 22:48:29 +01004 * Copyright 2000-2013 Willy Tarreau <w@1wt.eu>
Willy Tarreaubaaee002006-06-26 02:48:02 +02005 *
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
10 *
11 */
12
13#include <errno.h>
14#include <fcntl.h>
15#include <stdio.h>
16#include <stdlib.h>
Willy Tarreau2dd0d472006-06-29 17:53:05 +020017#include <string.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020018
19#include <sys/socket.h>
20#include <sys/stat.h>
21#include <sys/types.h>
22
Willy Tarreau48a7e722010-12-24 15:26:39 +010023#include <netinet/tcp.h>
24
Willy Tarreauc7e42382012-08-24 19:22:53 +020025#include <common/chunk.h>
Willy Tarreau2dd0d472006-06-29 17:53:05 +020026#include <common/compat.h>
Willy Tarreaue3ba5f02006-06-29 18:54:54 +020027#include <common/config.h>
Willy Tarreau8b0cbf92010-10-15 23:23:19 +020028#include <common/debug.h>
29#include <common/standard.h>
Willy Tarreau2dd0d472006-06-29 17:53:05 +020030#include <common/time.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020031
Willy Tarreaubaaee002006-06-26 02:48:02 +020032#include <types/global.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020033
Willy Tarreau8797c062007-05-07 00:55:35 +020034#include <proto/acl.h>
Willy Tarreau61612d42012-04-19 18:42:05 +020035#include <proto/arg.h>
Willy Tarreauc7e42382012-08-24 19:22:53 +020036#include <proto/channel.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020037#include <proto/fd.h>
Willy Tarreau03fa5df2010-05-24 21:02:37 +020038#include <proto/frontend.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020039#include <proto/log.h>
Willy Tarreaue5f20dc2006-12-03 15:21:35 +010040#include <proto/hdr_idx.h>
Willy Tarreau9650f372009-08-16 14:02:45 +020041#include <proto/proto_tcp.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020042#include <proto/proto_http.h>
Willy Tarreau7f062c42009-03-05 18:43:00 +010043#include <proto/proxy.h>
Willy Tarreaud6896bc2013-01-07 22:48:29 +010044#include <proto/sample.h>
Willy Tarreauc6ca1a02007-05-13 19:43:47 +020045#include <proto/session.h>
Willy Tarreaudded32d2008-11-30 19:48:07 +010046#include <proto/stream_interface.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020047#include <proto/task.h>
48
Willy Tarreau81f9aa32010-06-01 17:45:26 +020049/* Finish a session accept() for a proxy (TCP or HTTP). It returns a negative
Willy Tarreauabe8ea52010-11-11 10:56:04 +010050 * value in case of a critical failure which must cause the listener to be
51 * disabled, a positive value in case of success, or zero if it is a success
Willy Tarreaub363a1f2013-10-01 10:45:07 +020052 * but the session must be closed ASAP (eg: monitoring). It only supports
53 * sessions with a connection in si[0].
Willy Tarreaubaaee002006-06-26 02:48:02 +020054 */
Willy Tarreau81f9aa32010-06-01 17:45:26 +020055int frontend_accept(struct session *s)
Willy Tarreaueb472682010-05-28 18:46:57 +020056{
Willy Tarreaub363a1f2013-10-01 10:45:07 +020057 struct connection *conn = __objt_conn(s->si[0].end);
58 int cfd = conn->t.sock.fd;
Emeric Brunb982a3d2010-01-04 15:45:53 +010059
Willy Tarreaueb472682010-05-28 18:46:57 +020060 tv_zero(&s->logs.tv_request);
61 s->logs.t_queue = -1;
62 s->logs.t_connect = -1;
63 s->logs.t_data = -1;
64 s->logs.t_close = 0;
65 s->logs.bytes_in = s->logs.bytes_out = 0;
66 s->logs.prx_queue_size = 0; /* we get the number of pending conns before us */
67 s->logs.srv_queue_size = 0; /* we will get this number soon */
Willy Tarreaubaaee002006-06-26 02:48:02 +020068
Willy Tarreau35a09942010-06-01 17:12:40 +020069 /* FIXME: the logs are horribly complicated now, because they are
70 * defined in <p>, <p>, and later <be> and <be>.
Willy Tarreaueb472682010-05-28 18:46:57 +020071 */
William Lallemandbddd4fd2012-02-27 11:23:10 +010072 s->do_log = sess_log;
Willy Tarreau35a09942010-06-01 17:12:40 +020073
74 /* default error reporting function, may be changed by analysers */
75 s->srv_error = default_srv_error;
Willy Tarreaubaaee002006-06-26 02:48:02 +020076
Willy Tarreauf67c9782010-05-23 22:59:00 +020077 /* Adjust some socket options */
Willy Tarreau9c3bc222010-12-24 14:49:37 +010078 if (s->listener->addr.ss_family == AF_INET || s->listener->addr.ss_family == AF_INET6) {
79 if (setsockopt(cfd, IPPROTO_TCP, TCP_NODELAY,
80 (char *) &one, sizeof(one)) == -1)
81 goto out_return;
Willy Tarreauf67c9782010-05-23 22:59:00 +020082
Willy Tarreau9c3bc222010-12-24 14:49:37 +010083 if (s->fe->options & PR_O_TCP_CLI_KA)
84 setsockopt(cfd, SOL_SOCKET, SO_KEEPALIVE,
85 (char *) &one, sizeof(one));
Willy Tarreauf67c9782010-05-23 22:59:00 +020086
Willy Tarreau9c3bc222010-12-24 14:49:37 +010087 if (s->fe->options & PR_O_TCP_NOLING)
Willy Tarreauad38ace2013-12-15 14:19:38 +010088 fdtab[cfd].linger_risk = 1;
89
Willy Tarreau48a7e722010-12-24 15:26:39 +010090#if defined(TCP_MAXSEG)
91 if (s->listener->maxseg < 0) {
92 /* we just want to reduce the current MSS by that value */
93 int mss;
Willy Tarreau7d286a02011-01-05 15:42:54 +010094 socklen_t mss_len = sizeof(mss);
Willy Tarreau48a7e722010-12-24 15:26:39 +010095 if (getsockopt(cfd, IPPROTO_TCP, TCP_MAXSEG, &mss, &mss_len) == 0) {
96 mss += s->listener->maxseg; /* remember, it's < 0 */
97 setsockopt(cfd, IPPROTO_TCP, TCP_MAXSEG, &mss, sizeof(mss));
98 }
99 }
100#endif
Willy Tarreau9c3bc222010-12-24 14:49:37 +0100101 }
Willy Tarreauf67c9782010-05-23 22:59:00 +0200102
103 if (global.tune.client_sndbuf)
104 setsockopt(cfd, SOL_SOCKET, SO_SNDBUF, &global.tune.client_sndbuf, sizeof(global.tune.client_sndbuf));
105
106 if (global.tune.client_rcvbuf)
107 setsockopt(cfd, SOL_SOCKET, SO_RCVBUF, &global.tune.client_rcvbuf, sizeof(global.tune.client_rcvbuf));
108
Willy Tarreau9654e572014-11-18 18:49:19 +0100109 if (unlikely(s->fe->nb_req_cap > 0)) {
110 if ((s->txn.req.cap = pool_alloc2(s->fe->req_cap_pool)) == NULL)
111 goto out_return; /* no memory */
112 memset(s->txn.req.cap, 0, s->fe->nb_req_cap * sizeof(void *));
113 }
Willy Tarreaubaaee002006-06-26 02:48:02 +0200114
Willy Tarreau9654e572014-11-18 18:49:19 +0100115 if (unlikely(s->fe->nb_rsp_cap > 0)) {
116 if ((s->txn.rsp.cap = pool_alloc2(s->fe->rsp_cap_pool)) == NULL)
117 goto out_free_reqcap; /* no memory */
118 memset(s->txn.rsp.cap, 0, s->fe->nb_rsp_cap * sizeof(void *));
119 }
Willy Tarreaubaaee002006-06-26 02:48:02 +0200120
Willy Tarreau25320b22013-03-24 07:22:08 +0100121 if (s->fe->http_needed) {
Willy Tarreaueb472682010-05-28 18:46:57 +0200122 /* we have to allocate header indexes only if we know
123 * that we may make use of them. This of course includes
124 * (mode == PR_MODE_HTTP).
Willy Tarreau042cc792007-03-19 16:20:06 +0100125 */
Willy Tarreauac1932d2011-10-24 19:14:41 +0200126 s->txn.hdr_idx.size = global.tune.max_http_hdr;
Willy Tarreau45e73e32006-12-17 00:05:15 +0100127
Willy Tarreau34eb6712011-10-24 18:15:04 +0200128 if (unlikely((s->txn.hdr_idx.v = pool_alloc2(pool2_hdr_idx)) == NULL))
Willy Tarreau35a09942010-06-01 17:12:40 +0200129 goto out_free_rspcap; /* no memory */
Willy Tarreau45e73e32006-12-17 00:05:15 +0100130
Willy Tarreaueb472682010-05-28 18:46:57 +0200131 /* and now initialize the HTTP transaction state */
132 http_init_txn(s);
133 }
Willy Tarreaue5f20dc2006-12-03 15:21:35 +0100134
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200135 if ((s->fe->mode == PR_MODE_TCP || s->fe->mode == PR_MODE_HTTP)
William Lallemand0f99e342011-10-12 17:50:54 +0200136 && (!LIST_ISEMPTY(&s->fe->logsrvs))) {
Willy Tarreaud79a3b22012-12-28 09:40:16 +0100137 if (likely(!LIST_ISEMPTY(&s->fe->logformat))) {
Willy Tarreaueb472682010-05-28 18:46:57 +0200138 /* we have the client ip */
139 if (s->logs.logwait & LW_CLIP)
Willy Tarreaud79a3b22012-12-28 09:40:16 +0100140 if (!(s->logs.logwait &= ~(LW_CLIP|LW_INIT)))
Willy Tarreaueb472682010-05-28 18:46:57 +0200141 s->do_log(s);
Willy Tarreaua3445fc2010-05-20 16:17:07 +0200142 }
Willy Tarreau631f01c2011-09-05 00:36:48 +0200143 else {
Willy Tarreaueb472682010-05-28 18:46:57 +0200144 char pn[INET6_ADDRSTRLEN], sn[INET6_ADDRSTRLEN];
Willy Tarreau14c8aac2007-05-08 19:46:30 +0200145
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200146 conn_get_from_addr(conn);
147 conn_get_to_addr(conn);
Willy Tarreaubaaee002006-06-26 02:48:02 +0200148
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200149 switch (addr_to_str(&conn->addr.from, pn, sizeof(pn))) {
Willy Tarreau631f01c2011-09-05 00:36:48 +0200150 case AF_INET:
151 case AF_INET6:
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200152 addr_to_str(&conn->addr.to, sn, sizeof(sn));
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200153 send_log(s->fe, LOG_INFO, "Connect from %s:%d to %s:%d (%s/%s)\n",
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200154 pn, get_host_port(&conn->addr.from),
155 sn, get_host_port(&conn->addr.to),
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200156 s->fe->id, (s->fe->mode == PR_MODE_HTTP) ? "HTTP" : "TCP");
Willy Tarreau631f01c2011-09-05 00:36:48 +0200157 break;
158 case AF_UNIX:
159 /* UNIX socket, only the destination is known */
160 send_log(s->fe, LOG_INFO, "Connect to unix:%d (%s/%s)\n",
161 s->listener->luid,
162 s->fe->id, (s->fe->mode == PR_MODE_HTTP) ? "HTTP" : "TCP");
163 break;
Willy Tarreaubaaee002006-06-26 02:48:02 +0200164 }
Willy Tarreaueb472682010-05-28 18:46:57 +0200165 }
166 }
Willy Tarreaubaaee002006-06-26 02:48:02 +0200167
Willy Tarreau2281b7f2010-05-28 19:29:49 +0200168 if (unlikely((global.mode & MODE_DEBUG) && (!(global.mode & MODE_QUIET) || (global.mode & MODE_VERBOSE)))) {
Willy Tarreau631f01c2011-09-05 00:36:48 +0200169 char pn[INET6_ADDRSTRLEN];
Willy Tarreaubaaee002006-06-26 02:48:02 +0200170
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200171 conn_get_from_addr(conn);
Willy Tarreaubaaee002006-06-26 02:48:02 +0200172
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200173 switch (addr_to_str(&conn->addr.from, pn, sizeof(pn))) {
Willy Tarreau631f01c2011-09-05 00:36:48 +0200174 case AF_INET:
175 case AF_INET6:
Willy Tarreau19d14ef2012-10-29 16:51:55 +0100176 chunk_printf(&trash, "%08x:%s.accept(%04x)=%04x from [%s:%d]\n",
177 s->uniq_id, s->fe->id, (unsigned short)s->listener->fd, (unsigned short)cfd,
Willy Tarreaub363a1f2013-10-01 10:45:07 +0200178 pn, get_host_port(&conn->addr.from));
Willy Tarreau631f01c2011-09-05 00:36:48 +0200179 break;
180 case AF_UNIX:
181 /* UNIX socket, only the destination is known */
Willy Tarreau19d14ef2012-10-29 16:51:55 +0100182 chunk_printf(&trash, "%08x:%s.accept(%04x)=%04x from [unix:%d]\n",
183 s->uniq_id, s->fe->id, (unsigned short)s->listener->fd, (unsigned short)cfd,
184 s->listener->luid);
Willy Tarreau631f01c2011-09-05 00:36:48 +0200185 break;
Emeric Brunab844ea2010-10-22 16:33:18 +0200186 }
Willy Tarreau9a2d1542008-08-30 12:31:07 +0200187
Willy Tarreau89efaed2013-12-13 15:14:55 +0100188 shut_your_big_mouth_gcc(write(1, trash.str, trash.len));
Willy Tarreaueb472682010-05-28 18:46:57 +0200189 }
Willy Tarreaubaaee002006-06-26 02:48:02 +0200190
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200191 if (s->fe->mode == PR_MODE_HTTP)
Willy Tarreau22ec1ea2014-11-27 20:45:39 +0100192 s->req.flags |= CF_READ_DONTWAIT; /* one read is usually enough */
Willy Tarreaubaaee002006-06-26 02:48:02 +0200193
Willy Tarreaueb472682010-05-28 18:46:57 +0200194 /* note: this should not happen anymore since there's always at least the switching rules */
Willy Tarreau22ec1ea2014-11-27 20:45:39 +0100195 if (!s->req.analysers) {
196 channel_auto_connect(&s->req); /* don't wait to establish connection */
197 channel_auto_close(&s->req); /* let the producer forward close requests */
Willy Tarreaueb472682010-05-28 18:46:57 +0200198 }
Willy Tarreaud7971282006-07-29 18:36:34 +0200199
Willy Tarreau22ec1ea2014-11-27 20:45:39 +0100200 s->req.rto = s->fe->timeout.client;
201 s->res.wto = s->fe->timeout.client;
Willy Tarreaubaaee002006-06-26 02:48:02 +0200202
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200203 /* everything's OK, let's go on */
Willy Tarreaueb472682010-05-28 18:46:57 +0200204 return 1;
Willy Tarreau8ced9a42007-11-04 17:51:50 +0100205
206 /* Error unrolling */
Willy Tarreau35a09942010-06-01 17:12:40 +0200207 out_free_rspcap:
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200208 pool_free2(s->fe->rsp_cap_pool, s->txn.rsp.cap);
Willy Tarreau35a09942010-06-01 17:12:40 +0200209 out_free_reqcap:
Willy Tarreau81f9aa32010-06-01 17:45:26 +0200210 pool_free2(s->fe->req_cap_pool, s->txn.req.cap);
Willy Tarreauabe8ea52010-11-11 10:56:04 +0100211 out_return:
Willy Tarreaueb472682010-05-28 18:46:57 +0200212 return -1;
Willy Tarreaubaaee002006-06-26 02:48:02 +0200213}
214
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100215/************************************************************************/
216/* All supported sample and ACL keywords must be declared here. */
217/************************************************************************/
218
Willy Tarreaua5e37562011-12-16 17:06:15 +0100219/* set temp integer to the id of the frontend */
Willy Tarreaud41f8d82007-06-10 10:06:18 +0200220static int
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100221smp_fetch_fe_id(struct proxy *px, struct session *l4, void *l7, unsigned int opt,
Thierry FOURNIERf41a8092014-12-07 18:37:57 +0100222 const struct arg *args, struct sample *smp, const char *kw, void *private)
Willy Tarreau37406352012-04-23 16:16:37 +0200223{
Willy Tarreauf853c462012-04-23 18:53:56 +0200224 smp->flags = SMP_F_VOL_SESS;
225 smp->type = SMP_T_UINT;
226 smp->data.uint = l4->fe->uuid;
Emeric Brun5d16eda2010-01-04 15:47:45 +0100227 return 1;
228}
229
Willy Tarreau34db1082012-04-19 17:16:54 +0200230/* set temp integer to the number of connections per second reaching the frontend.
Willy Tarreau0146c2e2012-04-20 11:37:56 +0200231 * Accepts exactly 1 argument. Argument is a frontend, other types will cause
Willy Tarreau34db1082012-04-19 17:16:54 +0200232 * an undefined behaviour.
233 */
Willy Tarreaud41f8d82007-06-10 10:06:18 +0200234static int
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100235smp_fetch_fe_sess_rate(struct proxy *px, struct session *l4, void *l7, unsigned int opt,
Thierry FOURNIERf41a8092014-12-07 18:37:57 +0100236 const struct arg *args, struct sample *smp, const char *kw, void *private)
Willy Tarreau662b2d82007-05-08 19:56:15 +0200237{
Willy Tarreau37406352012-04-23 16:16:37 +0200238 smp->flags = SMP_F_VOL_TEST;
Willy Tarreauf853c462012-04-23 18:53:56 +0200239 smp->type = SMP_T_UINT;
Willy Tarreau24e32d82012-04-23 23:55:44 +0200240 smp->data.uint = read_freq_ctr(&args->data.prx->fe_sess_per_sec);
Emeric Brun5d16eda2010-01-04 15:47:45 +0100241 return 1;
242}
Alexandre Cassen5eb1a902007-11-29 15:43:32 +0100243
Willy Tarreau34db1082012-04-19 17:16:54 +0200244/* set temp integer to the number of concurrent connections on the frontend
Willy Tarreau0146c2e2012-04-20 11:37:56 +0200245 * Accepts exactly 1 argument. Argument is a frontend, other types will cause
Willy Tarreau34db1082012-04-19 17:16:54 +0200246 * an undefined behaviour.
247 */
Willy Tarreaud41f8d82007-06-10 10:06:18 +0200248static int
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100249smp_fetch_fe_conn(struct proxy *px, struct session *l4, void *l7, unsigned int opt,
Thierry FOURNIERf41a8092014-12-07 18:37:57 +0100250 const struct arg *args, struct sample *smp, const char *kw, void *private)
Willy Tarreau8797c062007-05-07 00:55:35 +0200251{
Willy Tarreau37406352012-04-23 16:16:37 +0200252 smp->flags = SMP_F_VOL_TEST;
Willy Tarreauf853c462012-04-23 18:53:56 +0200253 smp->type = SMP_T_UINT;
Willy Tarreau24e32d82012-04-23 23:55:44 +0200254 smp->data.uint = args->data.prx->feconn;
Krzysztof Piotr Oledzki346f76d2010-01-12 21:59:30 +0100255 return 1;
256}
257
Willy Tarreau8797c062007-05-07 00:55:35 +0200258
Willy Tarreau61612d42012-04-19 18:42:05 +0200259/* Note: must not be declared <const> as its list will be overwritten.
260 * Please take care of keeping this list alphabetically sorted.
261 */
Willy Tarreaudc13c112013-06-21 23:16:39 +0200262static struct sample_fetch_kw_list smp_kws = {ILH, {
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100263 { "fe_conn", smp_fetch_fe_conn, ARG1(1,FE), NULL, SMP_T_UINT, SMP_USE_INTRN, },
264 { "fe_id", smp_fetch_fe_id, 0, NULL, SMP_T_UINT, SMP_USE_FTEND, },
265 { "fe_sess_rate", smp_fetch_fe_sess_rate, ARG1(1,FE), NULL, SMP_T_UINT, SMP_USE_INTRN, },
266 { /* END */ },
267}};
268
269
270/* Note: must not be declared <const> as its list will be overwritten.
271 * Please take care of keeping this list alphabetically sorted.
272 */
Willy Tarreaudc13c112013-06-21 23:16:39 +0200273static struct acl_kw_list acl_kws = {ILH, {
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100274 { /* END */ },
Willy Tarreau8797c062007-05-07 00:55:35 +0200275}};
276
277
278__attribute__((constructor))
Willy Tarreau03fa5df2010-05-24 21:02:37 +0200279static void __frontend_init(void)
Willy Tarreau8797c062007-05-07 00:55:35 +0200280{
Willy Tarreaud6896bc2013-01-07 22:48:29 +0100281 sample_register_fetches(&smp_kws);
Willy Tarreau8797c062007-05-07 00:55:35 +0200282 acl_register_keywords(&acl_kws);
283}
284
285
Willy Tarreaubaaee002006-06-26 02:48:02 +0200286/*
287 * Local variables:
288 * c-indent-level: 8
289 * c-basic-offset: 8
290 * End:
291 */