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:
authorJacob Vosmaer <jacob@gitlab.com>2020-11-21 20:02:40 +0300
committerJacob Vosmaer <jacob@gitlab.com>2020-11-21 20:02:40 +0300
commit28c3dc4a19deae13756804c4f14f8d916cbce057 (patch)
tree5d075db5d9a6f2ace2cd02691620a8961dd00b8c
parentc7a6ed3f96f8b6c3dfb536e7d3619e05edecd38e (diff)
Rename function
-rw-r--r--internal/gitaly/service/hook/pack_objects.go10
1 files changed, 3 insertions, 7 deletions
diff --git a/internal/gitaly/service/hook/pack_objects.go b/internal/gitaly/service/hook/pack_objects.go
index 8f5cdbc59..a1017ea1b 100644
--- a/internal/gitaly/service/hook/pack_objects.go
+++ b/internal/gitaly/service/hook/pack_objects.go
@@ -104,10 +104,6 @@ func (s *server) PackObjectsHook(stream gitalypb.HookService_PackObjectsHookServ
return e.err
}
-type WriterFunc func([]byte) (int, error)
-
-func (f WriterFunc) Write(p []byte) (int, error) { return f(p) }
-
type cache struct {
*blob.Bucket
cacheID string
@@ -241,7 +237,7 @@ func (e *entry) generateResponse(repoPath string, args []string, stdin []byte, s
return err
}
- return e.stdout.CloseWriter()
+ return e.stdout.FlushChunk()
}()
e.Lock()
@@ -261,7 +257,7 @@ type blobBuffer struct {
currentChunkSize int
}
-func (bb *blobBuffer) CloseWriter() error {
+func (bb *blobBuffer) FlushChunk() error {
bb.Lock()
defer bb.Unlock()
@@ -319,7 +315,7 @@ func (bb *blobBuffer) Write(p []byte) (int, error) {
bb.Unlock()
if bb.chunkIsFull() {
- return n, bb.CloseWriter()
+ return n, bb.FlushChunk()
}
return n, nil