blob: 4a4b2857f1b088abe18e86294327d2bcf98939c3 [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 Tarreaubaaee002006-06-26 02:48:02 +020033int start_proxies(int verbose);
Willy Tarreau918ff602011-07-25 16:33:49 +020034struct task *manage_proxy(struct task *t);
Willy Tarreaubaaee002006-06-26 02:48:02 +020035void soft_stop(void);
Willy Tarreauce8fe252011-09-07 19:14:57 +020036int pause_proxy(struct proxy *p);
Willy Tarreau532a4502011-09-07 22:37:44 +020037int resume_proxy(struct proxy *p);
Willy Tarreauda250db2008-10-12 12:07:48 +020038void stop_proxy(struct proxy *p);
Willy Tarreaubaaee002006-06-26 02:48:02 +020039void pause_proxies(void);
Willy Tarreaube58c382011-07-24 18:28:10 +020040void resume_proxies(void);
Willy Tarreaubedb9ba2009-07-12 08:27:39 +020041int session_set_backend(struct session *s, struct proxy *be);
Willy Tarreaubaaee002006-06-26 02:48:02 +020042
Willy Tarreau816eb542007-11-04 07:04:43 +010043const char *proxy_cap_str(int cap);
Krzysztof Piotr Oledzki6eb730d2007-11-03 23:41:58 +010044const char *proxy_mode_str(int mode);
Alex Williams96532db2009-11-01 21:27:13 -050045struct proxy *findproxy_mode(const char *name, int mode, int cap);
46struct proxy *findproxy(const char *name, int cap);
Krzysztof Piotr Oledzkic8b16fc2008-02-18 01:26:35 +010047struct server *findserver(const struct proxy *px, const char *name);
Willy Tarreau915e1eb2009-06-22 15:48:36 +020048int proxy_cfg_ensure_no_http(struct proxy *curproxy);
Willy Tarreau237250c2011-07-29 01:49:03 +020049void init_new_proxy(struct proxy *p);
Willy Tarreauf3950172009-10-10 18:35:51 +020050int get_backend_server(const char *bk_name, const char *sv_name,
51 struct proxy **bk, struct server **sv);
Willy Tarreaubaaee002006-06-26 02:48:02 +020052
Willy Tarreau816eb542007-11-04 07:04:43 +010053/*
54 * This function returns a string containing the type of the proxy in a format
55 * suitable for error messages, from its capabilities.
56 */
57static inline const char *proxy_type_str(struct proxy *proxy)
58{
59 return proxy_cap_str(proxy->cap);
60}
61
Willy Tarreau3a70f942008-02-15 11:15:34 +010062/* this function initializes all timeouts for proxy p */
63static inline void proxy_reset_timeouts(struct proxy *proxy)
64{
Willy Tarreau0c303ee2008-07-07 00:09:58 +020065 proxy->timeout.client = TICK_ETERNITY;
66 proxy->timeout.tarpit = TICK_ETERNITY;
67 proxy->timeout.queue = TICK_ETERNITY;
68 proxy->timeout.connect = TICK_ETERNITY;
69 proxy->timeout.server = TICK_ETERNITY;
70 proxy->timeout.appsession = TICK_ETERNITY;
71 proxy->timeout.httpreq = TICK_ETERNITY;
72 proxy->timeout.check = TICK_ETERNITY;
Willy Tarreauce887fd2012-05-12 12:50:00 +020073 proxy->timeout.tunnel = TICK_ETERNITY;
Willy Tarreau3a70f942008-02-15 11:15:34 +010074}
75
Willy Tarreaub36b4242010-06-04 20:59:39 +020076/* increase the number of cumulated connections received on the designated frontend */
77static void inline proxy_inc_fe_conn_ctr(struct listener *l, struct proxy *fe)
Willy Tarreau7f062c42009-03-05 18:43:00 +010078{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010079 fe->fe_counters.cum_conn++;
Krzysztof Piotr Oledzkiaeebf9b2009-10-04 15:43:17 +020080 if (l->counters)
81 l->counters->cum_conn++;
82
Willy Tarreaub36b4242010-06-04 20:59:39 +020083 update_freq_ctr(&fe->fe_conn_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010084 if (fe->fe_conn_per_sec.curr_ctr > fe->fe_counters.cps_max)
85 fe->fe_counters.cps_max = fe->fe_conn_per_sec.curr_ctr;
Willy Tarreaub36b4242010-06-04 20:59:39 +020086}
87
88/* increase the number of cumulated connections accepted by the designated frontend */
89static void inline proxy_inc_fe_sess_ctr(struct listener *l, struct proxy *fe)
90{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010091 fe->fe_counters.cum_sess++;
Willy Tarreaub36b4242010-06-04 20:59:39 +020092 if (l->counters)
93 l->counters->cum_sess++;
Willy Tarreau7f062c42009-03-05 18:43:00 +010094 update_freq_ctr(&fe->fe_sess_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010095 if (fe->fe_sess_per_sec.curr_ctr > fe->fe_counters.sps_max)
96 fe->fe_counters.sps_max = fe->fe_sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +010097}
98
99/* increase the number of cumulated connections on the designated backend */
100static void inline proxy_inc_be_ctr(struct proxy *be)
101{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100102 be->be_counters.cum_conn++;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100103 update_freq_ctr(&be->be_sess_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100104 if (be->be_sess_per_sec.curr_ctr > be->be_counters.sps_max)
105 be->be_counters.sps_max = be->be_sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100106}
107
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100108/* increase the number of cumulated requests on the designated frontend */
109static void inline proxy_inc_fe_req_ctr(struct proxy *fe)
110{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100111 fe->fe_counters.p.http.cum_req++;
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100112 update_freq_ctr(&fe->fe_req_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100113 if (fe->fe_req_per_sec.curr_ctr > fe->fe_counters.p.http.rps_max)
114 fe->fe_counters.p.http.rps_max = fe->fe_req_per_sec.curr_ctr;
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100115}
116
Willy Tarreaubaaee002006-06-26 02:48:02 +0200117#endif /* _PROTO_PROXY_H */
Willy TARREAU3dc06442006-06-15 21:48:13 +0200118
Willy Tarreaubaaee002006-06-26 02:48:02 +0200119/*
120 * Local variables:
121 * c-indent-level: 8
122 * c-basic-offset: 8
123 * End:
124 */