logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-04 05:43:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert noisy newline changes

Browse Source
This commit is contained in:
Ian Davis 2021-07-19 13:32:00 +01:00 committed by vyzo
parent 079d8973a6
commit 37ebe34352
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
blacklist_test.go
View File

@ -17,6 +17,7 @@ func TestMapBlacklist(t *testing.T) {
if !b.Contains(p) { if !b.Contains(p) {
t.Fatal("peer not in the blacklist") t.Fatal("peer not in the blacklist")
} }
} }
func TestTimeCachedBlacklist(t *testing.T) { func TestTimeCachedBlacklist(t *testing.T) {

2
pubsub.go
View File

@ -493,8 +493,8 @@ func (p *PubSub) processLoop(ctx context.Context) {
case s := <-p.newPeerStream: case s := <-p.newPeerStream:
pid := s.Conn().RemotePeer() pid := s.Conn().RemotePeer()
ch, ok := p.peers[pid]
ch, ok := p.peers[pid]
if !ok { if !ok {
log.Warn("new stream for unknown peer: ", pid) log.Warn("new stream for unknown peer: ", pid)
s.Reset() s.Reset()