From b60df56157ee1fd0bd4938799bac05a62fda91a1 Mon Sep 17 00:00:00 2001
From: lookshe <github@lookshe.org>
Date: Sat, 14 Mar 2015 20:45:20 +0100
Subject: initial commit from working version

---
 .../redis/examples/backpressure_drain.js           | 33 ++++++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 signaling-server/node_modules/socket.io/node_modules/redis/examples/backpressure_drain.js

(limited to 'signaling-server/node_modules/socket.io/node_modules/redis/examples/backpressure_drain.js')

diff --git a/signaling-server/node_modules/socket.io/node_modules/redis/examples/backpressure_drain.js b/signaling-server/node_modules/socket.io/node_modules/redis/examples/backpressure_drain.js
new file mode 100644
index 0000000..3488ef4
--- /dev/null
+++ b/signaling-server/node_modules/socket.io/node_modules/redis/examples/backpressure_drain.js
@@ -0,0 +1,33 @@
+var redis = require("../index"),
+    client = redis.createClient(null, null, {
+        command_queue_high_water: 5,
+        command_queue_low_water: 1
+    }),
+    remaining_ops = 100000, paused = false;
+
+function op() {
+    if (remaining_ops <= 0) {
+        console.error("Finished.");
+        process.exit(0);
+    }
+
+    remaining_ops--;
+    if (client.hset("test hash", "val " + remaining_ops, remaining_ops) === false) {
+        console.log("Pausing at " + remaining_ops);
+        paused = true;
+    } else {
+        process.nextTick(op);
+    }
+}
+
+client.on("drain", function () {
+    if (paused) {
+        console.log("Resuming at " + remaining_ops);
+        paused = false;
+        process.nextTick(op);
+    } else {
+        console.log("Got drain while not paused at " + remaining_ops);
+    }
+});
+
+op();
-- 
cgit v1.2.3