diff options
author | Jacob Vosmaer <jacob@gitlab.com> | 2020-11-21 20:02:40 +0300 |
---|---|---|
committer | Jacob Vosmaer <jacob@gitlab.com> | 2020-11-21 20:02:40 +0300 |
commit | 28c3dc4a19deae13756804c4f14f8d916cbce057 (patch) | |
tree | 5d075db5d9a6f2ace2cd02691620a8961dd00b8c | |
parent | c7a6ed3f96f8b6c3dfb536e7d3619e05edecd38e (diff) |
Rename function
-rw-r--r-- | internal/gitaly/service/hook/pack_objects.go | 10 |
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 |