diff options
| author | sangtran <tranquangsang12.7@gmail.com> | 2026-09-12 16:35:06 +0700 |
|---|---|---|
| committer | sangtran <tranquangsang12.7@gmail.com> | 2026-09-12 16:35:06 +0700 |
| commit | 50139c994e539f2f902fc0c06ab29ee93c1bc03c (patch) | |
| tree | 7e355de76444c4eb02a178018dcc4d7ab258c466 /state | |
| parent | a7cb942d8b03e325b70ac95238d24939939a4c5a (diff) | |
| signature | Verified sangtran <tranquangsang12.7@gmail.com> Key: 8DD79823D235E1BB ultimate trust | |
| download | flux-main.tar.gz flux-main.zip | |
Diffstat (limited to 'state')
| -rw-r--r-- | state/pebble_backend.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/state/pebble_backend.go b/state/pebble_backend.go index f1aae0c..e8efc3a 100644 --- a/state/pebble_backend.go +++ b/state/pebble_backend.go | |||
| @@ -140,7 +140,7 @@ func (p *PebbleStateBackend) Snapshot(checkpointID uint64, targetDir string) err | |||
| 140 | // get parent dir | 140 | // get parent dir |
| 141 | parentDir := filepath.Dir(targetDir) | 141 | parentDir := filepath.Dir(targetDir) |
| 142 | 142 | ||
| 143 | if err := os.MkdirAll(parentDir, 0o755); err != nil { | 143 | if err := os.MkdirAll(parentDir, 00755); err != nil { |
| 144 | return err | 144 | return err |
| 145 | } | 145 | } |
| 146 | 146 | ||
| @@ -156,7 +156,7 @@ func (p *PebbleStateBackend) Snapshot(checkpointID uint64, targetDir string) err | |||
| 156 | } | 156 | } |
| 157 | }() | 157 | }() |
| 158 | 158 | ||
| 159 | if err := p.db.Checkpoint(tmpDir); err != nil { | 159 | if err := p.db.Checkpoint(tmpDir, pebble.WithFlushedWAL()); err != nil { |
| 160 | return fmt.Errorf("pebble checkpoint failed for ID %d: %w", checkpointID, err) | 160 | return fmt.Errorf("pebble checkpoint failed for ID %d: %w", checkpointID, err) |
| 161 | } | 161 | } |
| 162 | 162 | ||