aboutsummaryrefslogtreecommitdiff
path: root/cmd/plutia
diff options
context:
space:
mode:
authorFuwn <[email protected]>2026-02-27 09:26:06 -0800
committerFuwn <[email protected]>2026-02-27 09:26:06 -0800
commit8980607ef8e7426b601f942f26ae2cd4c4f3edff (patch)
tree60bdb4bbbe5755223c3387179ee7406432d084ab /cmd/plutia
parentfix: make mirror replay lossless with strict seq accounting and trace (diff)
downloadplutia-test-8980607ef8e7426b601f942f26ae2cd4c4f3edff.tar.xz
plutia-test-8980607ef8e7426b601f942f26ae2cd4c4f3edff.zip
feat: add thin mode for on-demand verified PLC resolution
Diffstat (limited to 'cmd/plutia')
-rw-r--r--cmd/plutia/main.go14
1 files changed, 8 insertions, 6 deletions
diff --git a/cmd/plutia/main.go b/cmd/plutia/main.go
index 2a507b5..b6192f5 100644
--- a/cmd/plutia/main.go
+++ b/cmd/plutia/main.go
@@ -110,11 +110,13 @@ func runServe(args []string) error {
defer stop()
- if err := app.service.Replay(ctx); err != nil {
- if app.service.IsCorrupted() {
- log.Printf("starting in read-only corrupted mode: %v", err)
- } else {
- return fmt.Errorf("initial replay failed: %w", err)
+ if app.cfg.Mode != config.ModeThin {
+ if err := app.service.Replay(ctx); err != nil {
+ if app.service.IsCorrupted() {
+ log.Printf("starting in read-only corrupted mode: %v", err)
+ } else {
+ return fmt.Errorf("initial replay failed: %w", err)
+ }
}
}
@@ -133,7 +135,7 @@ func runServe(args []string) error {
}
}()
- if !app.service.IsCorrupted() {
+ if app.cfg.Mode != config.ModeThin && !app.service.IsCorrupted() {
go func() {
defer close(pollDone)