diff --git a/uplink/src/base/serializer/mod.rs b/uplink/src/base/serializer/mod.rs index 9f25a315..08005e5d 100644 --- a/uplink/src/base/serializer/mod.rs +++ b/uplink/src/base/serializer/mod.rs @@ -225,25 +225,25 @@ impl StorageHandler { /// /// ```text /// -/// Send publishes in Storage to No more publishes -/// Network, write new data to disk left in Storage -/// ┌---------------------┐ ┌──────┐ -/// │Serializer::catchup()├───────────────────────────────────────►Normal│ -/// └---------▲---------┬-┘ └───┬──┘ -/// │ │ Network has crashed │ -/// Network is │ │ ┌───────────────────────┐ │ -/// available │ ├────►EventloopCrash(publish)│ │ -/// ┌-------------------┐ ┌----------------------┐ ┌───────┴──────┐ │ └───────────┬───────────┘ ┌----------▼---------┐ -/// │Serializer::start()├──►Serializer::recovery()├──►EventloopReady│ │ ┌------------▼-------------┐ │Serializer::normal()│ Forward all data to Network -/// └-------------------┘ └----------------------┘ └───────▲──────┘ │ │Serializer::crash(publish)├─┐ └----------┬---------┘ -/// │ │ └-------------------------▲┘ │ │ -/// │ │ Write all data to Storage└──┘ │ -/// │ │ │ -/// ┌---------┴---------┴-----┐ ┌───────────▼──────────┐ -/// │Serializer::slow(publish)◄───────────────────────────┤SlowEventloop(publish)│ -/// └-------------------------┘ └──────────────────────┘ -/// Write to storage, Slow network encountered -/// but continue trying to publish +/// Send publishes in Storage to No more publishes +/// Network, write new data to disk left in Storage +/// ┌---------------------┐ ┌──────┐ +/// │Serializer::catchup()├───────────────────────────────────────►Normal│ +/// └---------▲---------┬-┘ └───┬──┘ +/// │ │ Network has crashed │ +/// Network is │ │ ┌───────────────────────┐ │ +/// available │ ├────►EventloopCrash(publish)│ │ +/// ┌-------------------┐ ┌───────┴──────┐ │ └───────────┬───────────┘ ┌----------▼---------┐ +/// │Serializer::start()├────►EventloopReady│ │ ┌------------▼-------------┐ │Serializer::normal()│ Forward all data to Network +/// └-------------------┘ └───────▲──────┘ │ │Serializer::crash(publish)├─┐ └----------┬---------┘ +/// │ │ └-------------------------▲┘ │ │ +/// │ │ Write all data to Storage└──┘ │ +/// │ │ │ +/// ┌---------┴---------┴-----┐ ┌───────────▼──────────┐ +/// │Serializer::slow(publish)◄───────────────────────────┤SlowEventloop(publish)│ +/// └-------------------------┘ └──────────────────────┘ +/// Write to storage, Slow network encountered +/// but continue trying to publish /// ///``` /// [`start()`]: Serializer::start