Comparing version 3.5.25 to 3.5.26
@@ -5,3 +5,3 @@ { | ||
"author": "mranney@uber.com", | ||
"version": "3.5.25", | ||
"version": "3.5.26", | ||
"scripts": { | ||
@@ -8,0 +8,0 @@ "lint": "jshint .", |
@@ -235,3 +235,3 @@ // Copyright (c) 2015 Uber Technologies, Inc. | ||
var conn = self.connections[i]; | ||
conn.operations.setMaxTombstoneTTL(ttl); | ||
conn.ops.setMaxTombstoneTTL(ttl); | ||
} | ||
@@ -238,0 +238,0 @@ }; |
@@ -109,2 +109,32 @@ // Copyright (c) 2015 Uber Technologies, Inc. | ||
allocCluster.test('peer can setMaxTombstoneTTL', { | ||
numPeers: 2 | ||
}, function t(cluster, assert) { | ||
var server = cluster.channels[0]; | ||
var client = cluster.channels[1]; | ||
var serverHost = cluster.hosts[0]; | ||
server.makeSubChannel({ | ||
serviceName: 'server' | ||
}); | ||
var subClient = client.makeSubChannel({ | ||
serviceName: 'server', | ||
peers: [server.hostPort] | ||
}); | ||
var peer = subClient.peers.get(serverHost); | ||
var socket = peer.makeOutSocket(); | ||
var conn = peer.makeOutConnection(socket); | ||
peer.addConnection(conn); | ||
assert.doesNotThrow(function noThrow() { | ||
peer.setMaxTombstoneTTL(400); | ||
}); | ||
client.close(); | ||
server.close(); | ||
assert.end(); | ||
}); | ||
allocCluster.test('peer close should not leak connections', { | ||
@@ -111,0 +141,0 @@ numPeers: 2 |
1359558
35832