/*
- * Copyright (c) 2010 Apple Inc. All rights reserved.
+ * Copyright (c) 2010-2014 Apple Inc. All rights reserved.
*
* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
*
#define _NETINET_CC_H_
#ifdef KERNEL
-
+#include <netinet/tcp.h>
#include <netinet/tcp_var.h>
+#include <kern/zalloc.h>
-#define TCP_CC_ALGO_NEWRENO_INDEX 0 /* default congestion control algorithm */
-#define TCP_CC_ALGO_BACKGROUND_INDEX 1 /* congestion control for background transport */
-#define TCP_CC_ALGO_COUNT 2 /* Count of CC algorithms defined */
+#define TCP_CC_ALGO_NONE 0
+#define TCP_CC_ALGO_NEWRENO_INDEX 1
+#define TCP_CC_ALGO_BACKGROUND_INDEX 2 /* CC for background transport */
+#define TCP_CC_ALGO_CUBIC_INDEX 3 /* default CC algorithm */
+#define TCP_CC_ALGO_COUNT 4 /* Count of CC algorithms */
#define TCP_CA_NAME_MAX 16 /* Maximum characters in the name of a CC algorithm */
+extern int tcp_recv_bg;
+
/*
- * Structure to hold definition various actions defined by a congestion control
- * algorithm for TCP. This can be used to change the congestion control on a
- * connection based on the user settings of priority of a connection.
+ * Structure to hold definition various actions defined by a congestion
+ * control algorithm for TCP. This can be used to change the congestion
+ * control on a connection based on the user settings of priority of a
+ * connection.
*/
struct tcp_cc_algo {
char name[TCP_CA_NAME_MAX];
/* init the congestion algorithm for the specified control block */
int (*init) (struct tcpcb *tp);
- /* cleanup any state that is stored in the connection related to the algorithm */
+ /*
+ * cleanup any state that is stored in the connection
+ * related to the algorithm
+ */
int (*cleanup) (struct tcpcb *tp);
/* initialize cwnd at the start of a connection */
void (*cwnd_init) (struct tcpcb *tp);
- /* called on the receipt of in-sequence ack during congestion avoidance phase */
- void (*inseq_ack_rcvd) (struct tcpcb *tp, struct tcphdr *th);
+ /*
+ * called on the receipt of in-sequence ack during congestion
+ * avoidance phase
+ */
+ void (*congestion_avd) (struct tcpcb *tp, struct tcphdr *th);
/* called on the receipt of a valid ack */
void (*ack_rcvd) (struct tcpcb *tp, struct tcphdr *th);
/* called before entering FR */
- void (*pre_fr) (struct tcpcb *tp, struct tcphdr *th);
+ void (*pre_fr) (struct tcpcb *tp);
/* after exiting FR */
void (*post_fr) (struct tcpcb *tp, struct tcphdr *th);
} __attribute__((aligned(4)));
+extern struct zone *tcp_cc_zone;
+
extern struct tcp_cc_algo* tcp_cc_algo_list[TCP_CC_ALGO_COUNT];
#define CC_ALGO(tp) (tcp_cc_algo_list[tp->tcp_cc_index])
+#define TCP_CC_CWND_INIT_BYTES 4380
+/*
+ * The congestion window will have to be reset after a
+ * non-validated period -- currently set to 3 minutes
+ */
+#define TCP_CC_CWND_NONVALIDATED_PERIOD (3 * 60 * TCP_RETRANSHZ)
+
+extern void tcp_cc_init(void);
+extern void tcp_cc_resize_sndbuf(struct tcpcb *tp);
+extern void tcp_bad_rexmt_fix_sndbuf(struct tcpcb *tp);
+extern void tcp_cc_cwnd_init_or_reset(struct tcpcb *tp);
+extern int tcp_cc_delay_ack(struct tcpcb *tp, struct tcphdr *th);
+extern void tcp_ccdbg_trace(struct tcpcb *tp, struct tcphdr *th,
+ int32_t event);
+extern void tcp_cc_allocate_state(struct tcpcb *tp);
+extern void tcp_cc_after_idle_stretchack(struct tcpcb *tp);
+extern uint32_t tcp_cc_is_cwnd_nonvalidated(struct tcpcb *tp);
+extern void tcp_cc_adjust_nonvalidated_cwnd(struct tcpcb *tp);
+extern u_int32_t tcp_get_max_pipeack(struct tcpcb *tp);
+extern void tcp_clear_pipeack_state(struct tcpcb *tp);
#endif /* KERNEL */
#endif /* _NETINET_CC_H_ */