Struct BusyHandlerState 

pub struct BusyHandlerState { /* private fields */ }

Tracks the state of busy handler invocations for a statement.

This implements a yield-based busy handling mechanism that integrates with the async event loop. Instead of blocking with thread::sleep, the statement yields back to the caller with StepResult::IO and a timeout. When step() is called again after the timeout has passed, it retries the operation.

Uses increasing delays. After 12 iterations, continues with 100ms delays until max duration is reached.

Implementations

impl BusyHandlerState

pub fn new(now: MonotonicInstant) -> Self

Create a new busy handler state

pub fn reset(&mut self, now: MonotonicInstant)

Reset the state for a new locking event

pub fn timeout(&self) -> MonotonicInstant

Get the current timeout instant

pub fn invoke(&mut self, handler: &BusyHandler, now: MonotonicInstant) -> bool

Invoke the busy handler and determine whether to retry.

Returns true if the operation should be retried, false if SQLITE_BUSY should be returned to the application.

For timeout-based handlers, this also updates the internal timeout instant. For custom handlers, this invokes the callback and respects its return value.

pub fn get_delay(&self, now: MonotonicInstant) -> Duration

Get the delay duration that should be waited before the next retry.

This returns the duration between now and the timeout instant. Returns Duration::ZERO if the timeout has already passed.

Trait Implementations

impl Debug for BusyHandlerState

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

Formats the value using the given formatter.