b80b5fa389
well as sets in some of the groundwork for committing BBR. The hpts system is updated as well as some other needed utilities for the entrance of BBR. This is actually part 1 of 3 more needed commits which will finally complete with BBRv1 being added as a new tcp stack. Sponsored by: Netflix Inc. Differential Revision: https://reviews.freebsd.org/D20834
118 lines
4.0 KiB
C
118 lines
4.0 KiB
C
#ifndef __pacer_timer_h__
|
|
#define __pacer_timer_h__
|
|
/*-
|
|
* Copyright (c) 2017 Netflix, Inc.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
|
|
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
|
* SUCH DAMAGE.
|
|
*
|
|
* __FBSDID("$FreeBSD$");
|
|
*/
|
|
/* Common defines and such used by both RACK and BBR */
|
|
/* Special values for mss accounting array */
|
|
#define TCP_MSS_ACCT_JUSTRET 0
|
|
#define TCP_MSS_ACCT_SNDACK 1
|
|
#define TCP_MSS_ACCT_PERSIST 2
|
|
#define TCP_MSS_ACCT_ATIMER 60
|
|
#define TCP_MSS_ACCT_INPACE 61
|
|
#define TCP_MSS_ACCT_LATE 62
|
|
#define TCP_MSS_SMALL_SIZE_OFF 63 /* Point where small sizes enter */
|
|
#define TCP_MSS_ACCT_SIZE 70
|
|
#define TCP_MSS_SMALL_MAX_SIZE_DIV (TCP_MSS_ACCT_SIZE - TCP_MSS_SMALL_SIZE_OFF)
|
|
|
|
#define DUP_ACK_THRESHOLD 3
|
|
|
|
/* Magic flags for tracing progress events */
|
|
#define PROGRESS_DROP 1
|
|
#define PROGRESS_UPDATE 2
|
|
#define PROGRESS_CLEAR 3
|
|
#define PROGRESS_START 4
|
|
|
|
|
|
/* RTT sample methods */
|
|
#define USE_RTT_HIGH 0
|
|
#define USE_RTT_LOW 1
|
|
#define USE_RTT_AVG 2
|
|
|
|
#define PACE_MAX_IP_BYTES 65536
|
|
#define USECS_IN_SECOND 1000000
|
|
#define MSEC_IN_SECOND 1000
|
|
#define MS_IN_USEC 1000
|
|
#define USEC_TO_MSEC(x) (x / MS_IN_USEC)
|
|
#define TCP_TS_OVERHEAD 12 /* Overhead of having Timestamps on */
|
|
|
|
#ifdef _KERNEL
|
|
/* We have only 7 bits in rack so assert its true */
|
|
CTASSERT((PACE_TMR_MASK & 0x80) == 0);
|
|
#ifdef KERN_TLS
|
|
uint32_t ctf_get_opt_tls_size(struct socket *so, uint32_t rwnd);
|
|
#endif
|
|
int
|
|
ctf_process_inbound_raw(struct tcpcb *tp, struct socket *so,
|
|
struct mbuf *m, int has_pkt);
|
|
int
|
|
ctf_do_queued_segments(struct socket *so, struct tcpcb *tp, int have_pkt);
|
|
uint32_t ctf_outstanding(struct tcpcb *tp);
|
|
uint32_t ctf_flight_size(struct tcpcb *tp, uint32_t rc_sacked);
|
|
int
|
|
ctf_drop_checks(struct tcpopt *to, struct mbuf *m,
|
|
struct tcphdr *th, struct tcpcb *tp, int32_t * tlenp, int32_t * thf,
|
|
int32_t * drop_hdrlen, int32_t * ret_val);
|
|
void
|
|
ctf_do_dropafterack(struct mbuf *m, struct tcpcb *tp,
|
|
struct tcphdr *th, int32_t thflags, int32_t tlen, int32_t * ret_val);
|
|
void
|
|
ctf_do_dropwithreset(struct mbuf *m, struct tcpcb *tp,
|
|
struct tcphdr *th, int32_t rstreason, int32_t tlen);
|
|
void
|
|
ctf_do_drop(struct mbuf *m, struct tcpcb *tp);
|
|
|
|
int
|
|
ctf_process_rst(struct mbuf *m, struct tcphdr *th,
|
|
struct socket *so, struct tcpcb *tp);
|
|
|
|
void
|
|
ctf_challenge_ack(struct mbuf *m, struct tcphdr *th,
|
|
struct tcpcb *tp, int32_t * ret_val);
|
|
|
|
int
|
|
ctf_ts_check(struct mbuf *m, struct tcphdr *th,
|
|
struct tcpcb *tp, int32_t tlen, int32_t thflags, int32_t * ret_val);
|
|
|
|
void
|
|
ctf_calc_rwin(struct socket *so, struct tcpcb *tp);
|
|
|
|
void
|
|
ctf_do_dropwithreset_conn(struct mbuf *m, struct tcpcb *tp, struct tcphdr *th,
|
|
int32_t rstreason, int32_t tlen);
|
|
|
|
uint32_t
|
|
ctf_fixed_maxseg(struct tcpcb *tp);
|
|
|
|
void
|
|
ctf_log_sack_filter(struct tcpcb *tp, int num_sack_blks, struct sackblk *sack_blocks);
|
|
|
|
uint32_t
|
|
ctf_decay_count(uint32_t count, uint32_t decay_percentage);
|
|
|
|
#endif
|
|
#endif
|