From c67354443cc19e92f4bea25265147c648c4850b6 Mon Sep 17 00:00:00 2001 From: Kamil Dziedzic Date: Sat, 14 Oct 2017 18:44:46 +0200 Subject: [PATCH] restore TimeoutChan --- src/go/mongolib/profiler/profiler.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/go/mongolib/profiler/profiler.go b/src/go/mongolib/profiler/profiler.go index 320aeb99..be03d4cb 100644 --- a/src/go/mongolib/profiler/profiler.go +++ b/src/go/mongolib/profiler/profiler.go @@ -18,6 +18,7 @@ var ( type Profiler interface { GetLastError() error QueriesChan() chan stats.Queries + TimeoutsChan() <-chan time.Time FlushQueries() Start() Stop() @@ -93,6 +94,15 @@ func (p *Profile) Stop() { } } +func (p *Profile) TimeoutsChan() <-chan time.Time { + p.lock.Lock() + defer p.lock.Unlock() + if p.timeoutsChan == nil { + p.timeoutsChan = make(chan time.Time) + } + return p.timeoutsChan +} + func (p *Profile) getData() { go p.getDocs() p.stopWaitGroup.Add(1)