REMOVE MEMORY LEAK

Author: Sharkbyteprojects

Dockerfile

@@ -0,0 +1,22 @@
+FROM alpine:3.14
+
+WORKDIR /app
+
+RUN apk add --no-cache cmake build-base make
+
+COPY libuv libuv
+COPY libUvTest libUvTest
+COPY CMakeLists.txt .
+
+RUN mkdir /server
+RUN cmake -S . -B /server -G "Unix Makefiles"
+RUN cmake --build /server
+
+WORKDIR /server/libUvTest
+
+RUN rm -rf /app
+RUN apk del cmake build-base make
+
+EXPOSE 8000
+
+CMD ["./libUvTest"]

libUvTest/libUvTest.c

@@ -15,7 +15,6 @@ static void on_close(uv_handle_t* handle) {
 
 static void after_write(uv_write_t* req, int status) {
 	write_req_t* wr = (write_req_t*)req;
-
 	if (wr->buf.base != NULL)
 		free(wr->buf.base);
 	free(wr);
@@ -57,7 +56,8 @@ static void after_read(uv_stream_t* handle,
 
 	if (nread < 0) {
 		/*assert(nread == UV_EOF);*/
-		fprintf(stderr, "err: %s\n", uv_strerror(nread));
+		if (nread != UV_EOF)
+			fprintf(stderr, "err: %s\n", uv_strerror(nread));
 
 		req = (uv_shutdown_t*)malloc(sizeof(*req));
 		assert(req != NULL);
@@ -79,6 +79,7 @@ static void after_read(uv_stream_t* handle,
 			send[nread - 1 - s] = buf->base[s];
 		}
 		send[nread] = 0;
+		free(buf->base);
 	}
 	//END OF REVERSE
 

tcpTest.node.js

@@ -0,0 +1,43 @@
+const NumberOfSockets = 2000;
+// Include Nodejs' net module.
+const { Socket } = require('dgram');
+const Net = require('net');
+// The port number and hostname of the server.
+const port = 8000;
+const host = 'localhost';
+
+for(let x = 0;x < NumberOfSockets;x++){
+    // Create a new TCP client.
+    const client = new Net.Socket();
+    // Send a connection request to the server.
+    client.connect({ port: port, host: host }, () => {
+        // If there is no error, the server has accepted the request and created a new 
+        // socket dedicated to us.
+        console.log('TCP connection established with the server.');
+
+        // The client can now send data to the server by writing to its socket.
+        let ax = 0;
+        let i = setInterval(()=>{
+            if(ax % 2 == 0)
+                client.write('Hello, server');
+            else
+                client.write(`|Random Number: ${Math.round(Math.random() * 100)}|`.split("").reverse().join(""));
+            // Request an end to the connection after the data has been received.
+            if(++ax > 20) {
+                clearInterval(i);
+                client.end();
+            }
+        }, 100);
+    });
+
+    // The client can also receive data from the server by reading from its socket.
+    client.on('data', function(chunk) {
+        console.log(`Data received from the server: "${chunk.toString()}"`);
+
+
+    });
+
+    client.on('end', function() {
+        console.log('Requested an end to the TCP connection');
+    });
+}