blob: fb7392616234ea26b17beae35a02065306ef9878 [file] [log] [blame]
Willy Tarreaubaaee002006-06-26 02:48:02 +02001/*
Willy Tarreauf8e8b762012-01-20 15:57:05 +01002 * include/proto/queue.h
3 * This file defines everything related to queues.
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_QUEUE_H
23#define _PROTO_QUEUE_H
24
Willy Tarreaue3ba5f02006-06-29 18:54:54 +020025#include <common/config.h>
Willy Tarreau2dd0d472006-06-29 17:53:05 +020026#include <common/memory.h>
27#include <common/mini-clist.h>
Willy Tarreaubaaee002006-06-26 02:48:02 +020028
29#include <types/proxy.h>
30#include <types/queue.h>
31#include <types/session.h>
32#include <types/server.h>
33#include <types/task.h>
34
Willy Tarreauf8e8b762012-01-20 15:57:05 +010035#include <proto/backend.h>
36
Willy Tarreaue4d7e552007-05-13 20:19:55 +020037extern struct pool_head *pool2_pendconn;
38
39int init_pendconn();
Willy Tarreaubaaee002006-06-26 02:48:02 +020040struct session *pendconn_get_next_sess(struct server *srv, struct proxy *px);
41struct pendconn *pendconn_add(struct session *sess);
42void pendconn_free(struct pendconn *p);
Willy Tarreau7c669d72008-06-20 15:04:11 +020043void process_srv_queue(struct server *s);
Willy Tarreaub17916e2006-10-15 15:17:57 +020044unsigned int srv_dynamic_maxconn(const struct server *s);
Willy Tarreaubaaee002006-06-26 02:48:02 +020045
46
47
48/* Returns the first pending connection for server <s>, which may be NULL if
49 * nothing is pending.
50 */
Willy Tarreaub17916e2006-10-15 15:17:57 +020051static inline struct pendconn *pendconn_from_srv(const struct server *s) {
Willy Tarreaubaaee002006-06-26 02:48:02 +020052 if (!s->nbpend)
53 return NULL;
54
55 return LIST_ELEM(s->pendconns.n, struct pendconn *, list);
56}
57
58/* Returns the first pending connection for proxy <px>, which may be NULL if
59 * nothing is pending.
60 */
Willy Tarreaub17916e2006-10-15 15:17:57 +020061static inline struct pendconn *pendconn_from_px(const struct proxy *px) {
Willy Tarreaubaaee002006-06-26 02:48:02 +020062 if (!px->nbpend)
63 return NULL;
64
65 return LIST_ELEM(px->pendconns.n, struct pendconn *, list);
66}
67
Willy Tarreauc35362a2014-04-25 13:58:37 +020068/* Returns 0 if all slots are full on a server, or 1 if there are slots available. */
69static inline int server_has_room(const struct server *s) {
70 return !s->maxconn || s->cur_sess < srv_dynamic_maxconn(s);
71}
72
Willy Tarreaubaaee002006-06-26 02:48:02 +020073/* returns 0 if nothing has to be done for server <s> regarding queued connections,
Willy Tarreau922a8062008-12-04 09:33:58 +010074 * and non-zero otherwise. If the server is down, we only check its own queue. Suited
75 * for and if/else usage.
Willy Tarreaubaaee002006-06-26 02:48:02 +020076 */
Willy Tarreaub17916e2006-10-15 15:17:57 +020077static inline int may_dequeue_tasks(const struct server *s, const struct proxy *p) {
Willy Tarreauf8e8b762012-01-20 15:57:05 +010078 return (s && (s->nbpend || (p->nbpend && srv_is_usable(s->state, s->eweight))) &&
Willy Tarreau7c669d72008-06-20 15:04:11 +020079 (!s->maxconn || s->cur_sess < srv_dynamic_maxconn(s)));
Willy Tarreaubaaee002006-06-26 02:48:02 +020080}
81
82#endif /* _PROTO_QUEUE_H */
83
84/*
85 * Local variables:
86 * c-indent-level: 8
87 * c-basic-offset: 8
88 * End:
89 */