Struct PipeEndpoint

pub struct PipeEndpoint {
    state: Arc<Mutex<PipeState>>,
    can_read: bool,
    can_write: bool,
    id: String,
}

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

state: Arc<Mutex<PipeState>>

Shared pipe state

can_read: bool

Whether this endpoint can read

can_write: bool

Whether this endpoint can write

id: String

Unique identifier for debugging

Implementations

impl PipeEndpoint

fn new( state: Arc<Mutex<PipeState>>, 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 copy 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 IpcObject for PipeEndpoint

fn is_connected(&self) -> bool

Check if the 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 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

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