do not available, just try to read

EthernetInterface.cpp

@@ -30,6 +30,8 @@
 #include "WiThrottle.h"
 #include "DCCTimer.h"
 
+extern void looptimer(unsigned long timeout, const FSH* message);
+
 EthernetInterface * EthernetInterface::singleton=NULL;
 /**
  * @brief Setup Ethernet Connection
@@ -125,6 +127,7 @@ void EthernetInterface::loop()
         //nothing happened
         break;
     }
+    looptimer(8000, F("Ethloop after maintain"));
    singleton->loop2();
 }
 
@@ -199,21 +202,23 @@ void EthernetInterface::loop2() {
     // check for incoming data from all possible clients
     for (byte socket = 0; socket < MAX_SOCK_NUM; socket++)
     {
-        if (clients[socket]) {
+      if (clients[socket]) {
 	
-        int available=clients[socket].available();
-        if (available > 0) {
-            if (Diag::ETHERNET)  DIAG(F("Ethernet: available socket=%d,avail=%d"), socket, available);
-            // read bytes from a client
-            int count = clients[socket].read(buffer, MAX_ETH_BUFFER);
+	// read bytes from a client
+	int count = clients[socket].read(buffer, MAX_ETH_BUFFER);
+	looptimer(8000, F("Ethloop2 read"));
+        if (count > 0) {
+            if (Diag::ETHERNET)  DIAG(F("Ethernet: available socket=%d,count=%d"), socket, count);
             buffer[count] = '\0'; // terminate the string properly
-            if (Diag::ETHERNET) DIAG(F(",count=%d:%e"), socket,buffer);
+            if (Diag::ETHERNET) DIAG(F("buffer:%e"), buffer);
             // execute with data going directly back
             CommandDistributor::parse(socket,buffer,outboundRing);
+	    looptimer(2000, F("Ethloop2 parse"));
             return; // limit the amount of processing that takes place within 1 loop() cycle. 
           }
         }
     }
+    looptimer(8000, F("Ethloop2 after incoming"));
 
     // stop any clients which disconnect
    for (int socket = 0; socket<MAX_SOCK_NUM; socket++) {
@@ -223,8 +228,10 @@ void EthernetInterface::loop2() {
       if (Diag::ETHERNET)  DIAG(F("Ethernet: disconnect %d "), socket);             
      }
     }
+    looptimer(8000, F("Ethloop after disconnectcheck"));
 
     WiThrottle::loop(outboundRing);
+    looptimer(8000, F("Ethloop after Withrottleloop"));
 
     // handle at most 1 outbound transmission 
     int socketOut=outboundRing->read();
@@ -233,8 +240,17 @@ void EthernetInterface::loop2() {
     } else if (socketOut >= 0) {
       int count=outboundRing->count();
       if (Diag::ETHERNET) DIAG(F("Ethernet reply socket=%d, count=:%d"), socketOut,count);
-      for(;count>0;count--)  clients[socketOut].write(outboundRing->read());
+      {
+	char tmpbuf[count+1]; // one extra for '\0'
+	for(int i=0;i<count;i++) {
+	  tmpbuf[i] = outboundRing->read();
+	}
+	tmpbuf[count]=0;
+	clients[socketOut].write(tmpbuf,count);
+      }
       clients[socketOut].flush(); //maybe 
     }
+    looptimer(8000, F("Ethloop after outbound"));
+
 }
 #endif

GITHUB_SHA.h

@@ -1 +1 @@
-#define GITHUB_SHA "devel-fozzie-202408080852Z"
+#define GITHUB_SHA "devel-fozzie-202408090945Z"