pub trait CongAlg<I: Ipc> {
type Flow: Flow;
fn name() -> &'static str;
fn datapath_programs(&self) -> HashMap<&'static str, String>;
fn new_flow(&self, control: Datapath<I>, info: DatapathInfo) -> Self::Flow;
}
Expand description
implement this trait, portus::CongAlgBuilder
and
portus::Flow
to define a ccp congestion control algorithm.
CongAlg
implements functionality which applies to a given algorithm as a wholeFlow
implements functionality specific to an individual flowCongAlgBuilder
specifies how the trait that implementsCongAlg
should be built from given command-line arguments.
Associated Types
A type which implements the portus::Flow
trait, to manage
an individual connection.
Required methods
fn datapath_programs(&self) -> HashMap<&'static str, String>
fn datapath_programs(&self) -> HashMap<&'static str, String>
datapath_programs
returns all datapath programs the congestion control algorithm
will to use during its execution. It is called once, when Portus initializes
(portus::run
or portus::spawn
).
It should return a vector of string tuples, where the first string in each tuple is a unique name identifying the program, and the second string is the code for the program itself.
The Portus runtime will panic if any of the datapath programs do not compile.
For example,
use std::collections::HashMap;
let mut h = HashMap::new();
h.insert("prog1", "...(program)...".to_string());
h.insert("prog2", "...(program)...".to_string());
fn new_flow(&self, control: Datapath<I>, info: DatapathInfo) -> Self::Flow
fn new_flow(&self, control: Datapath<I>, info: DatapathInfo) -> Self::Flow
Create a new instance of the CongAlg to manage a new flow.
Optionally copy any configuration parameters from &self
.