mirror/kopia
1
0
Fork 0
mirror of https://github.com/kopia/kopia.git synced 2026-03-08 00:08:26 -05:00
Code Issues Packages Projects Releases Wiki Activity

test(general): Handle no space left errors in robustness tests (#3043)

Browse Source 
* Handle no space left errors in robustness tests

* fix lint error
This commit is contained in:
chaitalisg
2023-06-20 09:33:55 -07:00
committed by GitHub
parent 3eef67d2dc
commit d2ddda7114
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
tests/robustness/engine/action.go
View File

@@ -78,12 +78,14 @@ func (e *Engine) RandomAction(ctx context.Context, actionOpts ActionOpts) error
}
_, err := e.ExecAction(ctx, actionName, actionOpts[actionName])
err = e.checkErrRecovery(ctx, err, actionOpts)
err = e.CheckErrRecovery(ctx, err, actionOpts)
return err
}
func (e *Engine) checkErrRecovery(ctx context.Context, incomingErr error, actionOpts ActionOpts) (outgoingErr error) {
// CheckErrRecovery tries to recover from no space left error
// by deleting data directories.
func (e *Engine) CheckErrRecovery(ctx context.Context, incomingErr error, actionOpts ActionOpts) (outgoingErr error) {
outgoingErr = incomingErr
if incomingErr == nil {

4
tests/robustness/robustness_test/robustness_test.go
View File

@@ -35,12 +35,14 @@ func TestManySmallFiles(t *testing.T) {
ctx := testlogging.ContextWithLevel(t, testlogging.LevelInfo)
_, err := eng.ExecAction(ctx, engine.WriteRandomFilesActionKey, fileWriteOpts)
err = eng.CheckErrRecovery(ctx, err, engine.ActionOpts{})
require.NoError(t, err)
snapOut, err := eng.ExecAction(ctx, engine.SnapshotDirActionKey, nil)
require.NoError(t, err)
_, err = eng.ExecAction(ctx, engine.RestoreSnapshotActionKey, snapOut)
err = eng.CheckErrRecovery(ctx, err, engine.ActionOpts{})
require.NoError(t, err)
}
@@ -91,12 +93,14 @@ func TestManySmallFilesAcrossDirecoryTree(t *testing.T) {
ctx := testlogging.ContextWithLevel(t, testlogging.LevelInfo)
_, err := eng.ExecAction(ctx, engine.WriteRandomFilesActionKey, fileWriteOpts)
err = eng.CheckErrRecovery(ctx, err, engine.ActionOpts{})
require.NoError(t, err)
snapOut, err := eng.ExecAction(ctx, engine.SnapshotDirActionKey, nil)
require.NoError(t, err)
_, err = eng.ExecAction(ctx, engine.RestoreSnapshotActionKey, snapOut)
err = eng.CheckErrRecovery(ctx, err, engine.ActionOpts{})
require.NoError(t, err)
}