File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -130,7 +130,9 @@ func (cm *ConnManager) unprotectedPeers(peers []peer.ID) []peer.ID {
130
130
func (cm * ConnManager ) Connected (n network.Network , c network.Conn ) {
131
131
logger .Tracef (
132
132
"Host %s connected to peer %s" , n .LocalPeer (), c .RemotePeer ())
133
- cm .connectHandler (c .RemotePeer ())
133
+ if cm .connectHandler != nil {
134
+ cm .connectHandler (c .RemotePeer ())
135
+ }
134
136
135
137
cm .Lock ()
136
138
defer cm .Unlock ()
@@ -169,7 +171,9 @@ func (cm *ConnManager) Disconnected(_ network.Network, c network.Conn) {
169
171
logger .Tracef ("Host %s disconnected from peer %s" , c .LocalPeer (), c .RemotePeer ())
170
172
171
173
cm .Unprotect (c .RemotePeer (), "" )
172
- cm .disconnectHandler (c .RemotePeer ())
174
+ if cm .disconnectHandler != nil {
175
+ cm .disconnectHandler (c .RemotePeer ())
176
+ }
173
177
}
174
178
175
179
// OpenedStream is called when a stream is opened
You can’t perform that action at this time.
0 commit comments