From a59d4c3177763e6ff29f1fc24acb8387a82061ff Mon Sep 17 00:00:00 2001
From: cskarai <cskarai@users.noreply.github.com>
Date: Fri, 16 Jun 2017 05:54:43 +0200
Subject: [PATCH] Segment huge packets at TCP receive (#213)

---
 socket/socket.c | 25 +++++++++++++++++++------
 1 file changed, 19 insertions(+), 6 deletions(-)

diff --git a/socket/socket.c b/socket/socket.c
index 30ebb52..1814cc2 100644
--- a/socket/socket.c
+++ b/socket/socket.c
@@ -36,6 +36,8 @@ typedef struct {
 // Instead, we allocate a fixed pool of connections an round-robin. What this means is that the
 // attached MCU should really use at most as many SOCKET connections as there are slots in the pool.
 #define MAX_SOCKET 4
+#define MAX_RECEIVE_PACKET_LENGTH 100
+
 static SocketClient socketClient[MAX_SOCKET];
 static uint8_t socketNum = 0xff; // index into socketClient for next slot to allocate
 
@@ -48,12 +50,23 @@ socketclient_recv_cb(void *arg, char *pusrdata, unsigned short length) {
 	uint8_t clientNum = client->conn_num;
 	uint8_t cb_type = USERCB_RECV;
 	DBG_SOCK("SOCKET #%d: Received %d bytes: %s\n", client-socketClient, length, pusrdata);
-	cmdResponseStart(CMD_RESP_CB, client->resp_cb, 4);
-	cmdResponseBody(&cb_type, 1);	
-	cmdResponseBody(&clientNum, 1);
-	cmdResponseBody(&length, 2);
-	cmdResponseBody(pusrdata, length);
-	cmdResponseEnd();
+	
+	unsigned short position = 0;
+	do
+	{
+		unsigned short msgLen = length - position;
+		if( msgLen > MAX_RECEIVE_PACKET_LENGTH )
+			msgLen = MAX_RECEIVE_PACKET_LENGTH;
+		
+		cmdResponseStart(CMD_RESP_CB, client->resp_cb, 4);
+		cmdResponseBody(&cb_type, 1);	
+		cmdResponseBody(&clientNum, 1);
+		cmdResponseBody(&msgLen, 2);
+		cmdResponseBody(pusrdata + position, msgLen);
+		cmdResponseEnd();
+		
+		position += msgLen;
+	}while(position < length );
 	
 	if (client->sock_mode != SOCKET_TCP_SERVER) { // We don't wait for a response
 		DBG_SOCK("SOCKET #%d: disconnect after receiving\n", client-socketClient);