From 8b90f79bac07eb58c0ff3ee452d9503e32d92a06 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Thu, 28 May 2009 01:47:48 +0200
Subject: [PATCH] Work in progress on optimizing the send() function calls, to
 use as few as possible. (Although, this does not enable that code).

---
 src/hubio.c | 62 ++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 61 insertions(+), 1 deletion(-)

diff --git a/src/hubio.c b/src/hubio.c
index 5a5be3e..e06462f 100644
--- a/src/hubio.c
+++ b/src/hubio.c
@@ -20,6 +20,10 @@
 #include "uhub.h"
 #include "hubio.h"
 
+#define SEND_CHUNKS 1
+
+/* FIXME: This should not be needed! */
+extern struct hub_info* g_hub;
 
 struct hub_recvq* hub_recvq_create()
 {
@@ -114,13 +118,14 @@ void hub_sendq_add(struct hub_sendq* q, struct adc_message* msg_)
 void hub_sendq_remove(struct hub_sendq* q, struct adc_message* msg)
 {
 	list_remove(q->queue, msg);
-	adc_msg_free(msg);
 	q->size  -= msg->length;
+	adc_msg_free(msg);
 	q->offset = 0;
 }
 
 int  hub_sendq_send(struct hub_sendq* q, hub_recvq_write w, void* data)
 {
+#ifdef SEND_CHUNKS
 	int ret = 0;
 	int bytes_sent = 0;
 	
@@ -143,6 +148,61 @@ int  hub_sendq_send(struct hub_sendq* q, hub_recvq_write w, void* data)
 	}
 
 	return bytes_sent;
+#else
+	int ret = 0;
+	size_t sent = 0;
+	size_t bytes = 0;
+	size_t offset = q->offset; // offset into first message.
+	size_t length = 0;
+	size_t msgs = 0;
+	char* sbuf = g_hub->sendbuf;
+	size_t max_send_buf = 1000; // MAX_SEND_BUF;
+
+	/* Copy as many messages possible into global send queue */
+	struct adc_message* msg = list_get_first(q->queue);
+	
+	while (msg)
+	{
+		msgs++;
+		length = MIN(msg->length - offset, (max_send_buf-1) - bytes);
+		memcpy(sbuf + bytes, msg->cache + offset, length);
+		bytes += length;
+		
+		if (length < msg->length - offset)
+			break;
+		offset = 0;
+		msg = list_get_next(q->queue);
+	}
+
+	msg = list_get_first(q->queue);
+	printf("Queued up bytes: %d, in %d msgs (first=%d/%d)\n", (int) bytes, (int) msgs, (int) q->offset, (msg ? (int) msg->length : 0));
+	
+	/* Send as much as possible */
+	ret = w(data, sbuf, bytes);
+	
+	if (ret > 0)
+	{
+		/* Remove messages sent */
+		offset = q->offset;
+		msg = list_get_first(q->queue);
+		while (msg)
+		{
+			sent += (msg->length - offset);
+			offset = 0;
+			
+			if (sent >= bytes)
+				break;
+			
+			printf("removing msg %d [%p]\n", (int) msgs, msg);
+			
+			hub_sendq_remove(q, msg);
+			msgs--;
+			msg = list_get_next(q->queue);
+		}
+		q->offset = (bytes - sent);
+	}
+	return ret;
+#endif
 }
 
 int hub_sendq_is_empty(struct hub_sendq* q)