/* * include/types/server.h * This file defines everything related to servers. * * Copyright (C) 2000-2012 Willy Tarreau - w@1wt.eu * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation, version 2.1 * exclusively. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ #ifndef _TYPES_SERVER_H #define _TYPES_SERVER_H #include #include #include #include #include #include #include #include #include #include #include #include #include /* server flags */ #define SRV_RUNNING 0x0001 /* the server is UP */ #define SRV_BACKUP 0x0002 /* this server is a backup server */ #define SRV_MAPPORTS 0x0004 /* this server uses mapped ports */ #define SRV_BIND_SRC 0x0008 /* this server uses a specific source address */ #define SRV_CHECKED 0x0010 /* this server needs to be checked */ #define SRV_GOINGDOWN 0x0020 /* this server says that it's going down (404) */ #define SRV_WARMINGUP 0x0040 /* this server is warming up after a failure */ #define SRV_MAINTAIN 0x0080 /* this server is in maintenance mode */ #define SRV_TPROXY_ADDR 0x0100 /* bind to this non-local address to reach this server */ #define SRV_TPROXY_CIP 0x0200 /* bind to the client's IP address to reach this server */ #define SRV_TPROXY_CLI 0x0300 /* bind to the client's IP+port to reach this server */ #define SRV_TPROXY_DYN 0x0400 /* bind to a dynamically computed non-local address */ #define SRV_TPROXY_MASK 0x0700 /* bind to a non-local address to reach this server */ #define SRV_SEND_PROXY 0x0800 /* this server talks the PROXY protocol */ #define SRV_NON_STICK 0x1000 /* never add connections allocated to this server to a stick table */ /* function which act on servers need to return various errors */ #define SRV_STATUS_OK 0 /* everything is OK. */ #define SRV_STATUS_INTERNAL 1 /* other unrecoverable errors. */ #define SRV_STATUS_NOSRV 2 /* no server is available */ #define SRV_STATUS_FULL 3 /* the/all server(s) are saturated */ #define SRV_STATUS_QUEUED 4 /* the/all server(s) are saturated but the connection was queued */ /* bits for s->result used for health-checks */ #define SRV_CHK_UNKNOWN 0x0000 /* initialized to this by default */ #define SRV_CHK_ERROR 0x0001 /* error encountered during the check; has precedence */ #define SRV_CHK_RUNNING 0x0002 /* server seen as running */ #define SRV_CHK_DISABLE 0x0004 /* server returned a "disable" code */ /* various constants */ #define SRV_UWGHT_RANGE 256 #define SRV_UWGHT_MAX (SRV_UWGHT_RANGE - 1) #define SRV_EWGHT_RANGE (SRV_UWGHT_RANGE * BE_WEIGHT_SCALE) #define SRV_EWGHT_MAX (SRV_UWGHT_MAX * BE_WEIGHT_SCALE) /* A tree occurrence is a descriptor of a place in a tree, with a pointer back * to the server itself. */ struct server; struct tree_occ { struct server *server; struct eb32_node node; }; struct server { struct server *next; int state; /* server state (SRV_*) */ int prev_state; /* server state before last change (SRV_*) */ int cklen; /* the len of the cookie, to speed up checks */ int rdr_len; /* the length of the redirection prefix */ char *cookie; /* the id set in the cookie */ char *rdr_pfx; /* the redirection prefix */ struct proxy *proxy; /* the proxy this server belongs to */ int served; /* # of active sessions currently being served (ie not pending) */ int cur_sess; /* number of currently active sessions (including syn_sent) */ unsigned maxconn, minconn; /* max # of active sessions (0 = unlimited), min# for dynamic limit. */ int nbpend; /* number of pending connections */ int maxqueue; /* maximum number of pending connections allowed */ struct freq_ctr sess_per_sec; /* sessions per second on this server */ struct srvcounters counters; /* statistics counters */ struct list pendconns; /* pending connections */ struct list actconns; /* active connections */ struct task *check; /* the task associated to the health check processing */ struct task *warmup; /* the task dedicated to the warmup when slowstart is set */ int iface_len; /* bind interface name length */ char *iface_name; /* bind interface name or NULL */ struct port_range *sport_range; /* optional per-server TCP source ports */ struct server *tracknext, *track; /* next server in a tracking list, tracked server */ char *trackit; /* temporary variable to make assignment deferrable */ struct sockaddr_storage check_addr; /* the address to check, if different from */ short check_port; /* the port to use for the health checks */ int health; /* 0->rise-1 = bad; rise->rise+fall-1 = good */ int consecutive_errors; /* current number of consecutive errors */ int rise, fall; /* time in iterations */ int consecutive_errors_limit; /* number of consecutive errors that triggers an event */ short observe, onerror; /* observing mode: one of HANA_OBS_*; what to do on error: on of ANA_ONERR_* */ short onmarkeddown; /* what to do when marked down: on of HANA_ONMARKEDDOWN_* */ int inter, fastinter, downinter; /* checks: time in milliseconds */ int slowstart; /* slowstart time in seconds (ms in the conf) */ int result; /* health-check result : SRV_CHK_* */ int curfd; /* file desc used for current test, or -1 if not in test */ char *id; /* just for identification */ unsigned iweight,uweight, eweight; /* initial weight, user-specified weight, and effective weight */ unsigned wscore; /* weight score, used during srv map computation */ unsigned prev_eweight; /* eweight before last change */ unsigned rweight; /* remainer of weight in the current LB tree */ unsigned npos, lpos; /* next and last positions in the LB tree */ struct eb32_node lb_node; /* node used for tree-based load balancing */ struct eb_root *lb_tree; /* we want to know in what tree the server is */ struct server *next_full; /* next server in the temporary full list */ unsigned lb_nodes_tot; /* number of allocated lb_nodes (C-HASH) */ unsigned lb_nodes_now; /* number of lb_nodes placed in the tree (C-HASH) */ struct tree_occ *lb_nodes; /* lb_nodes_tot * struct tree_occ */ /* warning, these structs are huge, keep them at the bottom */ struct sockaddr_storage addr; /* the address to connect to */ struct sockaddr_storage source_addr; /* the address to which we want to bind for connect() */ #if defined(CONFIG_HAP_CTTPROXY) || defined(CONFIG_HAP_LINUX_TPROXY) struct sockaddr_storage tproxy_addr; /* non-local address we want to bind to for connect() */ char *bind_hdr_name; /* bind to this header name if defined */ int bind_hdr_len; /* length of the name of the header above */ int bind_hdr_occ; /* occurrence number of header above: >0 = from first, <0 = from end, 0=disabled */ #endif struct protocol *proto; /* server address protocol */ struct sock_ops *sock; /* server socket operations */ void *sock_init_arg; /* socket operations's opaque init argument if needed */ unsigned down_time; /* total time the server was down */ time_t last_change; /* last time, when the state was changed */ struct timeval check_start; /* last health check start time */ long check_duration; /* time in ms took to finish last health check */ short check_status, check_code; /* check result, check code */ char check_desc[HCHK_DESC_LEN]; /* health check descritpion */ int puid; /* proxy-unique server ID, used for SNMP, and "first" LB algo */ char *check_data; /* storage of partial check results */ int check_data_len; /* length of partial check results stored in check_data */ struct { const char *file; /* file where the section appears */ int line; /* line where the section appears */ struct eb32_node id; /* place in the tree of used IDs */ } conf; /* config information */ }; #endif /* _TYPES_SERVER_H */ /* * Local variables: * c-indent-level: 8 * c-basic-offset: 8 * End: */