Format
continuous-integration/drone/pr Build is pending
Details
continuous-integration/drone/pr Build is pending
Details
This commit is contained in:
parent
048effc91a
commit
fb164b104b
|
@ -259,7 +259,7 @@ func (cr *contactRetry) run() {
|
||||||
cr.addConnection(server, connections.DISCONNECTED, serverConn, lastSeen)
|
cr.addConnection(server, connections.DISCONNECTED, serverConn, lastSeen)
|
||||||
}
|
}
|
||||||
// this was an authorized event, and so we store this peer.
|
// this was an authorized event, and so we store this peer.
|
||||||
log.Debugf("authorizing id: %v", id);
|
log.Debugf("authorizing id: %v", id)
|
||||||
cr.authorizedPeers.Store(id, true)
|
cr.authorizedPeers.Store(id, true)
|
||||||
if c, ok := cr.connections.Load(id); ok {
|
if c, ok := cr.connections.Load(id); ok {
|
||||||
contact := c.(*contact)
|
contact := c.(*contact)
|
||||||
|
|
|
@ -36,10 +36,10 @@ func TestContactRetryQueue(t *testing.T) {
|
||||||
for {
|
for {
|
||||||
if pinf, exists := cr.connections.Load(testOnion); exists {
|
if pinf, exists := cr.connections.Load(testOnion); exists {
|
||||||
if pinf.(*contact).queued {
|
if pinf.(*contact).queued {
|
||||||
if _,exists := cr.authorizedPeers.Load(testOnion); exists {
|
if _, exists := cr.authorizedPeers.Load(testOnion); exists {
|
||||||
t.Logf("authorized");
|
t.Logf("authorized")
|
||||||
break;
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue