diff options
| author | tv <tv@krebsco.de> | 2026-10-31 19:53:27 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 19:53:27 +0100 |
| commit | 9c12bf2e8815dc9b42be62f1e1fd2932dd02938b (patch) | |
| tree | 09cd985fae9142a247a2285c755f9d002a2c7b30 /src/document/lock.rs | |
| parent | f4b0a7c5159d418e22682d2bd7d413fb3587ca7f (diff) | |
use Automerge as Document instead of AutoCommit
This allows a lot of operations to drop mut.
Diffstat (limited to 'src/document/lock.rs')
| -rw-r--r-- | src/document/lock.rs | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/src/document/lock.rs b/src/document/lock.rs index a394b52..f05c5e3 100644 --- a/src/document/lock.rs +++ b/src/document/lock.rs @@ -27,8 +27,8 @@ pub(crate) struct DocumentLock { pub(crate) struct LockWaits { /// Readers: wait for a writer only. pub(crate) read: Waits, - /// Writers (applying sync messages, generating them, writes, saves): wait for - /// everyone. + /// Writers (applying sync messages and fetched changes, writes, epoch switches): + /// wait for everyone. pub(crate) write: Waits, } @@ -125,13 +125,6 @@ impl DocumentLock { guard } - pub(crate) async fn write(&self) -> RwLockWriteGuard<'_, Replica> { - let since = Instant::now(); - let guard = self.replica.write().await; - self.waited(Mode::Write, since); - guard - } - /// Outside the runtime only (`spawn_blocking`), like `RwLock::blocking_read`. pub(crate) fn blocking_read(&self) -> RwLockReadGuard<'_, Replica> { let since = Instant::now(); |
