Struct Request

pub struct Request {
    next: AtomicPtr<Behavior>,
    scheduled: AtomicBool,
    target: Arc<dyn CownBase>,
}

A request for a cown.

Fields

next: AtomicPtr<Behavior>

Pointer to the next scheduled behavior.

scheduled: AtomicBool

Is this request scheduled?

target: Arc<dyn CownBase>

The cown that this request wants to access.

This is an Arc as the all exposed CownPtrs may have been dropped while the behavior is still scheduled.

Implementations

impl Request

fn new(target: Arc<dyn CownBase>) -> Request

Creates a new Request.

unsafe fn start_enqueue(&self, behavior: *const Behavior)

Start the first phase of the 2PL enqueue operation.

Enqueues self onto the target cown. Returns once all previous behaviors on this cown has finished enqueueing on all of its required cowns. This ensures the 2PL protocol.

SAFETY

behavior must be a valid raw pointer to the behavior for self, and this should be the only enqueueing of this request and behavior.

unsafe fn finish_enqueue(&self)

Finish the second phase of the 2PL enqueue operation.

Sets the scheduled flag so that subsequent behaviors can continue the 2PL enqueue.

Safety

All enqueues for smaller requests on this cown must have been completed.

unsafe fn release(&self)

Release the cown to the next behavior.

Called when self has been completed, and thus can allow the next waiting behavior to run. If there is no next behavior, then the cown’s tail pointer is set to null.

Safety

self must have been actually completed.

Trait Implementations

impl Debug for Request

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

Formats the value using the given formatter.

impl Ord for Request

fn cmp(&self, other: &Self) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for Request

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for Request

fn partial_cmp(&self, other: &Self) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Eq for Request

impl Send for Request