Struct Pipe 

pub struct Pipe {
    pub name: String,
    inbound: Vec<u8>,
    outbound: VecDeque<Vec<u8>>,
}

A virtual named pipe bound to one open file id.

Fields

name: String

Lowercased pipe name (e.g. srvsvc).

inbound: Vec<u8>

outbound: VecDeque<Vec<u8>>

Implementations

impl Pipe

pub fn new(name: &str) -> Self

Open a fresh, empty pipe with the given name.

pub fn pending(&self) -> usize

Bytes queued in the next outbound DCERPC fragment.

pub fn take(&mut self, max: usize) -> Vec<u8>

Dequeue up to max bytes of the next outbound fragment.

pub fn on_write(&mut self, data: &[u8], shares: &[ShareInfo])

Feed inbound DCERPC bytes, dispatching any complete request PDUs (BIND, and NetShareEnumAll opnum 15) and queueing their responses.