Struct PipeEndpoint 

pub struct PipeEndpoint {
    data: Arc<SharedPipeData>,
    can_read: bool,
    can_write: bool,
    id: String,
    nonblocking: AtomicBool,
}

A generic pipe endpoint

This represents the basic building block for all pipe types. It can be configured for read-only, write-only, or bidirectional access.

Fields

data: Arc<SharedPipeData>

Shared pipe data (state + wakers)

can_read: bool

Whether this endpoint can read

can_write: bool

Whether this endpoint can write

id: String

Unique identifier for debugging

nonblocking: AtomicBool

Per-endpoint non-blocking flag (O_NONBLOCK semantics)

Implementations

impl PipeEndpoint

fn new( data: Arc<SharedPipeData>, can_read: bool, can_write: bool, id: String, ) -> Self

Create a new pipe endpoint with specified capabilities

Trait Implementations

impl Clone for PipeEndpoint

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CloneOps for PipeEndpoint

fn custom_clone(&self) -> KernelObject

Perform a custom clone operation and return the cloned object

impl Drop for PipeEndpoint

fn drop(&mut self)

Executes the destructor for this type.

impl PipeObject for PipeEndpoint

fn has_readers(&self) -> bool

Check if there are readers on the other end

fn has_writers(&self) -> bool

Check if there are writers on the other end

fn buffer_size(&self) -> usize

Get the buffer size of the pipe

fn available_bytes(&self) -> usize

Get the number of bytes currently in the pipe buffer

fn is_readable(&self) -> bool

Check if this end of the pipe is readable

fn is_writable(&self) -> bool

Check if this end of the pipe is writable

fn as_selectable(&self) -> Option<&dyn Selectable>

Optional capability: expose select/pselect readiness/wait interface.

impl StreamIpcOps for PipeEndpoint

fn is_connected(&self) -> bool

Check if the stream IPC object is still connected/valid

fn peer_count(&self) -> usize

Get the number of active peers (readers/writers/endpoints)

fn description(&self) -> String

Get a human-readable description of this IPC object

impl StreamOps for PipeEndpoint

fn read(&self, buffer: &mut [u8]) -> Result<usize, StreamError>

Read data from the stream

fn write(&self, buffer: &[u8]) -> Result<usize, StreamError>

Write data to the stream