mirrors/talos
1
0
Fork 0
mirror of https://github.com/siderolabs/talos.git synced 2026-05-05 20:36:18 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(ci): zfs test

Browse Source 
Expect the zvol file to be present eventually.

Signed-off-by: Noel Georgi <git@frezbo.dev>
This commit is contained in:
Noel Georgi 2026-05-01 17:33:04 +05:30
parent 14abe51400
commit 4e5ff8fa21
No known key found for this signature in database
GPG Key ID: 21A9F444075C9E36
1 changed files with 27 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
internal/integration/api/extensions_qemu.go
View File

@ -469,7 +469,9 @@ func (suite *ExtensionsSuiteQEMU) TestExtensionsZFS() {
}
}()
suite.Require().True(suite.checkZFSPoolMounted(node), "expected zfs pool to be mounted")
suite.EventuallyWithT(func(t *assert.CollectT) {
suite.checkZFSPoolMounted(t, node)
}, 2*time.Minute, time.Second, "expected zfs pool to be mounted")
// now we want to reboot the node and make sure the pool is still mounted
suite.AssertRebooted(
@ -479,36 +481,48 @@ func (suite *ExtensionsSuiteQEMU) TestExtensionsZFS() {
suite.CleanupFailedPods,
)
suite.Require().True(suite.checkZFSPoolMounted(node), "expected zfs pool to be mounted")
suite.EventuallyWithT(func(t *assert.CollectT) {
suite.checkZFSPoolMounted(t, node)
}, 30*time.Second, time.Second, "expected zfs pool to be mounted after reboot")
}
func (suite *ExtensionsSuiteQEMU) checkZFSPoolMounted(node string) bool {
func (suite *ExtensionsSuiteQEMU) checkZFSPoolMounted(t *assert.CollectT, node string) {
ctx := client.WithNode(suite.ctx, node)
stream, err := suite.Client.LS(ctx, &machineapi.ListRequest{
Root: "/dev/zvol/tank/vol",
Types: []machineapi.ListRequest_Type{machineapi.ListRequest_REGULAR},
Root: "/dev/zvol/tank/",
Types: []machineapi.ListRequest_Type{machineapi.ListRequest_SYMLINK},
})
if !assert.NoError(t, err, "LS /dev/zvol/tank/") {
return
}
suite.Require().NoError(err)
found := false
suite.Require().NoError(helpers.ReadGRPCStream(stream, func(info *machineapi.FileInfo, node string, multipleNodes bool) error {
suite.Require().Equal("/dev/zvol/tank/vol", info.Name, "expected /dev/zvol/tank/vol to exist")
suite.Require().Equal("zd0", info.Link, "expected /dev/zvol/tank/vol to be linked to zd0")
if !assert.NoError(t, helpers.ReadGRPCStream(stream, func(info *machineapi.FileInfo, node string, multipleNodes bool) error {
if info.Name == "/dev/zvol/tank/vol" && strings.HasPrefix(filepath.Base(info.Link), "zd") {
found = true
}
return nil
}))
}), "reading LS stream") {
return
}
assert.True(t, found, "expected /dev/zvol/tank/vol symlink pointing to a zd* device")
disks, err := safe.StateListAll[*block.Disk](ctx, suite.Client.COSI)
suite.Require().NoError(err)
if !assert.NoError(t, err, "StateListAll disks") {
return
}
for disk := range disks.All() {
if strings.HasPrefix(disk.TypedSpec().DevPath, "/dev/zd") {
return true
return
}
}
return false
assert.Fail(t, "no /dev/zd* disk found in block resources")
}
// TestExtensionsUtilLinuxTools verifies util-linux-tools are working.