Commit be3e9404 authored by vyzo's avatar vyzo

rename dialWorker to startDialWorker

parent 17bc04b6
...@@ -121,7 +121,7 @@ func NewSwarm(ctx context.Context, local peer.ID, peers peerstore.Peerstore, bwc ...@@ -121,7 +121,7 @@ func NewSwarm(ctx context.Context, local peer.ID, peers peerstore.Peerstore, bwc
} }
} }
s.dsync = newDialSync(s.dialWorker) s.dsync = newDialSync(s.startDialWorker)
s.limiter = newDialLimiter(s.dialAddr, s.IsFdConsumingAddr) s.limiter = newDialLimiter(s.dialAddr, s.IsFdConsumingAddr)
s.proc = goprocessctx.WithContext(ctx) s.proc = goprocessctx.WithContext(ctx)
s.ctx = goprocessctx.OnClosingContext(s.proc) s.ctx = goprocessctx.OnClosingContext(s.proc)
......
...@@ -295,8 +295,8 @@ type dialResponse struct { ...@@ -295,8 +295,8 @@ type dialResponse struct {
err error err error
} }
// dialWorker is an active dial goroutine that synchronizes and executes concurrent dials // startDialWorker starts an active dial goroutine that synchronizes and executes concurrent dials
func (s *Swarm) dialWorker(ctx context.Context, p peer.ID, reqch <-chan dialRequest) error { func (s *Swarm) startDialWorker(ctx context.Context, p peer.ID, reqch <-chan dialRequest) error {
if p == s.local { if p == s.local {
return ErrDialToSelf return ErrDialToSelf
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment