From 0903bba205c63b59a0fb8fa43adda150162c7d74 Mon Sep 17 00:00:00 2001 From: Ruben Bridgewater Date: Sun, 22 Nov 2015 16:59:49 +0100 Subject: [PATCH] Remove old and not anymore needed connection breaker --- connection_breaker.js | 80 ------------------------------------------- 1 file changed, 80 deletions(-) delete mode 100644 connection_breaker.js diff --git a/connection_breaker.js b/connection_breaker.js deleted file mode 100644 index e036a2b173..0000000000 --- a/connection_breaker.js +++ /dev/null @@ -1,80 +0,0 @@ -'use strict'; - -var net = require('net'); - -var proxyPort = 6379; -var counter = 0; - -function breaker(conn) { - conn.end(); - conn.destroy(); -} - -var server = net.createServer(function(conn) { - counter++; - var proxyConn = net.createConnection({ - port: proxyPort - }); - conn.pipe(proxyConn); - proxyConn.pipe(conn); - proxyConn.on('end', function() { - conn.end(); - }); - conn.on('end', function() { - proxyConn.end(); - }); - conn.on('close', function() { - proxyConn.end(); - }); - proxyConn.on('close', function() { - conn.end(); - }); - proxyConn.on('error', function() { - conn.end(); - }); - conn.on('error', function() { - proxyConn.end(); - }); - - setTimeout(breaker.bind(null, conn), Math.floor(Math.random() * 2000)); -}); -server.listen(6479); - -var redis = require('./'); - -var client = redis.createClient(6479, 'localhost'); - -function iter() { - var k = "k" + Math.floor(Math.random() * 10); - var coinflip = Math.random() > 0.5; - if (coinflip) { - client.set(k, k, function(err, resp) { - if (!err && resp !== "OK") { - console.log("Unexpected set response " + resp); - } - }); - } else { - client.get(k, function(err, resp) { - if (!err) { - if (k !== resp) { - console.log("Key response mismatch: " + k + " " + resp); - } - } - }); - } -} - -function iters() { - for (var i = 0; i < 100; ++i) { - iter(); - } - setTimeout(iters, 10); -} - -client.on("connect", function () { - iters(); -}); - -client.on("error", function (err) { - console.log("Client error " + err); -});