use fixed socket options

Author: mkalkbrenner

include/DMDUtil/DMD.h

@@ -19,6 +19,7 @@
 #include <winsock2.h>  // Windows byte-order functions
 #else
 #include <arpa/inet.h>  // Linux/macOS byte-order functions
+#include <netinet/tcp.h>
 #endif
 
 #include <atomic>

src/DMD.cpp

@@ -53,7 +53,18 @@ class DMDServerConnector
   static DMDServerConnector* Create(const char* pAddress, int port)
   {
     sockpp::tcp_connector* pConnector = new sockpp::tcp_connector({pAddress, (in_port_t)port});
-    return pConnector ? new DMDServerConnector(pConnector) : nullptr;
+    if (pConnector)
+    {
+      int flag = 1;
+      int mss = 1200;  // Conservative size
+      int bufsize = 65536;
+      pConnector->set_option(IPPROTO_TCP, TCP_NODELAY, &flag, sizeof(flag));
+      pConnector->set_option(IPPROTO_TCP, TCP_MAXSEG, &mss, sizeof(mss));
+      pConnector->set_option(SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize));
+      pConnector->set_option(SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize));
+      return new DMDServerConnector(pConnector);
+    }
+    return nullptr;
   }
 
   ssize_t Write(const void* buf, size_t size) { return m_pConnector->write_n(buf, size); }

src/dmdServer.cpp

@@ -2,6 +2,7 @@
 #include <winsock2.h>  // Windows byte-order functions
 #else
 #include <arpa/inet.h>  // Linux/macOS byte-order functions
+#include <netinet/tcp.h>
 #endif
 
 #include <algorithm>
@@ -367,6 +368,14 @@ int main(int argc, char* argv[])
     }
     else
     {
+      int flag = 1;
+      int mss = 1200;  // Conservative size
+      int bufsize = 65536;
+      sock.set_option(IPPROTO_TCP, TCP_NODELAY, &flag, sizeof(flag));
+      sock.set_option(IPPROTO_TCP, TCP_MAXSEG, &mss, sizeof(mss));
+      sock.set_option(SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize));
+      sock.set_option(SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize));
+
       threadMutex.lock();
       currentThreadId = ++threadId;
       threads.push_back(currentThreadId);