blob: 97b11d64851416280069618479040ad6d83ea9e7 [file] [log] [blame]
Willy Tarreaubaaee002006-06-26 02:48:02 +02001/*
Willy Tarreau62c3be22012-01-20 13:12:32 +01002 * include/proto/backend.h
3 * Functions prototypes for the backend.
4 *
5 * Copyright (C) 2000-2012 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 Tarreaubaaee002006-06-26 02:48:02 +020021
22#ifndef _PROTO_BACKEND_H
23#define _PROTO_BACKEND_H
24
Willy Tarreaue3ba5f02006-06-29 18:54:54 +020025#include <common/config.h>
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050026#include <common/time.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020027
28#include <types/backend.h>
Willy Tarreauf89c1872009-10-01 11:19:37 +020029#include <types/proxy.h>
30#include <types/server.h>
Willy Tarreau87b09662015-04-03 00:22:06 +020031#include <types/stream.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020032
Willy Tarreau87b09662015-04-03 00:22:06 +020033int assign_server(struct stream *s);
Willy Tarreau1c8d32b2019-07-18 15:47:45 +020034int assign_server_address(struct stream *s);
Willy Tarreau87b09662015-04-03 00:22:06 +020035int assign_server_and_queue(struct stream *s);
36int connect_server(struct stream *s);
37int srv_redispatch_connect(struct stream *t);
Krzysztof Piotr Oledzki15514c22010-01-04 16:03:09 +010038const char *backend_lb_algo_str(int algo);
Willy Tarreaua93c74b2012-05-08 18:14:39 +020039int backend_parse_balance(const char **args, char **err, struct proxy *curproxy);
Willy Tarreau87b09662015-04-03 00:22:06 +020040int tcp_persist_rdp_cookie(struct stream *s, struct channel *req, int an_bit);
Willy Tarreaubaaee002006-06-26 02:48:02 +020041
Krzysztof Oledzki85130942007-10-22 16:21:10 +020042int be_downtime(struct proxy *px);
Willy Tarreauc5d9c802009-10-01 09:17:05 +020043void recount_servers(struct proxy *px);
44void update_backend_weight(struct proxy *px);
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050045int be_lastsession(const struct proxy *be);
46
Nenad Merdanovicb7e7c472017-03-12 21:56:55 +010047/* Returns number of usable servers in backend */
48static inline int be_usable_srv(struct proxy *be)
49{
50 if (be->state == PR_STSTOPPED)
51 return 0;
52 else if (be->srv_act)
53 return be->srv_act;
54 else if (be->lbprm.fbck)
55 return 1;
56 else
57 return be->srv_bck;
58}
59
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050060/* set the time of last session on the backend */
Willy Tarreau0e492e22019-04-15 21:25:03 +020061static inline void be_set_sess_last(struct proxy *be)
Bhaskar Maddalaa20cb852014-02-03 16:26:46 -050062{
63 be->be_counters.last_sess = now.tv_sec;
64}
Willy Tarreauc5d9c802009-10-01 09:17:05 +020065
Emeric Brun52a91d32017-08-31 14:41:55 +020066/* This function returns non-zero if the designated server will be
67 * usable for LB according to pending weight and state.
68 * Otherwise it returns 0.
Willy Tarreauc5d9c802009-10-01 09:17:05 +020069 */
Emeric Brun52a91d32017-08-31 14:41:55 +020070static inline int srv_willbe_usable(const struct server *srv)
Willy Tarreau87eb1d62014-05-13 18:51:40 +020071{
Emeric Brun52a91d32017-08-31 14:41:55 +020072 enum srv_state state = srv->next_state;
Willy Tarreau87eb1d62014-05-13 18:51:40 +020073
Emeric Brun52a91d32017-08-31 14:41:55 +020074 if (!srv->next_eweight)
Willy Tarreau87eb1d62014-05-13 18:51:40 +020075 return 0;
Emeric Brun52a91d32017-08-31 14:41:55 +020076 if (srv->next_admin & SRV_ADMF_MAINT)
Willy Tarreau20125212014-05-13 19:44:56 +020077 return 0;
Emeric Brun52a91d32017-08-31 14:41:55 +020078 if (srv->next_admin & SRV_ADMF_DRAIN)
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +020079 return 0;
Willy Tarreau892337c2014-05-13 23:41:20 +020080 switch (state) {
81 case SRV_ST_STARTING:
82 case SRV_ST_RUNNING:
83 return 1;
84 case SRV_ST_STOPPING:
85 case SRV_ST_STOPPED:
Willy Tarreau87eb1d62014-05-13 18:51:40 +020086 return 0;
Willy Tarreau892337c2014-05-13 23:41:20 +020087 }
88 return 0;
Willy Tarreau87eb1d62014-05-13 18:51:40 +020089}
90
91/* This function returns non-zero if the designated server was usable for LB
Emeric Brun52a91d32017-08-31 14:41:55 +020092 * according to its current weight and state. Otherwise it returns 0.
Willy Tarreau87eb1d62014-05-13 18:51:40 +020093 */
Emeric Brun52a91d32017-08-31 14:41:55 +020094static inline int srv_currently_usable(const struct server *srv)
Willy Tarreauc5d9c802009-10-01 09:17:05 +020095{
Emeric Brun52a91d32017-08-31 14:41:55 +020096 enum srv_state state = srv->cur_state;
Willy Tarreau87eb1d62014-05-13 18:51:40 +020097
Emeric Brun52a91d32017-08-31 14:41:55 +020098 if (!srv->cur_eweight)
Willy Tarreauc5d9c802009-10-01 09:17:05 +020099 return 0;
Emeric Brun52a91d32017-08-31 14:41:55 +0200100 if (srv->cur_admin & SRV_ADMF_MAINT)
Willy Tarreau20125212014-05-13 19:44:56 +0200101 return 0;
Emeric Brun52a91d32017-08-31 14:41:55 +0200102 if (srv->cur_admin & SRV_ADMF_DRAIN)
Willy Tarreaubfc7b7a2014-05-22 16:14:34 +0200103 return 0;
Willy Tarreau892337c2014-05-13 23:41:20 +0200104 switch (state) {
105 case SRV_ST_STARTING:
106 case SRV_ST_RUNNING:
107 return 1;
108 case SRV_ST_STOPPING:
109 case SRV_ST_STOPPED:
Willy Tarreauc5d9c802009-10-01 09:17:05 +0200110 return 0;
Willy Tarreau892337c2014-05-13 23:41:20 +0200111 }
112 return 0;
Willy Tarreauc5d9c802009-10-01 09:17:05 +0200113}
Willy Tarreaubaaee002006-06-26 02:48:02 +0200114
Emeric Brun52a91d32017-08-31 14:41:55 +0200115/* This function commits the next server state and weight onto the current
Willy Tarreau9df86f92019-04-16 11:21:14 +0200116 * ones in order to detect future changes. The server's lock is expected to
117 * be held when calling this function.
Willy Tarreauc5150da2014-05-13 19:27:31 +0200118 */
119static inline void srv_lb_commit_status(struct server *srv)
120{
Emeric Brun52a91d32017-08-31 14:41:55 +0200121 srv->cur_state = srv->next_state;
122 srv->cur_admin = srv->next_admin;
123 srv->cur_eweight = srv->next_eweight;
Willy Tarreauc5150da2014-05-13 19:27:31 +0200124}
125
126/* This function returns true when a server has experienced a change since last
127 * commit on its state or weight, otherwise zero.
128 */
129static inline int srv_lb_status_changed(const struct server *srv)
130{
Emeric Brun52a91d32017-08-31 14:41:55 +0200131 return (srv->next_state != srv->cur_state ||
132 srv->next_admin != srv->cur_admin ||
133 srv->next_eweight != srv->cur_eweight);
Willy Tarreauc5150da2014-05-13 19:27:31 +0200134}
135
Willy Tarreau4aac7db2014-05-16 11:48:10 +0200136/* sends a log message when a backend goes down, and also sets last
137 * change date.
138 */
139void set_backend_down(struct proxy *be);
140
Willy Tarreaubaaee002006-06-26 02:48:02 +0200141#endif /* _PROTO_BACKEND_H */
142
143/*
144 * Local variables:
145 * c-indent-level: 8
146 * c-basic-offset: 8
147 * End:
148 */