mirror of
https://github.com/haproxy/haproxy.git
synced 2026-04-21 22:28:41 -04:00
dfbae766b2
This file has been derived from mux_h2.c removing all h2 parts. At QUIC mux layer, there must not be any reference to http. This will be the responsability of the application layer (h3) to open streams handled by the mux.
126 lines
3.8 KiB
C
126 lines
3.8 KiB
C
/*
|
|
* include/haproxy/mux_quic-t.h
|
|
* This file containts prototypes for QUIC mux-demux.
|
|
*
|
|
* Copyright 2021 HAProxy Technologies, Frédéric Lécaille <flecaille@haproxy.com>
|
|
*
|
|
* 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_MUX_QUIC_H
|
|
#define _HAPROXY_MUX_QUIC_H
|
|
#ifdef USE_QUIC
|
|
#ifndef USE_OPENSSL
|
|
#error "Must define USE_OPENSSL"
|
|
#endif
|
|
|
|
#include <haproxy/buf-t.h>
|
|
#include <haproxy/mux_quic-t.h>
|
|
#include <haproxy/obj_type.h>
|
|
|
|
void quic_mux_transport_params_update(struct qcc *qcc);
|
|
struct buffer *qc_get_buf(struct qcc *qcc, struct buffer *bptr);
|
|
int qc_cpy_mbuf(struct qcs *qcs, unsigned char *buf, size_t len);
|
|
void qc_error(struct qcc *qcc, int err);
|
|
struct qcs *qcc_get_stream(struct qcc *qcc, uint64_t id);
|
|
struct qcs *bidi_qcs_new(struct qcc *qcc, uint64_t id);
|
|
struct qcs *luqs_new(struct qcc *qcc);
|
|
struct qcs *ruqs_new(struct qcc *qcc, uint64_t id);
|
|
size_t luqs_snd_buf(struct qcs *qcs, struct buffer *buf, size_t count, int flags);
|
|
void qcs_release(struct qcs *qcs);
|
|
|
|
void ruqs_notify_recv(struct qcs *qcs);
|
|
|
|
/* Return 1 if the stream with <id> as ID attached to <qcc> connection
|
|
* has been locally initiated, 0 if not.
|
|
*/
|
|
static inline int qc_local_stream_id(struct qcc *qcc, uint64_t id)
|
|
{
|
|
if ((objt_listener(qcc->conn->target) && (id & QCS_ID_SRV_INTIATOR_BIT)) ||
|
|
(objt_server(qcc->conn->target) && !(id & QCS_ID_SRV_INTIATOR_BIT)))
|
|
return 1;
|
|
|
|
return 0;
|
|
}
|
|
|
|
/* Return 1 if <qcs> stream has been locally initiated, 0 if not. */
|
|
static inline int qcs_local(struct qcs *qcs)
|
|
{
|
|
if ((objt_listener(qcs->qcc->conn->target) && (qcs->id & QCS_ID_SRV_INTIATOR_BIT)) ||
|
|
(objt_server(qcs->qcc->conn->target) && !(qcs->id & QCS_ID_SRV_INTIATOR_BIT)))
|
|
return 1;
|
|
|
|
return 0;
|
|
}
|
|
|
|
/* Return the direction of a stream with <id> as ID. */
|
|
static inline enum qcs_dir qcs_id_dir(uint64_t id)
|
|
{
|
|
return (id & QCS_ID_DIR_BIT) >> QCS_ID_DIR_BIT_SHIFT;
|
|
}
|
|
|
|
/* Return the direction of <qcs> QUIC stream. */
|
|
static inline enum qcs_dir qcs_dir(struct qcs *qcs)
|
|
{
|
|
return (qcs->id & QCS_ID_DIR_BIT) >> QCS_ID_DIR_BIT_SHIFT;
|
|
}
|
|
|
|
static inline enum qcs_type qcs_id_type(uint64_t id)
|
|
{
|
|
return id & QCS_ID_TYPE_MASK;
|
|
}
|
|
|
|
static inline enum qcs_type qcs_type_from_dir(struct qcc *qcc, enum qcs_dir dir)
|
|
{
|
|
return (dir << QCS_ID_DIR_BIT_SHIFT) |
|
|
(!!objt_listener(qcc->conn->target) ? QCS_ID_SRV_INTIATOR_BIT : 0);
|
|
}
|
|
|
|
static inline int64_t qcc_wnd(struct qcc *qcc)
|
|
{
|
|
return qcc->tx.max_data - qcc->tx.bytes;
|
|
}
|
|
|
|
/* Return 1 if <qcs> is unidirectional, 0 if not. */
|
|
static inline int qcs_uni(struct qcs *qcs)
|
|
{
|
|
return qcs->id & QCS_ID_DIR_BIT;
|
|
}
|
|
|
|
/* Return 1 if <qcs> is bidirectional, 0 if not. */
|
|
static inline int qcs_bidi(struct qcs *qcs)
|
|
{
|
|
return !qcs_uni(qcs);
|
|
}
|
|
|
|
/* Return the next stream ID with <qcs_type> as type if succeeded, (uint64_t)-1 if not. */
|
|
static inline uint64_t qcs_next_id(struct qcc *qcc, enum qcs_type qcs_type)
|
|
{
|
|
if (qcc->strms[qcs_type].nb_streams + 1 > qcc->strms[qcs_type].max_streams)
|
|
return (uint64_t)-1;
|
|
|
|
return (qcc->strms[qcs_type].nb_streams++ << QCS_ID_TYPE_SHIFT) | qcs_type;
|
|
}
|
|
|
|
static inline void *qcs_new(struct qcc *qcc, uint64_t id)
|
|
{
|
|
if (id & QCS_ID_DIR_BIT)
|
|
return ruqs_new(qcc, id);
|
|
else
|
|
return bidi_qcs_new(qcc, id);
|
|
}
|
|
|
|
#endif /* USE_QUIC */
|
|
#endif /* _HAPROXY_MUX_QUIC_H */
|