Page MenuHomeFreeBSD
Differential D15358 Diff 42359 FreeBSD/sys/netinet/cc/cc_newreno.c

Changeset View

Standalone View

View Options

FreeBSD/sys/netinet/cc/cc_newreno.c

Context not available.
#define CAST_PTR_INT(X) (*((int*)(X))) #define CAST_PTR_INT(X) (*((int*)(X)))
static int newreno_cb_init(struct cc_var *ccv); static void newreno_cb_destroy(struct cc_var *ccv);
static void newreno_ack_received(struct cc_var *ccv, uint16_t type); static void newreno_ack_received(struct cc_var *ccv, uint16_t type);
static void newreno_after_idle(struct cc_var *ccv); static void newreno_after_idle(struct cc_var *ccv);
static void newreno_cong_signal(struct cc_var *ccv, uint32_t type); static void newreno_cong_signal(struct cc_var *ccv, uint32_t type);
Context not available.
struct cc_algo newreno_cc_algo = { struct cc_algo newreno_cc_algo = {
.name = "newreno", .name = "newreno",
.cb_init = newreno_cb_init, .cb_destroy = newreno_cb_destroy,
.ack_received = newreno_ack_received, .ack_received = newreno_ack_received,
.after_idle = newreno_after_idle, .after_idle = newreno_after_idle,
.cong_signal = newreno_cong_signal, .cong_signal = newreno_cong_signal,
Context not available.
uint32_t beta_ecn; uint32_t beta_ecn;
}; };
int static inline struct newreno *
newreno_cb_init(struct cc_var *ccv) newreno_condmalloc(struct cc_var *ccv, int jit_alloc)
{ {
struct newreno *nreno; struct newreno *nreno;
nreno = malloc(sizeof(struct newreno), M_NEWRENO, M_NOWAIT|M_ZERO); nreno = ccv->cc_data;
if (nreno != NULL) { if (nreno == NULL && jit_alloc) {
nreno->beta = V_newreno_beta; nreno = malloc(sizeof(struct newreno), M_NEWRENO,
nreno->beta_ecn = V_newreno_beta_ecn; M_NOWAIT|M_ZERO);
if (nreno != NULL) {
nreno->beta = V_newreno_beta;
nreno->beta_ecn = V_newreno_beta_ecn;
ccv->cc_data = nreno;
}
} }
return (0); return (nreno);
}
static void
newreno_cb_destroy(struct cc_var *ccv)
{
if (ccv->cc_data != NULL)
free(ccv->cc_data, M_NEWRENO);
} }
static void static void
Context not available.
newreno_cong_signal(struct cc_var *ccv, uint32_t type) newreno_cong_signal(struct cc_var *ccv, uint32_t type)
{ {
struct newreno *nreno; struct newreno *nreno;
uint32_t cwin, factor; uint32_t beta, beta_ecn, cwin, factor;
u_int mss; u_int mss;
factor = V_newreno_beta;
nreno = ccv->cc_data;
if (nreno != NULL) {
if (V_cc_do_abe)
factor = (type == CC_ECN ? nreno->beta_ecn: nreno->beta);
else
factor = nreno->beta;
}
cwin = CCV(ccv, snd_cwnd); cwin = CCV(ccv, snd_cwnd);
mss = CCV(ccv, t_maxseg); mss = CCV(ccv, t_maxseg);
nreno = ccv->cc_data;
beta = (nreno == NULL) ? V_newreno_beta : nreno->beta;
beta_ecn = (nreno == NULL) ? V_newreno_beta_ecn : nreno->beta_ecn;
if (V_cc_do_abe && type == CC_ECN)
factor = beta_ecn;
else
factor = beta;
/* Catch algos which mistakenly leak private signal types. */ /* Catch algos which mistakenly leak private signal types. */
KASSERT((type & CC_SIGPRIVMASK) == 0, KASSERT((type & CC_SIGPRIVMASK) == 0,
Context not available.
V_cc_do_abe && V_cc_abe_frlossreduce)) { V_cc_do_abe && V_cc_abe_frlossreduce)) {
CCV(ccv, snd_ssthresh) = CCV(ccv, snd_ssthresh) =
((uint64_t)CCV(ccv, snd_ssthresh) * ((uint64_t)CCV(ccv, snd_ssthresh) *
(uint64_t)nreno->beta) / (uint64_t)beta) /
(100ULL * (uint64_t)nreno->beta_ecn); (100ULL * (uint64_t)beta_ecn);
} }
if (!IN_CONGRECOVERY(CCV(ccv, t_flags))) if (!IN_CONGRECOVERY(CCV(ccv, t_flags)))
CCV(ccv, snd_ssthresh) = cwin; CCV(ccv, snd_ssthresh) = cwin;
Context not available.
newreno_post_recovery(struct cc_var *ccv) newreno_post_recovery(struct cc_var *ccv)
{ {
int pipe; int pipe;
pipe = 0;
if (IN_FASTRECOVERY(CCV(ccv, t_flags))) { if (IN_FASTRECOVERY(CCV(ccv, t_flags))) {
/* /*
Context not available.
} }
} }
int static int
newreno_ctl_output(struct cc_var *ccv, struct sockopt *sopt, void *buf) newreno_ctl_output(struct cc_var *ccv, struct sockopt *sopt, void *buf)
{ {
struct newreno *nreno; struct newreno *nreno;
Context not available.
if (sopt->sopt_valsize != sizeof(struct cc_newreno_opts)) if (sopt->sopt_valsize != sizeof(struct cc_newreno_opts))
return (EMSGSIZE); return (EMSGSIZE);
nreno = ccv->cc_data; nreno = newreno_condmalloc(ccv, sopt->sopt_dir == SOPT_SET);
opt = buf; opt = buf;
switch (sopt->sopt_dir) { switch (sopt->sopt_dir) {
case SOPT_SET: case SOPT_SET:
/* We cannot set without cc_data memory. */
if (nreno == NULL)
return (ENOMEM);
switch (opt->name) { switch (opt->name) {
case CC_NEWRENO_BETA: case CC_NEWRENO_BETA:
nreno->beta = opt->val; nreno->beta = opt->val;
Context not available.
default: default:
return (ENOPROTOOPT); return (ENOPROTOOPT);
} }
break;
case SOPT_GET: case SOPT_GET:
switch (opt->name) { switch (opt->name) {
case CC_NEWRENO_BETA: case CC_NEWRENO_BETA:
opt->val = nreno->beta; opt->val = (nreno == NULL) ?
V_newreno_beta : nreno->beta;
break; break;
case CC_NEWRENO_BETA_ECN: case CC_NEWRENO_BETA_ECN:
opt->val = nreno->beta_ecn; opt->val = (nreno == NULL) ?
V_newreno_beta_ecn : nreno->beta_ecn;
break; break;
default: default:
return (ENOPROTOOPT); return (ENOPROTOOPT);
} }
break;
default: default:
return (EINVAL); return (EINVAL);
} }
Context not available.
static int static int
newreno_beta_handler(SYSCTL_HANDLER_ARGS) newreno_beta_handler(SYSCTL_HANDLER_ARGS)
{ {
if (req->newptr != NULL ) { if (req->newptr != NULL ) {
if (arg1 == &VNET_NAME(newreno_beta_ecn) && !V_cc_do_abe) if (arg1 == &VNET_NAME(newreno_beta_ecn) && !V_cc_do_abe)
return (EACCES); return (EACCES);
Context not available.