mirror of
https://git.haproxy.org/git/haproxy.git/
synced 2025-08-06 23:27:04 +02:00
a5b325f92c
At some places (log fd@XXX, bind fd@XXX) we support using an explicit file descriptor number, that is placed into the sockaddr for later use. The problem is that till now it was done with an AF_UNSPEC family, which is also used for other situations like missing info or rings (for logs). Let's create an "official" family AF_CUST_EXISTING_FD for this case so that we are certain the FD can be found in the address when it is set.
110 lines
4.7 KiB
C
110 lines
4.7 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_UDP4 (AF_MAX + 3)
|
|
#define AF_CUST_UDP6 (AF_MAX + 4)
|
|
#define AF_CUST_MAX (AF_MAX + 5)
|
|
|
|
/*
|
|
* 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(), and the enable_all()
|
|
* primitive must be called after the fork() to enable all fds.
|
|
*/
|
|
struct protocol {
|
|
char name[PROTO_NAME_LEN]; /* protocol name, zero-terminated */
|
|
struct proto_fam *fam; /* protocol family */
|
|
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() */
|
|
void (*accept)(int fd); /* generic accept function */
|
|
int (*listen)(struct listener *l, char *errmsg, int errlen); /* start a listener */
|
|
int (*enable_all)(struct protocol *proto); /* enable all bound listeners */
|
|
int (*disable_all)(struct protocol *proto); /* disable all bound listeners */
|
|
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 */
|
|
int (*pause)(struct listener *l); /* temporarily pause this listener for a soft restart */
|
|
void (*add)(struct listener *l, int port); /* add a listener for this protocol and port */
|
|
|
|
struct list listeners; /* list of listeners using this protocol (under proto_lock) */
|
|
int nb_listeners; /* number of listeners (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:
|
|
*/
|