blob: ed29f145941218352cb48bc8f259b9611d0cef94 [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 *
5 * Copyright (C) 2000-2009 Willy Tarreau - w@1wt.eu
6 *
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 Tarreaubaaee002006-06-26 02:48:02 +020028#include <types/proxy.h>
Willy Tarreau7f062c42009-03-05 18:43:00 +010029#include <proto/freq_ctr.h>
Willy TARREAU3dc06442006-06-15 21:48:13 +020030
Willy Tarreaubaaee002006-06-26 02:48:02 +020031int start_proxies(int verbose);
Willy Tarreau0c303ee2008-07-07 00:09:58 +020032void maintain_proxies(int *next);
Willy Tarreaubaaee002006-06-26 02:48:02 +020033void soft_stop(void);
34void pause_proxy(struct proxy *p);
Willy Tarreauda250db2008-10-12 12:07:48 +020035void stop_proxy(struct proxy *p);
Willy Tarreaubaaee002006-06-26 02:48:02 +020036void pause_proxies(void);
37void listen_proxies(void);
Willy Tarreaubedb9ba2009-07-12 08:27:39 +020038int session_set_backend(struct session *s, struct proxy *be);
Willy Tarreaubaaee002006-06-26 02:48:02 +020039
Willy Tarreau816eb542007-11-04 07:04:43 +010040const char *proxy_cap_str(int cap);
Krzysztof Piotr Oledzki6eb730d2007-11-03 23:41:58 +010041const char *proxy_mode_str(int mode);
Alex Williams96532db2009-11-01 21:27:13 -050042struct proxy *findproxy_mode(const char *name, int mode, int cap);
43struct proxy *findproxy(const char *name, int cap);
Krzysztof Piotr Oledzkic8b16fc2008-02-18 01:26:35 +010044struct server *findserver(const struct proxy *px, const char *name);
Willy Tarreau915e1eb2009-06-22 15:48:36 +020045int proxy_cfg_ensure_no_http(struct proxy *curproxy);
Willy Tarreauf3950172009-10-10 18:35:51 +020046int get_backend_server(const char *bk_name, const char *sv_name,
47 struct proxy **bk, struct server **sv);
Willy Tarreaubaaee002006-06-26 02:48:02 +020048
Willy Tarreau816eb542007-11-04 07:04:43 +010049/*
50 * This function returns a string containing the type of the proxy in a format
51 * suitable for error messages, from its capabilities.
52 */
53static inline const char *proxy_type_str(struct proxy *proxy)
54{
55 return proxy_cap_str(proxy->cap);
56}
57
Willy Tarreau3a70f942008-02-15 11:15:34 +010058/* this function initializes all timeouts for proxy p */
59static inline void proxy_reset_timeouts(struct proxy *proxy)
60{
Willy Tarreau0c303ee2008-07-07 00:09:58 +020061 proxy->timeout.client = TICK_ETERNITY;
62 proxy->timeout.tarpit = TICK_ETERNITY;
63 proxy->timeout.queue = TICK_ETERNITY;
64 proxy->timeout.connect = TICK_ETERNITY;
65 proxy->timeout.server = TICK_ETERNITY;
66 proxy->timeout.appsession = TICK_ETERNITY;
67 proxy->timeout.httpreq = TICK_ETERNITY;
68 proxy->timeout.check = TICK_ETERNITY;
Willy Tarreau3a70f942008-02-15 11:15:34 +010069}
70
Willy Tarreaub36b4242010-06-04 20:59:39 +020071/* increase the number of cumulated connections received on the designated frontend */
72static void inline proxy_inc_fe_conn_ctr(struct listener *l, struct proxy *fe)
Willy Tarreau7f062c42009-03-05 18:43:00 +010073{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010074 fe->fe_counters.cum_conn++;
Krzysztof Piotr Oledzkiaeebf9b2009-10-04 15:43:17 +020075 if (l->counters)
76 l->counters->cum_conn++;
77
Willy Tarreaub36b4242010-06-04 20:59:39 +020078 update_freq_ctr(&fe->fe_conn_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010079 if (fe->fe_conn_per_sec.curr_ctr > fe->fe_counters.cps_max)
80 fe->fe_counters.cps_max = fe->fe_conn_per_sec.curr_ctr;
Willy Tarreaub36b4242010-06-04 20:59:39 +020081}
82
83/* increase the number of cumulated connections accepted by the designated frontend */
84static void inline proxy_inc_fe_sess_ctr(struct listener *l, struct proxy *fe)
85{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010086 fe->fe_counters.cum_sess++;
Willy Tarreaub36b4242010-06-04 20:59:39 +020087 if (l->counters)
88 l->counters->cum_sess++;
Willy Tarreau7f062c42009-03-05 18:43:00 +010089 update_freq_ctr(&fe->fe_sess_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010090 if (fe->fe_sess_per_sec.curr_ctr > fe->fe_counters.sps_max)
91 fe->fe_counters.sps_max = fe->fe_sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +010092}
93
94/* increase the number of cumulated connections on the designated backend */
95static void inline proxy_inc_be_ctr(struct proxy *be)
96{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010097 be->be_counters.cum_conn++;
Willy Tarreau7f062c42009-03-05 18:43:00 +010098 update_freq_ctr(&be->be_sess_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +010099 if (be->be_sess_per_sec.curr_ctr > be->be_counters.sps_max)
100 be->be_counters.sps_max = be->be_sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +0100101}
102
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100103/* increase the number of cumulated requests on the designated frontend */
104static void inline proxy_inc_fe_req_ctr(struct proxy *fe)
105{
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100106 fe->fe_counters.p.http.cum_req++;
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100107 update_freq_ctr(&fe->fe_req_per_sec, 1);
Willy Tarreau7d0aaf32011-03-10 23:25:56 +0100108 if (fe->fe_req_per_sec.curr_ctr > fe->fe_counters.p.http.rps_max)
109 fe->fe_counters.p.http.rps_max = fe->fe_req_per_sec.curr_ctr;
Willy Tarreaud9b587f2010-02-26 10:05:55 +0100110}
111
Willy Tarreaubaaee002006-06-26 02:48:02 +0200112#endif /* _PROTO_PROXY_H */
Willy TARREAU3dc06442006-06-15 21:48:13 +0200113
Willy Tarreaubaaee002006-06-26 02:48:02 +0200114/*
115 * Local variables:
116 * c-indent-level: 8
117 * c-basic-offset: 8
118 * End:
119 */