diff --git a/.gx/lastpubver b/.gx/lastpubver index 83815252..63298094 100644 --- a/.gx/lastpubver +++ b/.gx/lastpubver @@ -1 +1 @@ -1.6.18: QmaijwHnbD4SabGA8C2fN9gchptLvRe2RxqTU5XkjAGBw5 +1.7.0: QmSx9mhEnKWDkgBYaEY6MZFFajUtiQJ8bipSZhzPuALSPv diff --git a/.travis.yml b/.travis.yml index 448d6904..96b2d5fa 100644 --- a/.travis.yml +++ b/.travis.yml @@ -6,7 +6,7 @@ os: language: go go: - - 1.7 + - 1.8 install: true diff --git a/package.json b/package.json index b39bfa99..973593b8 100644 --- a/package.json +++ b/package.json @@ -69,9 +69,9 @@ }, { "author": "whyrusleeping", - "hash": "Qma887khroMXGLJuHLYqqDZXHivAfFPxd2hQ8Z5kucMWTM", + "hash": "QmVNPgPmEG4QKaDKkxMPKY34Z53n8efzv1sEh4NTsdhto7", "name": "go-peerstream", - "version": "1.6.2" + "version": "1.7.0" }, { "author": "whyrusleeping", @@ -81,9 +81,9 @@ }, { "author": "whyrusleeping", - "hash": "QmaDBnCnmwPdqWGCJRLnmkfXRTEHp5rt3248Bwk4A7fLvt", + "hash": "QmPqPjFBqpx5AEfWYDJqt8w8YhRgPn7jw52omCKrYue4B6", "name": "go-libp2p-conn", - "version": "1.6.4" + "version": "1.6.5" }, { "author": "whyrusleeping", @@ -117,9 +117,9 @@ }, { "author": "whyrusleeping", - "hash": "QmR1fAHJvEyYFdEGn5jVmU4NL5kNSVJ48cduXB2whWbJq2", + "hash": "Qmcx4KoZ91XS6izLjdkujAMAunAS1YuTgfgASgYaZF5GkR", "name": "go-addr-util", - "version": "1.1.7" + "version": "1.2.0" }, { "hash": "QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52", @@ -174,6 +174,6 @@ "license": "MIT", "name": "go-libp2p-swarm", "releaseCmd": "git commit -a -m \"gx publish $VERSION\"", - "version": "1.6.18" + "version": "1.7.0" } diff --git a/swarm_notif_test.go b/swarm_notif_test.go index d9e9df62..8ebcccb9 100644 --- a/swarm_notif_test.go +++ b/swarm_notif_test.go @@ -17,8 +17,10 @@ func streamsSame(a, b inet.Stream) bool { } func TestNotifications(t *testing.T) { + const swarmSize = 5 + ctx := context.Background() - swarms := makeSwarms(ctx, t, 5) + swarms := makeSwarms(ctx, t, swarmSize) defer func() { for _, s := range swarms { s.Close() @@ -30,7 +32,7 @@ func TestNotifications(t *testing.T) { // signup notifs notifiees := make([]*netNotifiee, len(swarms)) for i, swarm := range swarms { - n := newNetNotifiee() + n := newNetNotifiee(swarmSize) swarm.Notify(n) notifiees[i] = n } @@ -184,14 +186,14 @@ type netNotifiee struct { closedStream chan inet.Stream } -func newNetNotifiee() *netNotifiee { +func newNetNotifiee(buffer int) *netNotifiee { return &netNotifiee{ - listen: make(chan ma.Multiaddr), - listenClose: make(chan ma.Multiaddr), - connected: make(chan inet.Conn), - disconnected: make(chan inet.Conn), - openedStream: make(chan inet.Stream), - closedStream: make(chan inet.Stream), + listen: make(chan ma.Multiaddr, buffer), + listenClose: make(chan ma.Multiaddr, buffer), + connected: make(chan inet.Conn, buffer), + disconnected: make(chan inet.Conn, buffer), + openedStream: make(chan inet.Stream, buffer), + closedStream: make(chan inet.Stream, buffer), } }