pub fn add(&mut self, inflight: u64) {
        if self.full() {
            panic!("cannot add into a Full inflights");
        }
        let mut next = self.start + self.count;
        let mut size = self.size;
        if next >= size {
            next -= size;
        }
        if next >= self.buffer.len() {
            self.grow();
        }
        self.buffer[next] = inflight;
        self.count += 1;
        if self.full() {
            info!("[has full {}]", self.count());
        }
    }
// Add notifies the Inflights that a new message with the given index is being
// dispatched. Full() must be called prior to Add() to verify that there is room
// for one more message, and consecutive calls to add Add() must provide a
// monotonic sequence of indexes.
Add notifies the Inflights that a new message with the given index is being
dispatched. Full() must be called prior to Add() to verify that there is room
for one more message, and consecutive calls to add Add() must provide a
monotonic sequence of indexes.
Add notifies the Inflights that a new message with the given index is being dispatched . Full () must be called prior to Add () to verify that there is room for one more message and consecutive calls to add Add () must provide a monotonic sequence of indexes .
pub fn add(&mut self, inflight: u64) {
        if self.full() {
            panic!("cannot add into a Full inflights");
        }
        let mut next = self.start + self.count;
        let mut size = self.size;
        if next >= size {
            next -= size;
        }
        if next >= self.buffer.len() {
            self.grow();
        }
        self.buffer[next] = inflight;
        self.count += 1;
        if self.full() {
            info!("[has full {}]", self.count());
        }
    }
pub fn add ( & mut self , inflight : u64 ) { if self . full ( ) { panic ! ( " " ) ; } let mut next = self . start + self . count ; let mut size = self . size ; if next >= size { next -= size ; } if next >= self . buffer . len ( ) { self . grow ( ) ; } self . buffer [ next ] = inflight ; self . count += 1 ; if self . full ( ) { info ! ( " " self count ( ) ) ; } }
Add notifies the Inflights that a new message with the given index is being
dispatched.
Add notifies the Inflights that a new message with the given index is being dispatched .
&mut self
inflight
u64