increase refcount before dropping dialsLk initially

libp2p · Oct 29, 2016 · 511d7a8 · 511d7a8
1 parent 41d999e
commit 511d7a8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dial_sync.go b/dial_sync.go
@@ -36,7 +36,6 @@ type activeDial struct {
 }
 
 func (dr *activeDial) wait(ctx context.Context) (*Conn, error) {
-	dr.incref()
 	defer dr.decref()
 	select {
 	case <-dr.waitch:
@@ -97,6 +96,9 @@ func (ds *DialSync) getActiveDial(p peer.ID) *activeDial {
 		go actd.start(adctx)
 	}
 
+	// increase ref count before dropping dialsLk
+	actd.incref()
+
 	return actd
 }