Add option to use TCP NODELAY

source/mysql/connection.d

@@ -513,7 +513,6 @@ package:
 	// so detect & prevent infinite recursion.
 	private bool isAutoPurging = false;
 
-
 	/// Called whenever mysql-native needs to send a command to the server
 	/// and be sure there aren't any pending results (which would prevent
 	/// a new command from being sent).
@@ -739,6 +738,16 @@ public:
 		resetPacket();
 	}
 
+	void tcpNoDelay(bool enabled)
+	{
+		_socket.tcpNoDelay(enabled);
+	}
+
+	bool tcpNoDelay()
+	{
+		return _socket.tcpNoDelay;
+	}
+
 	/++
 	Reconnects to the server using the same connection settings originally
 	used to create the `Connection`.

source/mysql/protocol/comms.d

@@ -1,4 +1,4 @@
-/++
+/++
 Internal - Low-level communications.
 
 Consider this module the main entry point for the low-level MySQL/MariaDB
@@ -45,7 +45,7 @@ package struct ProtocolPrepared
 	import std.datetime;
 	import std.variant;
 	import mysql.types;
-	
+
 	static ubyte[] makeBitmap(in Variant[] inParams)
 	{
 		size_t bml = (inParams.length+7)/8;
@@ -451,7 +451,7 @@ package struct ProtocolPrepared
 		Variant[] inParams, ParameterSpecialization[] psa)
 	{
 		conn.autoPurge();
-		
+
 		ubyte[] packet;
 		conn.resetPacket();
 
@@ -771,7 +771,7 @@ body
 	}
 
 	conn.autoPurge();
- 
+
 	conn.resetPacket();
 
 	ubyte[] header;
@@ -967,7 +967,7 @@ package(mysql) SvrCapFlags setClientFlags(SvrCapFlags serverCaps, SvrCapFlags ca
 	// didn't supply it
 	cCaps |= SvrCapFlags.PROTOCOL41;
 	cCaps |= SvrCapFlags.SECURE_CONNECTION;
-	
+
 	return cCaps;
 }
 
@@ -998,7 +998,7 @@ package(mysql) PreparedServerInfo performRegister(Connection conn, const(char[])
 	scope(failure) conn.kill();
 
 	PreparedServerInfo info;
-	
+
 	conn.sendCmd(CommandType.STMT_PREPARE, sql);
 	conn._fieldCount = 0;
 

source/mysql/protocol/sockets.d

@@ -1,6 +1,8 @@
-/// Internal - Phobos and vibe.d sockets.
+/// Internal - Phobos and vibe.d sockets.
 module mysql.protocol.sockets;
 
+import core.stdc.stdint;
+
 import std.exception;
 import std.socket;
 
@@ -45,6 +47,8 @@ interface MySQLSocket
 	void release();
 	bool isOwner();
 	bool amOwner();
+	void tcpNoDelay(bool enabled);
+	bool tcpNoDelay();
 }
 
 /// Wraps a Phobos socket with the common interface
@@ -100,6 +104,18 @@ class MySQLSocketPhobos : MySQLSocket
 	void release() { /+ Do nothing +/ }
 	bool isOwner() { return true; }
 	bool amOwner() { return true; }
+
+	void tcpNoDelay(bool enabled)
+	{
+		socket.setOption(SocketOptionLevel.TCP, SocketOption.TCP_NODELAY, cast(int32_t) enabled);
+	}
+
+	bool tcpNoDelay()
+	{
+		int32_t result = void;
+		socket.getOption(SocketOptionLevel.TCP, SocketOption.TCP_NODELAY, result);
+		return result != 0;
+	}
 }
 
 version(Have_vibe_core) {
@@ -156,5 +172,15 @@ version(Have_vibe_core) {
 			bool isOwner() { return true; }
 			bool amOwner() { return true; }
 		}
+
+		void tcpNoDelay(bool enabled)
+		{
+			socket.tcpNoDelay(enabled);
+		}
+
+		bool tcpNoDelay()
+		{
+			return socket.tcpNoDelay;
+		}
 	}
 }