mirror of
https://github.com/restic/restic.git
synced 2026-08-06 13:43:18 +00:00
Each time a local backend is created, the local backend also creates all shard subdirectories. For the integration tests this has the downside that this results in ~120 (number of test) * 256 (number of directories) = 30k directories that are created unnecessarily. This significantly slows down test execution and cleanup.
76 lines
2.4 KiB
Go
76 lines
2.4 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/restic/restic/internal/global"
|
|
"github.com/restic/restic/internal/repository"
|
|
"github.com/restic/restic/internal/restic"
|
|
rtest "github.com/restic/restic/internal/test"
|
|
)
|
|
|
|
func testRunInit(t testing.TB, gopts global.Options) {
|
|
repository.TestUseLowSecurityKDFParameters(t)
|
|
restic.TestDisableCheckPolynomial(t)
|
|
repository.TestSetLockTimeout(t, 0)
|
|
|
|
err := withTermStatus(t, gopts, func(ctx context.Context, gopts global.Options) error {
|
|
return runInit(ctx, InitOptions{}, gopts, nil, gopts.Term)
|
|
})
|
|
rtest.OK(t, err)
|
|
t.Logf("repository initialized at %v", gopts.Repo)
|
|
|
|
// create temporary junk files to verify that restic does not trip over them
|
|
for _, path := range []string{"index", "snapshots", "keys", "locks", filepath.Join("data", "00")} {
|
|
rtest.OK(t, os.MkdirAll(filepath.Join(gopts.Repo, path), 0700))
|
|
rtest.OK(t, os.WriteFile(filepath.Join(gopts.Repo, path, "tmp12345"), []byte("junk file"), 0o600))
|
|
}
|
|
}
|
|
|
|
func TestInitCopyChunkerParams(t *testing.T) {
|
|
env, cleanup := withTestEnvironment(t)
|
|
defer cleanup()
|
|
env2, cleanup2 := withTestEnvironment(t)
|
|
defer cleanup2()
|
|
|
|
testRunInit(t, env2.gopts)
|
|
|
|
initOpts := InitOptions{
|
|
SecondaryRepoOptions: global.SecondaryRepoOptions{
|
|
Repo: env2.gopts.Repo,
|
|
Password: env2.gopts.Password,
|
|
},
|
|
}
|
|
err := withTermStatus(t, env.gopts, func(ctx context.Context, gopts global.Options) error {
|
|
return runInit(ctx, initOpts, gopts, nil, gopts.Term)
|
|
})
|
|
rtest.Assert(t, err != nil, "expected invalid init options to fail")
|
|
|
|
initOpts.CopyChunkerParameters = true
|
|
err = withTermStatus(t, env.gopts, func(ctx context.Context, gopts global.Options) error {
|
|
return runInit(ctx, initOpts, gopts, nil, gopts.Term)
|
|
})
|
|
rtest.OK(t, err)
|
|
|
|
var repo *repository.Repository
|
|
err = withTermStatus(t, env.gopts, func(ctx context.Context, gopts global.Options) error {
|
|
repo, err = global.OpenRepository(ctx, gopts, restic.NewNoopPrinter())
|
|
return err
|
|
})
|
|
rtest.OK(t, err)
|
|
|
|
var otherRepo *repository.Repository
|
|
err = withTermStatus(t, env2.gopts, func(ctx context.Context, gopts global.Options) error {
|
|
otherRepo, err = global.OpenRepository(ctx, gopts, restic.NewNoopPrinter())
|
|
return err
|
|
})
|
|
rtest.OK(t, err)
|
|
|
|
rtest.Assert(t, repo.Config().ChunkerPolynomial == otherRepo.Config().ChunkerPolynomial,
|
|
"expected equal chunker polynomials, got %v expected %v", repo.Config().ChunkerPolynomial,
|
|
otherRepo.Config().ChunkerPolynomial)
|
|
}
|