Commit 0ac05e32 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 527532fc
...@@ -22,6 +22,8 @@ package demo ...@@ -22,6 +22,8 @@ package demo
import ( import (
"bytes" "bytes"
"context" "context"
"fmt"
"os"
"regexp" "regexp"
"testing" "testing"
...@@ -81,10 +83,10 @@ func withDemoStorage(t *testing.T, f func(t *testing.T, dsrv *Storage/*XXX -> Sr ...@@ -81,10 +83,10 @@ func withDemoStorage(t *testing.T, f func(t *testing.T, dsrv *Storage/*XXX -> Sr
defer os.RemoveAll(work) defer os.RemoveAll(work)
test1 := func(δstart zodb.Tid, zdumpBase, zdumpδ string) { test1 := func(δstart zodb.Tid, zdumpBase, zdumpδ string) {
t.Helper() t.Helper()
t.Run(fmt.Sprintf("δstart=%s", δstart), func(t *testinf,T) { t.Run(fmt.Sprintf("δstart=%s", δstart), func(t *testing.T) {
t.Helper() t.Helper()
X := xtesting.FatalIf(t) X := xtesting.FatalIf(t)
work1 := filepath.Join(work, δstart.String()) work1 := work + "/" + δstart.String()
err := os.Mkdir(work1, 0x777); X(err) err := os.Mkdir(work1, 0x777); X(err)
_, err = xtesting.ZPyRestore(work1+"/base.fs", zdumpBase); X(err) _, err = xtesting.ZPyRestore(work1+"/base.fs", zdumpBase); X(err)
...@@ -97,8 +99,8 @@ func withDemoStorage(t *testing.T, f func(t *testing.T, dsrv *Storage/*XXX -> Sr ...@@ -97,8 +99,8 @@ func withDemoStorage(t *testing.T, f func(t *testing.T, dsrv *Storage/*XXX -> Sr
}) })
} }
for i := 0; i < len(txnv); i++ { for i := 0; i < len(txnv); i++ {
δstart = txnv[i] δtail := txnv[i]
test1(δstart.tid, zdump[:δstart.pos], zdump[δstart.pos:]) test1(δtail.tid, zdump[:δtail.pos], zdump[δtail.pos:])
} }
test1(zodb.TidMax, zdump, "") test1(zodb.TidMax, zdump, "")
} }
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment