blob: 139791f8c952cdd83a8c7e957d88096db21c3646 [file] [log] [blame]
Willy TARREAU3dc06442006-06-15 21:48:13 +02001/*
Willy Tarreauac68c5d2009-10-04 23:12:44 +02002 * include/proto/proxy.h
3 * This file defines function prototypes for proxy management.
4 *
Willy Tarreau918ff602011-07-25 16:33:49 +02005 * Copyright (C) 2000-2011 Willy Tarreau - w@1wt.eu
Willy Tarreauac68c5d2009-10-04 23:12:44 +02006 *
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation, version 2.1
10 * exclusively.
11 *
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20 */
Willy TARREAU3dc06442006-06-15 21:48:13 +020021
Willy Tarreaubaaee002006-06-26 02:48:02 +020022#ifndef _PROTO_PROXY_H
23#define _PROTO_PROXY_H
24
Willy Tarreaue3ba5f02006-06-29 18:54:54 +020025#include <common/config.h>
Willy Tarreau0c303ee2008-07-07 00:09:58 +020026#include <common/ticks.h>
Willy Tarreaud825eef2007-05-12 22:35:00 +020027#include <common/time.h>
Willy Tarreau81c25d02011-09-07 15:17:21 +020028#include <types/global.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020029#include <types/proxy.h>
Willy Tarreaud1d54542012-09-12 22:58:11 +020030#include <types/listener.h>
Willy Tarreau7f062c42009-03-05 18:43:00 +010031#include <proto/freq_ctr.h>
Willy TARREAU3dc06442006-06-15 21:48:13 +020032
Willy Tarreauf79d9502014-03-15 07:22:35 +010033extern struct proxy *proxy;
34extern struct eb_root used_proxy_id; /* list of proxy IDs in use */
35extern unsigned int error_snapshot_id; /* global ID assigned to each error then incremented */
36extern struct eb_root proxy_by_name; /* tree of proxies sorted by name */
37
Willy Tarreaubaaee002006-06-26 02:48:02 +020038int start_proxies(int verbose);
Willy Tarreau918ff602011-07-25 16:33:49 +020039struct task *manage_proxy(struct task *t);
Willy Tarreaubaaee002006-06-26 02:48:02 +020040void soft_stop(void);
Willy Tarreauce8fe252011-09-07 19:14:57 +020041int pause_proxy(struct proxy *p);
Willy Tarreau532a4502011-09-07 22:37:44 +020042int resume_proxy(struct proxy *p);
Willy Tarreauda250db2008-10-12 12:07:48 +020043void stop_proxy(struct proxy *p);
Willy Tarreaubaaee002006-06-26 02:48:02 +020044void pause_proxies(void);
Willy Tarreaube58c382011-07-24 18:28:10 +020045void resume_proxies(void);
Willy Tarreau87b09662015-04-03 00:22:06 +020046int stream_set_backend(struct stream *s, struct proxy *be);
Willy Tarreaubaaee002006-06-26 02:48:02 +020047
Willy Tarreau816eb542007-11-04 07:04:43 +010048const char *proxy_cap_str(int cap);
Krzysztof Piotr Oledzki6eb730d2007-11-03 23:41:58 +010049const char *proxy_mode_str(int mode);
Willy Tarreauf79d9502014-03-15 07:22:35 +010050void proxy_store_name(struct proxy *px);
Alex Williams96532db2009-11-01 21:27:13 -050051struct proxy *findproxy_mode(const char *name, int mode, int cap);
52struct proxy *findproxy(const char *name, int cap);
Krzysztof Piotr Oledzkic8b16fc2008-02-18 01:26:35 +010053struct server *findserver(const struct proxy *px, const char *name);
Willy Tarreau915e1eb2009-06-22 15:48:36 +020054int proxy_cfg_ensure_no_http(struct proxy *curproxy);
Willy Tarreau237250c2011-07-29 01:49:03 +020055void init_new_proxy(struct proxy *p);
Willy Tarreauf3950172009-10-10 18:35:51 +020056int get_backend_server(const char *bk_name, const char *sv_name,
57 struct proxy **bk, struct server **sv);
Willy Tarreaubaaee002006-06-26 02:48:02 +020058
Willy Tarreau816eb542007-11-04 07:04:43 +010059/*
60 * This function returns a string containing the type of the proxy in a format
61 * suitable for error messages, from its capabilities.
62 */
63static inline const char *proxy_type_str(struct proxy *proxy)
64{
65 return proxy_cap_str(proxy->cap);
66}
67
Willy Tarreau3a70f942008-02-15 11:15:34 +010068/* this function initializes all timeouts for proxy p */
69static inline void proxy_reset_timeouts(struct proxy *proxy)
70{
Willy Tarreau0c303ee2008-07-07 00:09:58 +020071 proxy->timeout.client = TICK_ETERNITY;
72 proxy->timeout.tarpit = TICK_ETERNITY;
73 proxy->timeout.queue = TICK_ETERNITY;
74 proxy->timeout.connect = TICK_ETERNITY;
75 proxy->timeout.server = TICK_ETERNITY;
76 proxy->timeout.appsession = TICK_ETERNITY;
77 proxy->timeout.httpreq = TICK_ETERNITY;
78 proxy->timeout.check = TICK_ETERNITY;
Willy Tarreauce887fd2012-05-12 12:50:00 +020079 proxy->timeout.tunnel = TICK_ETERNITY;
Willy Tarreau3a70f942008-02-15 11:15:34 +010080}
81
Willy Tarreaub36b4242010-06-04 20:59:39 +020082/* increase the number of cumulated connections received on the designated frontend */
83static void inline proxy_inc_fe_conn_ctr(struct listener *l, struct proxy *fe)
Willy Tarreau7f062c42009-03-05 18:43:00 +010084{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010085 fe->fe_counters.cum_conn++;
Krzysztof Piotr Oledzkiaeebf9b2009-10-04 15:43:17 +020086 if (l->counters)
87 l->counters->cum_conn++;
88
Willy Tarreaub36b4242010-06-04 20:59:39 +020089 update_freq_ctr(&fe->fe_conn_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010090 if (fe->fe_conn_per_sec.curr_ctr > fe->fe_counters.cps_max)
91 fe->fe_counters.cps_max = fe->fe_conn_per_sec.curr_ctr;
Willy Tarreaub36b4242010-06-04 20:59:39 +020092}
93
94/* increase the number of cumulated connections accepted by the designated frontend */
95static void inline proxy_inc_fe_sess_ctr(struct listener *l, struct proxy *fe)
96{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010097 fe->fe_counters.cum_sess++;
Willy Tarreaub36b4242010-06-04 20:59:39 +020098 if (l->counters)
99 l->counters->cum_sess++;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100100 update_freq_ctr(&fe->fe_sess_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100101 if (fe->fe_sess_per_sec.curr_ctr > fe->fe_counters.sps_max)
102 fe->fe_counters.sps_max = fe->fe_sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100103}
104
105/* increase the number of cumulated connections on the designated backend */
106static void inline proxy_inc_be_ctr(struct proxy *be)
107{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100108 be->be_counters.cum_conn++;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100109 update_freq_ctr(&be->be_sess_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100110 if (be->be_sess_per_sec.curr_ctr > be->be_counters.sps_max)
111 be->be_counters.sps_max = be->be_sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100112}
113
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100114/* increase the number of cumulated requests on the designated frontend */
115static void inline proxy_inc_fe_req_ctr(struct proxy *fe)
116{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100117 fe->fe_counters.p.http.cum_req++;
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100118 update_freq_ctr(&fe->fe_req_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100119 if (fe->fe_req_per_sec.curr_ctr > fe->fe_counters.p.http.rps_max)
120 fe->fe_counters.p.http.rps_max = fe->fe_req_per_sec.curr_ctr;
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100121}
122
Willy Tarreaubaaee002006-06-26 02:48:02 +0200123#endif /* _PROTO_PROXY_H */
Willy TARREAU3dc06442006-06-15 21:48:13 +0200124
Willy Tarreaubaaee002006-06-26 02:48:02 +0200125/*
126 * Local variables:
127 * c-indent-level: 8
128 * c-basic-offset: 8
129 * End:
130 */