test: remove timeout/slow calls

Author: aminya

.vscode/settings.json

@@ -13,9 +13,7 @@
   },
   "mochaExplorer.parallel": true,
   "mochaExplorer.globImplementation": "vscode",
-  "mochaExplorer.nodeArgv": [
-    "--expose-gc"
-  ],
+  "mochaExplorer.nodeArgv": ["--expose-gc"],
   "mochaExplorer.debuggerConfig": "JS-Attach",
   "files.exclude": {
     "**/.DS_Store": true,

test/unit/compat/socket-router-test.js

@@ -72,7 +72,6 @@ if (process.env.INCLUDE_COMPAT_TESTS) {
       })
 
       it("should handle router-dealer message bursts", function (done) {
-        this.slow(150)
         // tests https://github.com/JustinTulloss/zeromq.node/issues/523
         // based on https://gist.github.com/messa/862638ab44ca65f712fe4d6ef79aeb67
 

test/unit/context-process-exit-test.ts

@@ -7,7 +7,6 @@ import {createProcess} from "./helpers"
 describe("context process exit", function () {
   describe("with default context", function () {
     it("should occur when sockets are closed", async function () {
-      this.slow(200)
       const {code} = await createProcess(() => {
         const socket1 = new zmq.Dealer()
         socket1.close()
@@ -19,7 +18,6 @@ describe("context process exit", function () {
     })
 
     it("should occur when sockets are not closed", async function () {
-      this.slow(200)
       const {code} = await createProcess(() => {
         const socket1 = new zmq.Dealer()
         const socket2 = new zmq.Router()
@@ -29,7 +27,6 @@ describe("context process exit", function () {
     })
 
     it("should not occur when sockets are open and polling", async function () {
-      this.slow(1000)
       const {code, isTimeout} = await createProcess(() => {
         const socket1 = new zmq.Dealer()
         socket1.connect("inproc://foo")
@@ -43,7 +40,6 @@ describe("context process exit", function () {
     })
 
     it("should produce warning when messages are queued with blocky", async function () {
-      this.slow(2000)
       const {stderr} = await createProcess(() => {
         zmq.context.blocky = true
         const socket1 = new zmq.Dealer({linger: 1000})
@@ -67,7 +63,6 @@ describe("context process exit", function () {
     })
 
     it("should produce warning when messages are queued without blocky", async function () {
-      this.slow(2000)
       const {stderr} = await createProcess(() => {
         zmq.context.blocky = false
         const socket1 = new zmq.Dealer({linger: 1000})
@@ -84,7 +79,6 @@ describe("context process exit", function () {
     })
 
     it("should not produce warning when messages are queued for a short time", async function () {
-      this.slow(1000)
       const {stderr} = await createProcess(() => {
         zmq.context.blocky = true
         const socket1 = new zmq.Dealer({linger: 50})
@@ -100,7 +94,6 @@ describe("context process exit", function () {
 
   describe("with custom context", function () {
     it("should occur when sockets are closed", async function () {
-      this.slow(200)
       const {code} = await createProcess(() => {
         const context = new zmq.Context()
         const socket1 = new zmq.Dealer({context})
@@ -113,7 +106,6 @@ describe("context process exit", function () {
     })
 
     it("should occur when sockets are closed and context is gced", async function () {
-      this.slow(200)
       const {code} = await createProcess(() => {
         function run() {
           const context = new zmq.Context()
@@ -131,7 +123,6 @@ describe("context process exit", function () {
     })
 
     it("should occur when sockets are not closed", async function () {
-      this.slow(200)
       const {code} = await createProcess(() => {
         const context = new zmq.Context()
         const socket1 = new zmq.Dealer({context})
@@ -142,7 +133,6 @@ describe("context process exit", function () {
     })
 
     it("should not occur when sockets are open and polling", async function () {
-      this.slow(1000)
       const {code, isTimeout} = await createProcess(() => {
         const context = new zmq.Context()
         const socket1 = new zmq.Dealer({context})

test/unit/context-thread-test.ts

@@ -5,9 +5,6 @@ import {assert} from "chai"
 import {createWorker} from "./helpers"
 
 describe("context in thread", function () {
-  this.slow(2000)
-  this.timeout(5000)
-
   beforeEach(function () {
     /* Node.js worker support introduced in version 10.5. */
     if (semver.satisfies(process.versions.node, "< 10.5")) {

test/unit/socket-close-test.ts

@@ -108,7 +108,6 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
 
       it("should release reference to context", async function () {
         const gc = getGcOrSkipTest(this)
-        this.slow(200)
 
         let weakRef: undefined | WeakRef<zmq.Context>
 
@@ -138,7 +137,7 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
     //     if (process.env.SKIP_GC_FINALIZER_TESTS) {
     //       this.skip()
     //     }
-    //     this.slow(200)
+    //
 
     //     let weakRef: undefined | WeakRef<zmq.Context>
     //     const task = async () => {

test/unit/socket-events-test.ts

@@ -54,7 +54,6 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
         })
 
         it("should receive connect events", async function () {
-          this.slow(250)
           const address = await uniqAddress(proto)
 
           const [event] = await Promise.all([

test/unit/socket-process-exit-test.ts

@@ -6,7 +6,6 @@ import {createProcess} from "./helpers"
 describe("socket process exit", function () {
   /* Reported: https://github.com/nodejs/node-addon-api/issues/591 */
   it.skip("should occur cleanly when sending in exit hook", async function () {
-    this.slow(200)
     const {code} = await createProcess(async () => {
       const sockA = new zmq.Pair()
       const sockB = new zmq.Pair()
@@ -24,7 +23,6 @@ describe("socket process exit", function () {
   })
 
   it("should occur cleanly when sending on unbound socket", async function () {
-    this.slow(200)
     const {code} = await createProcess(async () => {
       const sock = new zmq.Publisher()
       await sock.send("test")
@@ -34,7 +32,6 @@ describe("socket process exit", function () {
   })
 
   it("should not occur when sending and blocked on unbound socket", async function () {
-    this.slow(1000)
     const {code} = await createProcess(async () => {
       const sock = new zmq.Dealer()
       await sock.send("test")
@@ -44,7 +41,6 @@ describe("socket process exit", function () {
   })
 
   it("should occur cleanly on socket close when reading events", async function () {
-    this.slow(200)
     const {code} = await createProcess(() => {
       const sock = new zmq.Dealer()
 
@@ -63,7 +59,6 @@ describe("socket process exit", function () {
   })
 
   it("should not occur while reading events", async function () {
-    this.slow(1000)
     const {code} = await createProcess(async () => {
       const sock = new zmq.Dealer()
 

test/unit/socket-send-receive-test.ts

@@ -265,8 +265,6 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
       })
 
       it("should poll simultaneously", async function () {
-        this.timeout(5000)
-
         const sendReceiveA = async () => {
           const [msg1] = await Promise.all([
             sockA.receive(),
@@ -426,8 +424,6 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
       }
 
       it("should not starve event loop", async function () {
-        this.slow(250)
-
         sockA.sendHighWaterMark = 5000
         sockB.receiveHighWaterMark = 5000
 

test/unit/socket-thread-test.ts

@@ -6,9 +6,6 @@ import {createWorker, testProtos, uniqAddress} from "./helpers"
 
 for (const proto of testProtos("tcp", "ipc", "inproc")) {
   describe(`socket with ${proto} in thread`, function () {
-    this.slow(2000)
-    this.timeout(5000)
-
     beforeEach(function () {
       /* Node.js worker support introduced in version 10.5. */
       if (semver.satisfies(process.versions.node, "< 10.5")) {

test/unit/socket-zap-test.ts

@@ -167,8 +167,6 @@ for (const proto of testProtos("tcp", "ipc")) {
           this.skip()
         }
 
-        this.slow(250)
-
         sockA.plainServer = true
         sockB.curveServer = true