def publish.parent

mylsm-lsm-store@0.6.0.1 · src/transfer/BackupIo.bend:70

import Base
import mylsm-lsm-store@0.6.0.1/src/transfer/PublicationPolicy.bend as PublicationPolicy
import mylsm-lsm-store@0.6.0.1/src/CrashPoint.bend as CrashPoint

70def publish.parent(
71  +temporary: String,
72  result: Result<&1, &1, U32 & String, Unit>
73) -> IO(Result<&1, &1, Error, Unit>):
74  match result:
75    case Fail{error}:
76      publish.parent.failed(temporary,
77        PublicationPolicy.failure(PublicationPolicy.AfterRename{}), error)
78    case Done{Unit{}}:
79      do IO<Result<&1, &1, Error, Unit>>:
80        _stopped : Result<&1, &1, U32 & String, Unit> <- CrashPoint.hit("backup.parent_synced")
81        cleanup(temporary)
82        return Done{Unit{}}