Struct NotificationStream

pub struct NotificationStream { /* private fields */ }

A stream of seccomp notifications.

This struct provides an asynchronous stream of seccomp notifications. It wraps an AsyncFd around a SeccompFd to enable asynchronous operations on the seccomp file descriptor.

Implementations

impl NotificationStream

pub fn new(fd: RawFd) -> Result<Self, Error>

Creates a new NotificationStream from a raw file descriptor.

This method initializes a NotificationStream with the given raw file descriptor. It sets up the AsyncFd to be ready for reading seccomp notifications.

Arguments

• fd - The raw file descriptor for seccomp notifications.

Returns

A Result containing a new NotificationStream or an io::Error if the operation fails.

pub fn blocking_recv(&self) -> Result<Notification, Error>

Receives a seccomp notification.

This method will block until it receives a seccomp notification. You can prevent it from blocking by listening for self.inner to become readable using epoll / poll / select.

Returns

A Result containing a Notification or an io::Error.

pub async fn recv(&self) -> Result<Notification, Error>

Receives a seccomp notification asynchronously.

This method will not block unless other threads are simultaneously listening for notifications.

Returns

A Result containing a Notification or an io::Error.

pub fn send( &self, notif: Notification, response_type: ResponseType, ) -> Result<(), Error>

Sends a response to a seccomp notification.

This method sends a response to a seccomp notification based on the provided ResponseType.

Arguments

• notif - The notification to which the response is being sent.
• response_type - The type of response to send.

Returns

A Result indicating the success or failure of the operation.

pub unsafe fn send_continue(&self, notif: Notification) -> Result<(), Error>

Sends a continue response to a seccomp notification.

This method sends a continue response to a seccomp notification. It returns a Result indicating the success or failure of the operation.

Arguments

• notif - The notification to which the continue response is being sent.

Returns

A Result indicating the success or failure of the operation.

Safety

This method is unsafe because continuing a syscall is inherently prone to race conditions. See RawResponse::send_continue for more information.

Trait Implementations

impl Debug for NotificationStream

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

Formats the value using the given formatter.

impl Stream for NotificationStream

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Polls the stream for the next notification.

This method polls the stream to check if a new notification is ready to be received. It returns a Poll indicating whether a notification is ready, an error occurred, or the operation is pending.

Arguments

• self - A mutable reference to self.
• cx - A context for the current task.

Returns

A Poll indicating the state of the next notification.

type Item = Notification

Values yielded by the stream.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.