diff options
| author | Paul Buetow <paul@buetow.org> | 2021-10-24 12:59:08 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2021-10-24 12:59:08 +0300 |
| commit | 995c850d1f07f6221558d1c01924f2da6294f4ec (patch) | |
| tree | 80e5c86086ce7157e43a6fba08fb8fe9edae9707 /internal/io/fs/catfile.go | |
| parent | 1ff2e424cc99a979ceac461c28b03605c46a669f (diff) | |
Fix deadlock around aggregating data + server max concurrent file read limiter
Diffstat (limited to 'internal/io/fs/catfile.go')
| -rw-r--r-- | internal/io/fs/catfile.go | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/internal/io/fs/catfile.go b/internal/io/fs/catfile.go index 01c15ba..e4676f3 100644 --- a/internal/io/fs/catfile.go +++ b/internal/io/fs/catfile.go @@ -6,9 +6,7 @@ type CatFile struct { } // NewCatFile returns a new file catter. -func NewCatFile(filePath string, globID string, serverMessages chan<- string, - limiter chan struct{}) CatFile { - +func NewCatFile(filePath string, globID string, serverMessages chan<- string) CatFile { return CatFile{ readFile: readFile{ filePath: filePath, @@ -17,7 +15,6 @@ func NewCatFile(filePath string, globID string, serverMessages chan<- string, retry: false, canSkipLines: false, seekEOF: false, - limiter: limiter, }, } } |
