scottk/talos
1
0
Fork 0
mirror of https://github.com/lingble/talos.git synced 2025-11-01 21:17:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: clear connection refused errors after reset

Browse Source 
After node reboot (and gRPC API unavailability), gRPC stack might cache
connection refused errors for up to backoff timeout. Explicitly clear
such errors in reset tests before trying to read data from the node to
verify reset success.

Signed-off-by: Andrey Smirnov <smirnov.andrey@gmail.com>
This commit is contained in:
Andrey Smirnov
2021-01-29 16:42:13 +03:00
committed by talos-bot
parent c36e4a9355
commit 87ccf0eb21
3 changed files with 39 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/integration/api/reset.go
View File

@@ -125,6 +125,8 @@ func (suite *ResetSuite) TestResetNodeByNode() {
return base.IgnoreGRPCUnavailable(suite.Client.Reset(nodeCtx, true, true))
}, 10*time.Minute)
suite.ClearConnectionRefused(suite.ctx, node)
postReset, err := suite.hashKubeletCert(suite.ctx, node)
suite.Require().NoError(err)
@@ -156,6 +158,8 @@ func (suite *ResetSuite) TestResetNoGraceful() {
return base.IgnoreGRPCUnavailable(suite.Client.Reset(nodeCtx, false, true))
}, 5*time.Minute)
suite.ClearConnectionRefused(suite.ctx, node)
postReset, err := suite.hashKubeletCert(suite.ctx, node)
suite.Require().NoError(err)
@@ -195,6 +199,8 @@ func (suite *ResetSuite) TestResetWithSpecEphemeral() {
}))
}, 5*time.Minute)
suite.ClearConnectionRefused(suite.ctx, node)
postReset, err := suite.hashKubeletCert(suite.ctx, node)
suite.Require().NoError(err)
@@ -236,6 +242,8 @@ func (suite *ResetSuite) TestResetWithSpecState() {
}))
}, 5*time.Minute)
suite.ClearConnectionRefused(suite.ctx, node)
postReset, err := suite.hashKubeletCert(suite.ctx, node)
suite.Require().NoError(err)