Struct ThreadLoopRc

pub struct ThreadLoopRc { /* private fields */ }

Implementations

impl ThreadLoopRc

pub unsafe fn new( name: Option<&str>, properties: Option<&DictRef>, ) -> Result<Self, Error>

Initialize Pipewire and create a new ThreadLoopRc with the given name and optional properties.

Safety

TODO

pub unsafe fn new_cstr( name: Option<&CStr>, properties: Option<&DictRef>, ) -> Result<Self, Error>

Initialize Pipewire and create a new ThreadLoopRc with the given name as C string, and optional properties.

Safety

TODO

pub unsafe fn from_box(thread_loop: ThreadLoopBox) -> Self

Create a ThreadLoopRc using an existing ThreadLoopBox.

Safety

TODO

pub unsafe fn from_raw(ptr: NonNull<pw_thread_loop>) -> Self

Create a new main loop from a raw pw_thread_loop, taking ownership of it.

Safety

The provided pointer must point to a valid, well aligned pw_thread_loop.

The raw loop should not be manually destroyed or moved, as the new ThreadLoopRc takes ownership of it.

pub fn downgrade(&self) -> ThreadLoopWeak

Methods from Deref<Target = ThreadLoop>

pub fn as_raw(&self) -> &pw_thread_loop

pub fn as_raw_ptr(&self) -> *mut pw_thread_loop

pub fn loop_(&self) -> &Loop

pub fn lock(&self) -> ThreadLoopLockGuard<'_>

Lock the Loop

This ensures that the loop thread will not access objects associated with the loop while the lock is held, lock() can be used multiple times from the same thread.

The lock needs to be held whenever you call any PipeWire function that uses an object associated with this loop. Make sure to not hold on to the lock more than necessary though, as the threaded loop stops while the lock is held.

pub fn start(&self)

Start the ThreadLoop

pub fn stop(&self)

Stop the ThreadLoop

Stopping the ThreadLoop must be called without the lock

pub fn signal(&self, signal: bool)

Signal all threads waiting with wait()

pub fn wait(&self)

Release the lock and wait

Release the lock and wait until some thread calls signal()

pub fn timed_wait(&self, wait_max_sec: Duration)

Release the lock and wait a maximum of wait_max_sec seconds until some thread calls signal() or time out

pub fn get_time(&self, timeout: i64) -> TimeSpec

Get a timespec suitable for timed_wait_full()

pub fn timed_wait_full(&self, abstime: TimeSpec)

Release the lock and wait up to abs seconds until some thread calls signal(). Use get_time() to get a suitable timespec

pub fn accept(&self)

Signal all threads executing signal() with wait_for_accept

pub fn in_thread(&self)

Check if inside the thread

Trait Implementations

impl AsRef<Loop> for ThreadLoopRc

fn as_ref(&self) -> &Loop

Converts this type into a shared reference of the (usually inferred) input type.

impl AsRef<ThreadLoop> for ThreadLoopRc

fn as_ref(&self) -> &ThreadLoop

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for ThreadLoopRc

fn clone(&self) -> ThreadLoopRc

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadLoopRc

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for ThreadLoopRc

type Target = ThreadLoop

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl IsLoopRc for ThreadLoopRc