From 8fc68cd56947aa6423f603c4e93e422e8285e262 Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Mon, 3 Aug 2015 13:11:00 -0700 Subject: [PATCH] small fix --- clientconn.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/clientconn.go b/clientconn.go index 5c20f71e..8d4e1f2f 100644 --- a/clientconn.go +++ b/clientconn.go @@ -241,16 +241,16 @@ func (cc *ClientConn) WaitForStateChange(timeout time.Duration, sourceState Conn return false } done := make(chan struct{}) - go func() { + go func(expired *bool) { select { case <-time.After(timeout-time.Since(start)): cc.mu.Lock() - expired = true + *expired = true cc.stateCV.Broadcast() cc.mu.Unlock() case <-done: } - }() + }(&expired) defer close(done) for sourceState == cc.state { cc.stateCV.Wait()