fix: support close socket on windows.

Author: b4rtaz

examples/chat-api-client.js

@@ -6,7 +6,7 @@
 // 2. Run this script: `node examples/chat-api-client.js`
 
 const HOST = process.env.HOST ? process.env.HOST : '127.0.0.1';
-const PORT = process.env.PORT ? Number(process.env.PORT) : 5000;
+const PORT = process.env.PORT ? Number(process.env.PORT) : 9990;
 
 async function chat(messages, maxTokens) {
     const response = await fetch(`http://${HOST}:${PORT}/v1/chat/completions`, {

src/dllama-api.cpp

@@ -560,19 +560,15 @@ static void server(AppInferenceContext *context) {
             HttpRequest request = HttpRequest::read(clientSocket);
             printf("🔷 %s %s\n", request.getMethod().c_str(), request.path.c_str());
             Router::resolve(request, routes);
-            #ifdef _WIN32
-            closesocket(clientSocket);
-            #else
-            close(clientSocket);
-            #endif
+            destroySocket(clientSocket);
         } catch (NnReadNetworkException& ex) {
             printf("Read socket error: %d %s\n", ex.code, ex.message);
         } catch (NnWriteNetworkException& ex) {
             printf("Write socket error: %d %s\n", ex.code, ex.message);
         }
     }
 
-    closeServerSocket(serverSocket);
+    destroySocket(serverSocket);
 }
 
 #ifdef _WIN32

src/nn/nn-network.cpp

@@ -220,7 +220,7 @@ int createServerSocket(int port) {
     return serverSocket;
 }
 
-void closeServerSocket(int serverSocket) {
+void destroySocket(int serverSocket) {
     shutdown(serverSocket, 2);
     #ifdef _WIN32
     closesocket(serverSocket);
@@ -316,12 +316,7 @@ std::unique_ptr<NnNetwork> NnNetwork::serve(int port) {
     delete[] hosts;
     delete[] ports;
 
-    shutdown(serverSocket, 2);
-    #ifdef _WIN32
-    closesocket(serverSocket);
-    #else
-    close(serverSocket);
-    #endif
+    destroySocket(serverSocket);
     printf("⭕ Network is initialized\n");
     return std::unique_ptr<NnNetwork>(new NnNetwork(nSockets, sockets));
 }
@@ -365,14 +360,8 @@ NnNetwork::NnNetwork(NnUint nSockets, int *sockets) {
 NnNetwork::~NnNetwork() {
     delete[] sentBytes;
     delete[] recvBytes;
-    for (NnUint i = 0; i < nSockets; i++) {
-        shutdown(sockets[i], 2);
-        #ifdef _WIN32
-        closesocket(sockets[i]);
-        #else
-        close(sockets[i]);
-        #endif
-    }
+    for (NnUint i = 0; i < nSockets; i++)
+        destroySocket(sockets[i]);
     delete[] sockets;
     printf("⭕ Network is closed\n");
 }

src/nn/nn-network.hpp

@@ -12,7 +12,7 @@ void setReuseAddr(int socket);
 void writeSocket(int socket, const void* data, NnSize size);
 void readSocket(int socket, void* data, NnSize size);
 int createServerSocket(int port);
-void closeServerSocket(int serverSocket);
+void destroySocket(int serverSocket);
 
 class NnReadNetworkException : public std::exception {
 public: