From 4c3fffa0976b7af72439780678ab3f0be747df70 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Sat, 19 Mar 2016 17:39:56 +1100 Subject: [PATCH] Fix locks on Reader.SetReadahead --- reader.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/reader.go b/reader.go index 4689bc64..1b3815f3 100644 --- a/reader.go +++ b/reader.go @@ -34,8 +34,11 @@ func (r *Reader) SetResponsive() { // prioritized in preparation for further reads. func (r *Reader) SetReadahead(readahead int64) { r.mu.Lock() - defer r.mu.Unlock() r.readahead = readahead + r.mu.Unlock() + r.t.cl.mu.Lock() + defer r.t.cl.mu.Unlock() + r.tickleClient() } func (r *Reader) readable(off int64) (ret bool) { -- 2.48.1