parent
077a81814f
commit
d9d18512ca
|
@ -376,7 +376,7 @@ func (h *BasicHost) background() {
|
|||
log.Errorf("error creating a signed peer record from the set of current addresses, err=%s", err)
|
||||
return
|
||||
}
|
||||
changeEvt.SignedPeerRecord = *sr
|
||||
changeEvt.SignedPeerRecord = sr
|
||||
|
||||
// persist the signed record to the peerstore
|
||||
if _, err := h.caBook.ConsumePeerRecord(sr, peerstore.PermanentAddrTTL); err != nil {
|
||||
|
|
|
@ -589,7 +589,7 @@ func TestAddrChangeImmediatelyIfAddressNonEmpty(t *testing.T) {
|
|||
// assert it's in the peerstore
|
||||
ev := h.Peerstore().(peerstore.CertifiedAddrBook).GetPeerRecord(h.ID())
|
||||
require.NotNil(t, ev)
|
||||
rc = peerRecordFromEnvelope(t, *ev)
|
||||
rc = peerRecordFromEnvelope(t, ev)
|
||||
require.Equal(t, taddrs, rc.Addrs)
|
||||
}
|
||||
|
||||
|
@ -678,7 +678,7 @@ func TestHostAddrChangeDetection(t *testing.T) {
|
|||
// assert it's in the peerstore
|
||||
ev := h.Peerstore().(peerstore.CertifiedAddrBook).GetPeerRecord(h.ID())
|
||||
require.NotNil(t, ev)
|
||||
rc = peerRecordFromEnvelope(t, *ev)
|
||||
rc = peerRecordFromEnvelope(t, ev)
|
||||
require.Equal(t, addrSets[i], rc.Addrs)
|
||||
}
|
||||
}
|
||||
|
@ -738,7 +738,7 @@ func updatedAddrEventsEqual(a, b event.EvtLocalAddressesUpdated) bool {
|
|||
updatedAddrsEqual(a.Removed, b.Removed)
|
||||
}
|
||||
|
||||
func peerRecordFromEnvelope(t *testing.T, ev record.Envelope) *peer.PeerRecord {
|
||||
func peerRecordFromEnvelope(t *testing.T, ev *record.Envelope) *peer.PeerRecord {
|
||||
t.Helper()
|
||||
rec, err := ev.Record()
|
||||
if err != nil {
|
||||
|
|
|
@ -204,7 +204,7 @@ func (ids *IDService) handleProtosChanged(evt event.EvtLocalProtocolsUpdated) {
|
|||
func (ids *IDService) handleLocalAddrsUpdated(evt event.EvtLocalAddressesUpdated) {
|
||||
ids.peerrecMu.Lock()
|
||||
rec := evt.SignedPeerRecord
|
||||
ids.peerrec = &rec
|
||||
ids.peerrec = rec
|
||||
ids.peerrecMu.Unlock()
|
||||
|
||||
log.Debug("triggering push based on updated local PeerRecord")
|
||||
|
|
|
@ -236,7 +236,7 @@ func generatePeerRecord(t *testing.T, h host.Host) {
|
|||
if err != nil {
|
||||
t.Fatalf("error generating peer record: %s", err)
|
||||
}
|
||||
evt := event.EvtLocalAddressesUpdated{SignedPeerRecord: *signed}
|
||||
evt := event.EvtLocalAddressesUpdated{SignedPeerRecord: signed}
|
||||
emitter, err := h.EventBus().Emitter(new(event.EvtLocalAddressesUpdated), eventbus.Stateful)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
|
Loading…
Reference in New Issue