blob: 9893266c0c2974ea5954f94d247d91fbda3a8112 [file] [log] [blame]
Willy TARREAU3dc06442006-06-15 21:48:13 +02001/*
Willy Tarreauac68c5d2009-10-04 23:12:44 +02002 * include/proto/server.h
3 * This file defines everything related to servers.
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_SERVER_H
23#define _PROTO_SERVER_H
24
25#include <unistd.h>
26
Willy Tarreaue3ba5f02006-06-29 18:54:54 +020027#include <common/config.h>
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050028#include <common/time.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020029#include <types/proxy.h>
30#include <types/queue.h>
31#include <types/server.h>
Willy TARREAU3dc06442006-06-15 21:48:13 +020032
Willy Tarreaubaaee002006-06-26 02:48:02 +020033#include <proto/queue.h>
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050034#include <proto/log.h>
Willy Tarreau7f062c42009-03-05 18:43:00 +010035#include <proto/freq_ctr.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020036
Simon Hormana3608442013-11-01 16:46:15 +090037int srv_downtime(const struct server *s);
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050038int srv_lastsession(const struct server *s);
Simon Horman4a741432013-02-23 15:35:38 +090039int srv_getinter(const struct check *check);
Willy Tarreau272adea2014-03-31 10:39:59 +020040int parse_server(const char *file, int linenum, char **args, struct proxy *curproxy, struct proxy *defproxy);
Willy Tarreaubaaee002006-06-26 02:48:02 +020041
Willy Tarreau7f062c42009-03-05 18:43:00 +010042/* increase the number of cumulated connections on the designated server */
43static void inline srv_inc_sess_ctr(struct server *s)
44{
Krzysztof Piotr Oledzki052d4fd2009-10-04 14:52:57 +020045 s->counters.cum_sess++;
Willy Tarreau7f062c42009-03-05 18:43:00 +010046 update_freq_ctr(&s->sess_per_sec, 1);
Willy Tarreauac68c5d2009-10-04 23:12:44 +020047 if (s->sess_per_sec.curr_ctr > s->counters.sps_max)
48 s->counters.sps_max = s->sess_per_sec.curr_ctr;
Willy Tarreau7f062c42009-03-05 18:43:00 +010049}
50
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050051/* set the time of last session on the designated server */
52static void inline srv_set_sess_last(struct server *s)
53{
54 s->counters.last_sess = now.tv_sec;
55}
56
Willy Tarreaubaaee002006-06-26 02:48:02 +020057#endif /* _PROTO_SERVER_H */
Willy TARREAU3dc06442006-06-15 21:48:13 +020058
Willy Tarreaubaaee002006-06-26 02:48:02 +020059/*
Willy Tarreau21faa912012-10-10 08:27:36 +020060 * Registers the server keyword list <kwl> as a list of valid keywords for next
61 * parsing sessions.
62 */
63void srv_register_keywords(struct srv_kw_list *kwl);
64
65/* Return a pointer to the server keyword <kw>, or NULL if not found. */
66struct srv_kw *srv_find_kw(const char *kw);
67
68/* Dumps all registered "server" keywords to the <out> string pointer. */
69void srv_dump_kws(char **out);
70
Willy Tarreau004e0452013-11-21 11:22:01 +010071/* Recomputes the server's eweight based on its state, uweight, the current time,
72 * and the proxy's algorihtm. To be used after updating sv->uweight. The warmup
73 * state is automatically disabled if the time is elapsed.
74 */
75void server_recalc_eweight(struct server *sv);
76
Willy Tarreaud32c3992013-11-21 15:30:45 +010077/* returns the current server throttle rate between 0 and 100% */
78static inline unsigned int server_throttle_rate(struct server *sv)
79{
80 struct proxy *px = sv->proxy;
81
82 /* when uweight is 0, we're in soft-stop so that cannot be a slowstart,
83 * thus the throttle is 100%.
84 */
85 if (!sv->uweight)
86 return 100;
87
Willy Tarreaue38feed2013-12-16 18:04:57 +010088 return (100U * px->lbprm.wmult * sv->eweight + px->lbprm.wdiv - 1) / (px->lbprm.wdiv * sv->uweight);
Willy Tarreaud32c3992013-11-21 15:30:45 +010089}
90
Willy Tarreau21faa912012-10-10 08:27:36 +020091/*
Simon Horman7d09b9a2013-02-12 10:45:51 +090092 * Parses weight_str and configures sv accordingly.
93 * Returns NULL on success, error message string otherwise.
94 */
95const char *server_parse_weight_change_request(struct server *sv,
96 const char *weight_str);
97
98/*
Willy Tarreau02615f92014-05-13 22:08:20 +020099 * Return true if the server has a zero user-weight, meaning it's in draining
100 * mode (ie: not taking new non-persistent connections).
Simon Horman8c3d0be2013-11-25 10:46:40 +0900101 */
Willy Tarreau02615f92014-05-13 22:08:20 +0200102static inline int server_is_draining(const struct server *s)
Simon Horman8c3d0be2013-11-25 10:46:40 +0900103{
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200104 return !s->uweight || (s->admin & SRV_ADMF_DRAIN);
Simon Horman8c3d0be2013-11-25 10:46:40 +0900105}
Willy Tarreau4aac7db2014-05-16 11:48:10 +0200106
107/* Shutdown all connections of a server. The caller must pass a termination
108 * code in <why>, which must be one of SN_ERR_* indicating the reason for the
109 * shutdown.
110 */
111void srv_shutdown_sessions(struct server *srv, int why);
112
113/* Shutdown all connections of all backup servers of a proxy. The caller must
114 * pass a termination code in <why>, which must be one of SN_ERR_* indicating
115 * the reason for the shutdown.
116 */
117void srv_shutdown_backup_sessions(struct proxy *px, int why);
118
Willy Tarreaubda92272014-05-20 21:55:30 +0200119/* Appends some information to a message string related to a server going UP or
120 * DOWN. If both <forced> and <reason> are null and the server tracks another
121 * one, a "via" information will be provided to know where the status came from.
122 * If <reason> is non-null, the entire string will be appended after a comma and
123 * a space (eg: to report some information from the check that changed the state).
124 * If <xferred> is non-negative, some information about requeued sessions are
125 * provided.
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200126 */
Willy Tarreaubda92272014-05-20 21:55:30 +0200127void srv_append_status(struct chunk *msg, struct server *s, const char *reason, int xferred, int forced);
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200128
Willy Tarreaue7d1ef12014-05-20 22:25:12 +0200129/* Marks server <s> down, regardless of its checks' statuses, notifies by all
130 * available means, recounts the remaining servers on the proxy and transfers
131 * queued sessions whenever possible to other servers. It automatically
132 * recomputes the number of servers, but not the map. Maintenance servers are
133 * ignored. It reports <reason> if non-null as the reason for going down. Note
134 * that it makes use of the trash to build the log strings, so <reason> must
135 * not be placed there.
136 */
137void srv_set_stopped(struct server *s, const char *reason);
138
Willy Tarreaudbd5e782014-05-20 22:46:35 +0200139/* Marks server <s> up regardless of its checks' statuses and provided it isn't
140 * in maintenance. Notifies by all available means, recounts the remaining
141 * servers on the proxy and tries to grab requests from the proxy. It
142 * automatically recomputes the number of servers, but not the map. Maintenance
143 * servers are ignored. It reports <reason> if non-null as the reason for going
144 * up. Note that it makes use of the trash to build the log strings, so <reason>
145 * must not be placed there.
146 */
147void srv_set_running(struct server *s, const char *reason);
148
Willy Tarreau8eb77842014-05-21 13:54:57 +0200149/* Marks server <s> stopping regardless of its checks' statuses and provided it
150 * isn't in maintenance. Notifies by all available means, recounts the remaining
151 * servers on the proxy and tries to grab requests from the proxy. It
152 * automatically recomputes the number of servers, but not the map. Maintenance
153 * servers are ignored. It reports <reason> if non-null as the reason for going
154 * up. Note that it makes use of the trash to build the log strings, so <reason>
155 * must not be placed there.
156 */
157void srv_set_stopping(struct server *s, const char *reason);
158
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200159/* Enables admin flag <mode> (among SRV_ADMF_*) on server <s>. This is used to
160 * enforce either maint mode or drain mode. It is not allowed to set more than
161 * one flag at once. The equivalent "inherited" flag is propagated to all
162 * tracking servers. Maintenance mode disables health checks (but not agent
163 * checks). When either the flag is already set or no flag is passed, nothing
164 * is done.
165 */
166void srv_set_admin_flag(struct server *s, enum srv_admin mode);
167
168/* Disables admin flag <mode> (among SRV_ADMF_*) on server <s>. This is used to
169 * stop enforcing either maint mode or drain mode. It is not allowed to set more
170 * than one flag at once. The equivalent "inherited" flag is propagated to all
171 * tracking servers. Leaving maintenance mode re-enables health checks. When
172 * either the flag is already cleared or no flag is passed, nothing is done.
173 */
174void srv_clr_admin_flag(struct server *s, enum srv_admin mode);
175
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200176/* Puts server <s> into maintenance mode, and propagate that status down to all
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200177 * tracking servers.
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200178 */
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200179static inline void srv_adm_set_maint(struct server *s)
180{
181 srv_set_admin_flag(s, SRV_ADMF_FMAINT);
182 srv_clr_admin_flag(s, SRV_ADMF_FDRAIN);
183}
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200184
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200185/* Puts server <s> into drain mode, and propagate that status down to all
186 * tracking servers.
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200187 */
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200188static inline void srv_adm_set_drain(struct server *s)
189{
190 srv_set_admin_flag(s, SRV_ADMF_FDRAIN);
191 srv_clr_admin_flag(s, SRV_ADMF_FMAINT);
192}
193
194/* Puts server <s> into ready mode, and propagate that status down to all
195 * tracking servers.
196 */
197static inline void srv_adm_set_ready(struct server *s)
198{
199 srv_clr_admin_flag(s, SRV_ADMF_FDRAIN);
200 srv_clr_admin_flag(s, SRV_ADMF_FMAINT);
201}
Willy Tarreaua0066dd2014-05-16 11:25:16 +0200202
Simon Horman8c3d0be2013-11-25 10:46:40 +0900203/*
Willy Tarreaubaaee002006-06-26 02:48:02 +0200204 * Local variables:
205 * c-indent-level: 8
206 * c-basic-offset: 8
207 * End:
208 */