/* * Server management functions. * * Copyright 2000-2012 Willy Tarreau * Copyright 2007-2008 Krzysztof Piotr Oledzki * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version * 2 of the License, or (at your option) any later version. * */ #include #include #include #include /* List head of all known server keywords */ static struct srv_kw_list srv_keywords = { .list = LIST_HEAD_INIT(srv_keywords.list) }; int srv_downtime(struct server *s) { if ((s->state & SRV_RUNNING) && s->last_change < now.tv_sec) // ignore negative time return s->down_time; return now.tv_sec - s->last_change + s->down_time; } int srv_getinter(struct server *s) { if ((s->state & SRV_CHECKED) && (s->health == s->rise + s->fall - 1)) return s->inter; if (!(s->state & SRV_RUNNING) && s->health==0) return (s->downinter)?(s->downinter):(s->inter); return (s->fastinter)?(s->fastinter):(s->inter); } /* * Registers the server keyword list as a list of valid keywords for next * parsing sessions. */ void srv_register_keywords(struct srv_kw_list *kwl) { LIST_ADDQ(&srv_keywords.list, &kwl->list); } /* Return a pointer to the server keyword , or NULL if not found. If the * keyword is found with a NULL ->parse() function, then an attempt is made to * find one with a valid ->parse() function. This way it is possible to declare * platform-dependant, known keywords as NULL, then only declare them as valid * if some options are met. Note that if the requested keyword contains an * opening parenthesis, everything from this point is ignored. */ struct srv_kw *srv_find_kw(const char *kw) { int index; const char *kwend; struct srv_kw_list *kwl; struct srv_kw *ret = NULL; kwend = strchr(kw, '('); if (!kwend) kwend = kw + strlen(kw); list_for_each_entry(kwl, &srv_keywords.list, list) { for (index = 0; kwl->kw[index].kw != NULL; index++) { if ((strncmp(kwl->kw[index].kw, kw, kwend - kw) == 0) && kwl->kw[index].kw[kwend-kw] == 0) { if (kwl->kw[index].parse) return &kwl->kw[index]; /* found it !*/ else ret = &kwl->kw[index]; /* may be OK */ } } } return ret; } /* Dumps all registered "server" keywords to the string pointer. The * unsupported keywords are only dumped if their supported form was not * found. */ void srv_dump_kws(char **out) { struct srv_kw_list *kwl; int index; *out = NULL; list_for_each_entry(kwl, &srv_keywords.list, list) { for (index = 0; kwl->kw[index].kw != NULL; index++) { if (kwl->kw[index].parse || srv_find_kw(kwl->kw[index].kw) == &kwl->kw[index]) { memprintf(out, "%s[%4s] %s%s%s%s\n", *out ? *out : "", kwl->scope, kwl->kw[index].kw, kwl->kw[index].skip ? " " : "", kwl->kw[index].default_ok ? " [dflt_ok]" : "", kwl->kw[index].parse ? "" : " (not supported)"); } } } } /* parse the "id" server keyword */ static int srv_parse_id(char **args, int *cur_arg, struct proxy *curproxy, struct server *newsrv, char **err) { struct eb32_node *node; if (!*args[*cur_arg + 1]) { memprintf(err, "'%s' : expects an integer argument", args[*cur_arg]); return ERR_ALERT | ERR_FATAL; } newsrv->puid = atol(args[*cur_arg + 1]); newsrv->conf.id.key = newsrv->puid; if (newsrv->puid <= 0) { memprintf(err, "'%s' : custom id has to be > 0", args[*cur_arg]); return ERR_ALERT | ERR_FATAL; } node = eb32_lookup(&curproxy->conf.used_server_id, newsrv->puid); if (node) { struct server *target = container_of(node, struct server, conf.id); memprintf(err, "'%s' : custom id %d already used at %s:%d ('server %s')", args[*cur_arg], newsrv->puid, target->conf.file, target->conf.line, target->id); return ERR_ALERT | ERR_FATAL; } eb32_insert(&curproxy->conf.used_server_id, &newsrv->conf.id); return 0; } /* Note: must not be declared as its list will be overwritten. * Please take care of keeping this list alphabetically sorted, doing so helps * all code contributors. * Optional keywords are also declared with a NULL ->parse() function so that * the config parser can report an appropriate error when a known keyword was * not enabled. */ static struct srv_kw_list srv_kws = { "ALL", { }, { { "id", srv_parse_id, 1, 0 }, /* set id# of server */ { NULL, NULL, 0 }, }}; __attribute__((constructor)) static void __listener_init(void) { srv_register_keywords(&srv_kws); } /* * Local variables: * c-indent-level: 8 * c-basic-offset: 8 * End: */