cluster

Author: Hussein Nasser

20-streams/200-raw-request-stream.js

@@ -1,7 +1,7 @@
 const http = require("node:http");
 //request object is a writable stream
 const req = http.request("http://example.com",  { "method": "GET"});
-
+ 
 req.on("response", res => {
         //the data events implicity calls read for us
         //response object is a readeable stream

20-streams/202-raw-httpserver.js

@@ -4,7 +4,7 @@ const http = require("node:http");
 //run with default, send this request
 // head -c 10240000 /dev/zero | curl -X POST --data-binary http://192.168.7.179:8080
 //then run with the overriden hwm
-const server = http.createServer({"highWaterMark": 300_000} );
+const server = http.createServer({"highWaterMark": 200_000} );
 
 //const server = http.createServer( );
 

21-worker-threads/213-worker-thread-workdata.js

@@ -11,7 +11,7 @@ const WorkerThreads = require('node:worker_threads');;
     const MaxNumber = 100_000_000
     const os = require("os")
 
-    const threadCount = 16 //os.availableParallelism; //try to match the core count
+    const threadCount = 2 //os.availableParallelism; //try to match the core count
     //use os.availableParallelism
     //spread MaxNumber on threads 
     //each thread gets workSlice worth 

21-worker-threads/214-worker-thread-connection.js

@@ -10,8 +10,7 @@ if (WorkerThreads.isMainThread) {
 
   // Create a TCP server on the parent
   const server = net.createServer();  
-
-   // Listen on the port with SO_REUSEPORT
+ 
    server.listen({ port: PORT},
     () => {
       console.log(`parent process ${process.pid} is listening on port ${PORT}`);

22-child-process/220-child-process.js

@@ -18,13 +18,13 @@ const child_process = require('child_process');
     console.log("End parent initial phase")
     process.on("exit", ()=>console.log("Parent exit"))
   } else {
-    //child thread gets its own loop
+    //child Process gets its own loop
     setTimeout(()=> console.log("Child Timer"), 0)
-    console.log("Start Thread's initial phase")
+    console.log("Start Process's initial phase")
     console.log("I'm a worker process: " + process.pid)
 
     for (let i =0; i< 10000000000;i++);
-    console.log("End Thread's initial phase")
+    console.log("End Process's initial phase")
     process.on("exit", ()=>console.log("Child exit"))
 
    } 

22-child-process/221-child-process-ipc.js

@@ -27,18 +27,18 @@ const child_process = require('child_process');
     process.on("message", message => console.log(`Received message from parent '${message}'`))
 
     process.send("hey dad")
-    console.log("Start Thread's initial phase")
+    console.log("Start Process's initial phase")
     console.log("I'm a worker process: " + process.pid)
 
     for (let i =0; i< 100000000;i++);
-    console.log("End Thread's initial phase")
+    console.log("End Process's initial phase")
     process.on("exit", ()=>console.log("Child exit"))
 
     setTimeout(()=> {
       console.log("Child Timer")
       //exit process
       //once we exit process is free to leave
-      process.exit(0);
+      //process.exit(0);
     }, 3000)
 
 

22-child-process/225-cluster.js

@@ -13,7 +13,7 @@ const PORT = 3000;
 //the parent will call accept 
 //the parent then sends accepted connection to a worker based
 //round robin algorithm
-cluster.schedulingPolicy= cluster.SCHED_RR ;
+cluster.schedulingPolicy= cluster.SCHED_NONE ;
 
 
 // Check if the current process is the master process