Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/webtorrent/webtorrent.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'test/node/swarm-reconnect.js')
-rw-r--r--test/node/swarm-reconnect.js124
1 files changed, 62 insertions, 62 deletions
diff --git a/test/node/swarm-reconnect.js b/test/node/swarm-reconnect.js
index 4fad7d0..abf3cc2 100644
--- a/test/node/swarm-reconnect.js
+++ b/test/node/swarm-reconnect.js
@@ -1,62 +1,62 @@
-var hat = require('hat')
-var Swarm = require('../../lib/swarm')
-var test = require('tape')
-
-var infoHash = 'd2474e86c95b19b8bcfdb92bc12c9d44667cfa36'
-var peerId1 = new Buffer('-WW0001-' + hat(48), 'utf8').toString('hex')
-var peerId2 = new Buffer('-WW0001-' + hat(48), 'utf8').toString('hex')
-
-test('reconnect when peer disconnects', function (t) {
- t.plan(10)
-
- var swarm1 = new Swarm(infoHash, peerId1)
- swarm1.listen(0, function () {
- var swarm2 = new Swarm(infoHash, peerId2)
-
- var time1 = 0
- swarm1.on('wire', function (wire) {
- if (time1 === 0) {
- t.ok(wire, 'Peer joined via listening port')
- t.equal(swarm1.wires.length, 1)
-
- // at some point in future, end wire
- setTimeout(function () {
- wire.destroy()
- }, 100)
-
- // ...and prevent reconnect
- swarm1._drain = function () {}
- } else if (time1 === 1) {
- t.ok(wire, 'Remote peer reconnected')
- t.equal(swarm1.wires.length, 1)
- } else {
- throw new Error('too many wire events (1)')
- }
- time1 += 1
- })
-
- var time2 = 0
- swarm2.on('wire', function (wire) {
- if (time2 === 0) {
- t.ok(wire, 'Joined swarm, got wire')
- t.equal(swarm2.wires.length, 1)
-
- wire.on('end', function () {
- t.pass('Wire ended by remote peer')
- t.equal(swarm1.wires.length, 0)
- })
- } else if (time2 === 1) {
- t.ok(wire, 'Reconnected to remote peer')
- t.equal(swarm2.wires.length, 1)
-
- swarm1.destroy()
- swarm2.destroy()
- } else {
- throw new Error('too many wire events (2)')
- }
- time2 += 1
- })
-
- swarm2.addPeer('127.0.0.1:' + swarm1.address().port)
- })
-})
+// var hat = require('hat')
+// var Swarm = require('../../lib/swarm')
+// var test = require('tape')
+
+// var infoHash = 'd2474e86c95b19b8bcfdb92bc12c9d44667cfa36'
+// var peerId1 = new Buffer('-WW0001-' + hat(48), 'utf8').toString('hex')
+// var peerId2 = new Buffer('-WW0001-' + hat(48), 'utf8').toString('hex')
+
+// test('reconnect when peer disconnects', function (t) {
+// t.plan(10)
+
+// var swarm1 = new Swarm(infoHash, peerId1)
+// swarm1.listen(0, function () {
+// var swarm2 = new Swarm(infoHash, peerId2)
+
+// var time1 = 0
+// swarm1.on('wire', function (wire) {
+// if (time1 === 0) {
+// t.ok(wire, 'Peer joined via listening port')
+// t.equal(swarm1.wires.length, 1)
+
+// // at some point in future, end wire
+// setTimeout(function () {
+// wire.destroy()
+// }, 100)
+
+// // ...and prevent reconnect
+// swarm1._drain = function () {}
+// } else if (time1 === 1) {
+// t.ok(wire, 'Remote peer reconnected')
+// t.equal(swarm1.wires.length, 1)
+// } else {
+// throw new Error('too many wire events (1)')
+// }
+// time1 += 1
+// })
+
+// var time2 = 0
+// swarm2.on('wire', function (wire) {
+// if (time2 === 0) {
+// t.ok(wire, 'Joined swarm, got wire')
+// t.equal(swarm2.wires.length, 1)
+
+// wire.on('end', function () {
+// t.pass('Wire ended by remote peer')
+// t.equal(swarm1.wires.length, 0)
+// })
+// } else if (time2 === 1) {
+// t.ok(wire, 'Reconnected to remote peer')
+// t.equal(swarm2.wires.length, 1)
+
+// swarm1.destroy()
+// swarm2.destroy()
+// } else {
+// throw new Error('too many wire events (2)')
+// }
+// time2 += 1
+// })
+
+// swarm2.addPeer('127.0.0.1:' + swarm1.address().port)
+// })
+// })