Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitaly.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPavlo Strokov <pstrokov@gitlab.com>2021-10-25 17:00:20 +0300
committerPavlo Strokov <pstrokov@gitlab.com>2021-10-25 17:00:20 +0300
commita6633baf092115fbc1fa0cd99d5b62fc9a1d37a6 (patch)
tree10e0ae752e6ece320afcf5bacfe57c50457ca347
parent54837cd5cb3b5ab8f35dfa447bd488fc78bbd76b (diff)
parent77238fa64baa8c05a41db9d51d68db4af70967bf (diff)
Merge branch 'ps-check-listen-error' into 'master'
test: Check error returned by gRCP server See merge request gitlab-org/gitaly!4000
-rw-r--r--internal/testhelper/testserver/gitaly.go11
1 files changed, 8 insertions, 3 deletions
diff --git a/internal/testhelper/testserver/gitaly.go b/internal/testhelper/testserver/gitaly.go
index 91b14df5e..9bac530bb 100644
--- a/internal/testhelper/testserver/gitaly.go
+++ b/internal/testhelper/testserver/gitaly.go
@@ -11,6 +11,7 @@ import (
"github.com/pelletier/go-toml"
"github.com/sirupsen/logrus"
+ "github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
gitalyauth "gitlab.com/gitlab-org/gitaly/v14/auth"
"gitlab.com/gitlab-org/gitaly/v14/client"
@@ -232,9 +233,11 @@ func runGitaly(t testing.TB, cfg config.Cfg, rubyServer *rubyserver.Server, regi
internalListener, err := net.Listen("unix", cfg.GitalyInternalSocketPath())
require.NoError(t, err)
- go internalServer.Serve(internalListener)
+ go func() {
+ assert.NoError(t, internalServer.Serve(internalListener), "failure to serve internal gRPC")
+ }()
- defer waitHealthy(t, cfg, "unix://"+internalListener.Addr().String())
+ waitHealthy(t, cfg, "unix://"+internalListener.Addr().String())
}
externalServer, err := serverFactory.CreateExternal(cfg.TLS.CertPath != "" && cfg.TLS.KeyPath != "")
@@ -264,7 +267,9 @@ func runGitaly(t testing.TB, cfg config.Cfg, rubyServer *rubyserver.Server, regi
addr = "unix://" + serverSocketPath
}
- go externalServer.Serve(listener)
+ go func() {
+ assert.NoError(t, externalServer.Serve(listener), "failure to serve external gRPC")
+ }()
waitHealthy(t, cfg, addr)