summaryrefslogtreecommitdiff
path: root/internal/command/uploadpack/gitalycall.go
diff options
context:
space:
mode:
authorPatrick Bajao <ebajao@gitlab.com>2022-05-04 04:55:58 +0000
committerPatrick Bajao <ebajao@gitlab.com>2022-05-04 04:55:58 +0000
commitd43b496296d97cdab5f7caa0895a3f9cda027410 (patch)
treeff0878b5a1117a2cd05608237d5c852b6adfb126 /internal/command/uploadpack/gitalycall.go
parent4828228c95cf9789614a04df06d3d55dda63b2ca (diff)
parentb2b31cee4a27cccd100a5f0aa546d5a515576ada (diff)
downloadgitlab-shell-d43b496296d97cdab5f7caa0895a3f9cda027410.tar.gz
Merge branch 'jv-always-use-sidechannel' into 'main'
Always use Gitaly sidechannel connections See merge request gitlab-org/gitlab-shell!567
Diffstat (limited to 'internal/command/uploadpack/gitalycall.go')
-rw-r--r--internal/command/uploadpack/gitalycall.go22
1 files changed, 3 insertions, 19 deletions
diff --git a/internal/command/uploadpack/gitalycall.go b/internal/command/uploadpack/gitalycall.go
index 96dd823..2ba5f1d 100644
--- a/internal/command/uploadpack/gitalycall.go
+++ b/internal/command/uploadpack/gitalycall.go
@@ -15,24 +15,7 @@ import (
func (c *Command) performGitalyCall(ctx context.Context, response *accessverifier.Response) error {
gc := handler.NewGitalyCommand(c.Config, string(commandargs.UploadPack), response)
- if response.Gitaly.UseSidechannel {
- request := &pb.SSHUploadPackWithSidechannelRequest{
- Repository: &response.Gitaly.Repo,
- GitProtocol: c.Args.Env.GitProtocolVersion,
- GitConfigOptions: response.GitConfigOptions,
- }
-
- return gc.RunGitalyCommand(ctx, func(ctx context.Context, conn *grpc.ClientConn) (int32, error) {
- ctx, cancel := gc.PrepareContext(ctx, request.Repository, c.Args.Env)
- defer cancel()
-
- registry := c.Config.GitalyClient.SidechannelRegistry
- rw := c.ReadWriter
- return client.UploadPackWithSidechannel(ctx, conn, registry, rw.In, rw.Out, rw.ErrOut, request)
- })
- }
-
- request := &pb.SSHUploadPackRequest{
+ request := &pb.SSHUploadPackWithSidechannelRequest{
Repository: &response.Gitaly.Repo,
GitProtocol: c.Args.Env.GitProtocolVersion,
GitConfigOptions: response.GitConfigOptions,
@@ -42,7 +25,8 @@ func (c *Command) performGitalyCall(ctx context.Context, response *accessverifie
ctx, cancel := gc.PrepareContext(ctx, request.Repository, c.Args.Env)
defer cancel()
+ registry := c.Config.GitalyClient.SidechannelRegistry
rw := c.ReadWriter
- return client.UploadPack(ctx, conn, rw.In, rw.Out, rw.ErrOut, request)
+ return client.UploadPackWithSidechannel(ctx, conn, registry, rw.In, rw.Out, rw.ErrOut, request)
})
}