Increase buffer size

Author: knizhnik

dtmd/include/limits.h

@@ -3,7 +3,7 @@
 
 #define MAX_TRANSACTIONS 4096
 
-#define BUFFER_SIZE (64 * 1024)
+#define BUFFER_SIZE (256 * 1024)
 #define LISTEN_QUEUE_SIZE 100
 #define MAX_STREAMS 4096
 

dtmd/src/server.c

@@ -128,6 +128,9 @@ bool server_start(server_t server) {
 	return true;
 }
 
+long sent_messages;
+long sent_bytes;
+
 static bool stream_flush(stream_t stream) {
 	int tosend = stream->output.ready;
 	if (tosend == 0) {
@@ -138,12 +141,14 @@ static bool stream_flush(stream_t stream) {
 	char *cursor = stream->output.data;
 	while (tosend > 0) {
 		// repeat sending until we send everything
-		int sent = send(stream->fd, cursor, tosend, 0);
+		int sent = send(stream->fd, cursor, tosend, 0);        
 		if (sent == -1) {
 			shout("failed to flush the stream\n");
 			stream->good = false;
 			return false;
 		}
+        sent_messages += 1;
+        sent_bytes += sent;
 		cursor += sent;
 		tosend -= sent;
 		assert(tosend >= 0);