Improve TCP/IP responsiveness.

Eris/BaseConnection.cpp

@@ -76,7 +76,12 @@ int BaseConnection::connect(const std::string & host, short port)
         StreamSocket::Callbacks callbacks;
         callbacks.dispatch = [&] {this->dispatch();};
         callbacks.stateChanged =
-                [&](StreamSocket::Status state) {this->stateChanged(state);};
+                [&](StreamSocket::Status state) {
+            if (state == StreamSocket::NEGOTIATE) {
+                //Turn off Nagle's algorithm to increase responsiveness.
+                ((ResolvableAsioStreamSocket<ip::tcp>*)_socket.get())->getAsioSocket().set_option(ip::tcp::no_delay(true));
+            }
+            this->stateChanged(state);};
         auto socket = new ResolvableAsioStreamSocket<ip::tcp>(_io_service, _clientName,
                 _bridge, callbacks);
         _socket.reset(socket);

Eris/StreamSocket.h

@@ -159,6 +159,7 @@ class AsioStreamSocket: public StreamSocket
     virtual ~AsioStreamSocket();
     void connect(const typename ProtocolT::endpoint& endpoint);
     virtual void write();
+    typename ProtocolT::socket& getAsioSocket();
 protected:
     typename ProtocolT::socket m_socket;
     virtual void negotiate_read();

Eris/StreamSocket_impl.h

@@ -62,6 +62,12 @@ AsioStreamSocket<ProtocolT>::~AsioStreamSocket()
     }
 }
 
+template<typename ProtocolT>
+typename ProtocolT::socket& AsioStreamSocket<ProtocolT>::getAsioSocket()
+{
+    return m_socket;
+}
+
 template<typename ProtocolT>
 ResolvableAsioStreamSocket<ProtocolT>::ResolvableAsioStreamSocket(
         boost::asio::io_service& io_service, const std::string& client_name,