Willy TARREAU | 3dc0644 | 2006-06-15 21:48:13 +0200 | [diff] [blame] | 1 | /* |
Willy Tarreau | ac68c5d | 2009-10-04 23:12:44 +0200 | [diff] [blame] | 2 | * 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 TARREAU | 3dc0644 | 2006-06-15 21:48:13 +0200 | [diff] [blame] | 21 | |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 22 | #ifndef _PROTO_SERVER_H |
| 23 | #define _PROTO_SERVER_H |
| 24 | |
| 25 | #include <unistd.h> |
| 26 | |
Willy Tarreau | e3ba5f0 | 2006-06-29 18:54:54 +0200 | [diff] [blame] | 27 | #include <common/config.h> |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 28 | #include <types/proxy.h> |
| 29 | #include <types/queue.h> |
| 30 | #include <types/server.h> |
Willy TARREAU | 3dc0644 | 2006-06-15 21:48:13 +0200 | [diff] [blame] | 31 | |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 32 | #include <proto/queue.h> |
Willy Tarreau | 7f062c4 | 2009-03-05 18:43:00 +0100 | [diff] [blame] | 33 | #include <proto/freq_ctr.h> |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 34 | |
Simon Horman | a360844 | 2013-11-01 16:46:15 +0900 | [diff] [blame] | 35 | int srv_downtime(const struct server *s); |
Simon Horman | 4a74143 | 2013-02-23 15:35:38 +0900 | [diff] [blame] | 36 | int srv_getinter(const struct check *check); |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 37 | |
Willy Tarreau | 7f062c4 | 2009-03-05 18:43:00 +0100 | [diff] [blame] | 38 | /* increase the number of cumulated connections on the designated server */ |
| 39 | static void inline srv_inc_sess_ctr(struct server *s) |
| 40 | { |
Krzysztof Piotr Oledzki | 052d4fd | 2009-10-04 14:52:57 +0200 | [diff] [blame] | 41 | s->counters.cum_sess++; |
Willy Tarreau | 7f062c4 | 2009-03-05 18:43:00 +0100 | [diff] [blame] | 42 | update_freq_ctr(&s->sess_per_sec, 1); |
Willy Tarreau | ac68c5d | 2009-10-04 23:12:44 +0200 | [diff] [blame] | 43 | if (s->sess_per_sec.curr_ctr > s->counters.sps_max) |
| 44 | s->counters.sps_max = s->sess_per_sec.curr_ctr; |
Willy Tarreau | 7f062c4 | 2009-03-05 18:43:00 +0100 | [diff] [blame] | 45 | } |
| 46 | |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 47 | #endif /* _PROTO_SERVER_H */ |
Willy TARREAU | 3dc0644 | 2006-06-15 21:48:13 +0200 | [diff] [blame] | 48 | |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 49 | /* |
Willy Tarreau | 21faa91 | 2012-10-10 08:27:36 +0200 | [diff] [blame] | 50 | * Registers the server keyword list <kwl> as a list of valid keywords for next |
| 51 | * parsing sessions. |
| 52 | */ |
| 53 | void srv_register_keywords(struct srv_kw_list *kwl); |
| 54 | |
| 55 | /* Return a pointer to the server keyword <kw>, or NULL if not found. */ |
| 56 | struct srv_kw *srv_find_kw(const char *kw); |
| 57 | |
| 58 | /* Dumps all registered "server" keywords to the <out> string pointer. */ |
| 59 | void srv_dump_kws(char **out); |
| 60 | |
Willy Tarreau | 004e045 | 2013-11-21 11:22:01 +0100 | [diff] [blame] | 61 | /* Recomputes the server's eweight based on its state, uweight, the current time, |
| 62 | * and the proxy's algorihtm. To be used after updating sv->uweight. The warmup |
| 63 | * state is automatically disabled if the time is elapsed. |
| 64 | */ |
| 65 | void server_recalc_eweight(struct server *sv); |
| 66 | |
Willy Tarreau | d32c399 | 2013-11-21 15:30:45 +0100 | [diff] [blame] | 67 | /* returns the current server throttle rate between 0 and 100% */ |
| 68 | static inline unsigned int server_throttle_rate(struct server *sv) |
| 69 | { |
| 70 | struct proxy *px = sv->proxy; |
| 71 | |
| 72 | /* when uweight is 0, we're in soft-stop so that cannot be a slowstart, |
| 73 | * thus the throttle is 100%. |
| 74 | */ |
| 75 | if (!sv->uweight) |
| 76 | return 100; |
| 77 | |
Willy Tarreau | e38feed | 2013-12-16 18:04:57 +0100 | [diff] [blame] | 78 | return (100U * px->lbprm.wmult * sv->eweight + px->lbprm.wdiv - 1) / (px->lbprm.wdiv * sv->uweight); |
Willy Tarreau | d32c399 | 2013-11-21 15:30:45 +0100 | [diff] [blame] | 79 | } |
| 80 | |
Willy Tarreau | 21faa91 | 2012-10-10 08:27:36 +0200 | [diff] [blame] | 81 | /* |
Simon Horman | 7d09b9a | 2013-02-12 10:45:51 +0900 | [diff] [blame] | 82 | * Parses weight_str and configures sv accordingly. |
| 83 | * Returns NULL on success, error message string otherwise. |
| 84 | */ |
| 85 | const char *server_parse_weight_change_request(struct server *sv, |
| 86 | const char *weight_str); |
| 87 | |
| 88 | /* |
Simon Horman | 8c3d0be | 2013-11-25 10:46:40 +0900 | [diff] [blame] | 89 | * Update the server's drain state to reflect its user-weight. This is not |
| 90 | * done immediately to allow a discrepancy between the server's user-weight |
| 91 | * and drains state to control logging of changes in the drain state. |
| 92 | */ |
| 93 | static inline void set_server_drain_state(struct server *s) |
| 94 | { |
| 95 | if (!s->uweight) |
| 96 | s->state |= SRV_DRAIN; |
| 97 | else |
| 98 | s->state &= ~SRV_DRAIN; |
| 99 | } |
| 100 | /* |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 101 | * Local variables: |
| 102 | * c-indent-level: 8 |
| 103 | * c-basic-offset: 8 |
| 104 | * End: |
| 105 | */ |