mirror of
https://github.com/haproxy/haproxy.git
synced 2026-02-20 00:10:41 -05:00
5ddf1ce9c4
These methods will be used to enable/disable accepting new connections
so that listeners do not play with FD directly anymore. Since all the
currently supported protocols work on socket for now, these are identical
to the rx_enable/rx_disable functions. However they were not defined in
sock.c since it's likely that some will quickly start to differ. At the
moment they're not used.
We have to take care of fd_updt before calling fd_{want,stop}_recv()
because it's allocated fairly late in the boot process and some such
functions may be called very early (e.g. to stop a disabled frontend's
listeners).
118 lines
5.2 KiB
C
118 lines
5.2 KiB
C
/*
|
|
* include/haproxy/protocol-t.h
|
|
* This file defines the structures used by generic network protocols.
|
|
*
|
|
* Copyright (C) 2000-2020 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 _HAPROXY_PROTOCOL_T_H
|
|
#define _HAPROXY_PROTOCOL_T_H
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/socket.h>
|
|
|
|
#include <import/eb32tree.h>
|
|
#include <haproxy/api-t.h>
|
|
|
|
/* some pointer types referenced below */
|
|
struct listener;
|
|
struct receiver;
|
|
struct connection;
|
|
|
|
/*
|
|
* Custom network family for str2sa parsing. Should be ok to do this since
|
|
* sa_family_t is standardized as an unsigned integer
|
|
*/
|
|
#define AF_CUST_EXISTING_FD (AF_MAX + 1)
|
|
#define AF_CUST_SOCKPAIR (AF_MAX + 2)
|
|
#define AF_CUST_MAX (AF_MAX + 3)
|
|
|
|
/*
|
|
* Test in case AF_CUST_MAX overflows the sa_family_t (unsigned int)
|
|
*/
|
|
#if (AF_CUST_MAX < AF_MAX)
|
|
# error "Can't build on the target system, AF_CUST_MAX overflow"
|
|
#endif
|
|
|
|
/* max length of a protocol name, including trailing zero */
|
|
#define PROTO_NAME_LEN 16
|
|
|
|
/* flags for ->connect() */
|
|
#define CONNECT_HAS_DATA 0x00000001 /* There's data available to be sent */
|
|
#define CONNECT_DELACK_SMART_CONNECT 0x00000002 /* Use a delayed ACK if the backend has tcp-smart-connect */
|
|
#define CONNECT_DELACK_ALWAYS 0x00000004 /* Use a delayed ACK */
|
|
#define CONNECT_CAN_USE_TFO 0x00000008 /* We can use TFO for this connection */
|
|
|
|
/* protocol families define standard functions acting on a given address family
|
|
* for a socket implementation, such as AF_INET/PF_INET for example.
|
|
*/
|
|
struct proto_fam {
|
|
char name[PROTO_NAME_LEN]; /* family name, zero-terminated */
|
|
int sock_domain; /* socket domain, as passed to socket() */
|
|
sa_family_t sock_family; /* socket family, for sockaddr */
|
|
socklen_t sock_addrlen; /* socket address length, used by bind() */
|
|
int l3_addrlen; /* layer3 address length, used by hashes */
|
|
int (*addrcmp)(const struct sockaddr_storage *, const struct sockaddr_storage *); /* compare addresses (like memcmp) */
|
|
int (*bind)(struct receiver *rx, void (*handler)(int fd), char **errmsg); /* bind a receiver */
|
|
int (*get_src)(int fd, struct sockaddr *, socklen_t, int dir); /* syscall used to retrieve src addr */
|
|
int (*get_dst)(int fd, struct sockaddr *, socklen_t, int dir); /* syscall used to retrieve dst addr */
|
|
};
|
|
|
|
/* This structure contains all information needed to easily handle a protocol.
|
|
* Its primary goal is to ease listeners maintenance. Specifically, the
|
|
* bind() primitive must be used before any fork(). rx_suspend()/rx_resume()
|
|
* return >0 on success, 0 if rx stopped, -1 on failure to proceed. rx_* may
|
|
* be null if the protocol doesn't provide direct access to the receiver.
|
|
*/
|
|
struct protocol {
|
|
char name[PROTO_NAME_LEN]; /* protocol name, zero-terminated */
|
|
struct proto_fam *fam; /* protocol family */
|
|
int ctrl_type; /* control layer type (SOCK_STREAM/SOCK_DGRAM) */
|
|
int sock_domain; /* socket domain, as passed to socket() */
|
|
int sock_type; /* socket type, as passed to socket() */
|
|
int sock_prot; /* socket protocol, as passed to socket() */
|
|
|
|
/* functions acting on the listener */
|
|
void (*add)(struct listener *l, int port); /* add a listener for this protocol and port */
|
|
int (*listen)(struct listener *l, char *errmsg, int errlen); /* start a listener */
|
|
void (*enable)(struct listener *l); /* enable receipt of new connections */
|
|
void (*disable)(struct listener *l); /* disable receipt of new connections */
|
|
|
|
/* functions acting on the receiver */
|
|
void (*rx_enable)(struct receiver *rx); /* enable receiving on the receiver */
|
|
void (*rx_disable)(struct receiver *rx); /* disable receiving on the receiver */
|
|
int (*rx_suspend)(struct receiver *rx); /* temporarily suspend this receiver for a soft restart */
|
|
int (*rx_resume)(struct receiver *rx); /* try to resume a temporarily suspended receiver */
|
|
|
|
/* functions acting on connections */
|
|
void (*accept)(int fd); /* generic accept function */
|
|
int (*connect)(struct connection *, int flags); /* connect function if any, see below for flags values */
|
|
int (*drain)(int fd); /* indicates whether we can safely close the fd */
|
|
|
|
struct list receivers; /* list of receivers using this protocol (under proto_lock) */
|
|
int nb_receivers; /* number of receivers (under proto_lock) */
|
|
struct list list; /* list of registered protocols (under proto_lock) */
|
|
};
|
|
|
|
#endif /* _HAPROXY_PROTOCOL_T_H */
|
|
|
|
/*
|
|
* Local variables:
|
|
* c-indent-level: 8
|
|
* c-basic-offset: 8
|
|
* End:
|
|
*/
|