Added set options function for sockets

include/ur_modern_driver/tcp_socket.h

@@ -25,6 +25,7 @@ protected:
   {
     return false;
   }
+  virtual void setOptions(int socket_fd);
   
   
   bool setup(std::string &host, int port);

include/ur_modern_driver/ur/server.h

@@ -20,6 +20,8 @@ protected:
   {
     return ::bind(socket_fd, address, address_len) == 0;
   }
+  virtual void setOptions(int socket_fd);
+
 
 public:
   URServer(int port);

include/ur_modern_driver/ur/stream.h

@@ -32,7 +32,7 @@ public:
   }
   void disconnect()
   {
-    LOG_INFO("Disconnecting");
+    LOG_INFO("Disconnecting from %s:%d", host_.c_str(), port_);
     TCPSocket::close();
   }
 

src/tcp_socket.cpp

@@ -16,6 +16,12 @@ TCPSocket::~TCPSocket()
   close();
 }
 
+void TCPSocket::setOptions(int socket_fd)
+{
+  int flag = 1;
+  setsockopt(socket_fd, IPPROTO_TCP, TCP_NODELAY, &flag, sizeof(int));
+}
+
 bool TCPSocket::setup(std::string &host, int port)
 {
   if(state_ == SocketState::Connected)
@@ -63,6 +69,7 @@ bool TCPSocket::setup(std::string &host, int port)
   }
   else
   {
+    setOptions(socket_fd_);
     state_ = SocketState::Connected;
     LOG_INFO("Connection established for %s:%d", host.c_str(), port);
   }

src/ur/server.cpp

@@ -9,6 +9,14 @@ URServer::URServer(int port)
 {
 }
 
+void URServer::setOptions(int socket_fd)
+{
+  TCPSocket::setOptions(socket_fd);
+
+  int flag = 1;
+  setsockopt(socket_fd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(int));
+}
+
 std::string URServer::getIP()
 {
   char buf[128];