Struct FileAllocationLock 

pub struct FileAllocationLock { /* private fields */ }

d1’s file lock, which is host-wide across processes as well as across tasks.

Defence in depth behind InProcessAllocationLock, for the configuration d1 documents as the one where two agents can genuinely coexist: the platform state directory is per-account, so a service-account daemon and an interactive daemon run resolve different paths and do not contend for the single-instance lock. They do contend here if they share a state directory.

runner_manager_platform::lock::HostLock::acquire blocks the calling thread and its own documentation names this caller: “Async callers must wrap it in tokio::task::spawn_blocking”. That is what this does, and the returned HostLock lives inside the guard, because dropping it is the release.

Implementations

impl FileAllocationLock

pub const fn new(paths: Arc<AppPaths>) -> Self

pub const fn with_wait(self, wait: Duration) -> Self

Trait Implementations

impl AllocationLock for FileAllocationLock

fn acquire<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<AllocationGuard, AllocationLockBusy>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Take the lock, waiting briefly for it.

impl Clone for FileAllocationLock

fn clone(&self) -> FileAllocationLock

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileAllocationLock

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

Formats the value using the given formatter.