EthernetInterface.cpp

@@ -30,8 +30,6 @@
 #include "WiThrottle.h"
 #include "DCCTimer.h"
 
-extern void looptimer(unsigned long timeout, const FSH* message);
-
 EthernetInterface * EthernetInterface::singleton=NULL;
 /**
  * @brief Setup Ethernet Connection
@@ -127,7 +125,6 @@ void EthernetInterface::loop()
         //nothing happened
         break;
     }
-    looptimer(8000, F("Ethloop after maintain"));
    singleton->loop2();
 }
 
@@ -202,23 +199,21 @@ 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]) {
-	
+        
-	// read bytes from a client
+        int available=clients[socket].available();
-	int count = clients[socket].read(buffer, MAX_ETH_BUFFER);
+        if (available > 0) {
-	looptimer(8000, F("Ethloop2 read"));
+            if (Diag::ETHERNET)  DIAG(F("Ethernet: available socket=%d,avail=%d"), socket, available);
-        if (count > 0) {
+            // read bytes from a client
-            if (Diag::ETHERNET)  DIAG(F("Ethernet: available socket=%d,count=%d"), socket, count);
+            int count = clients[socket].read(buffer, MAX_ETH_BUFFER);
             buffer[count] = '\0'; // terminate the string properly
-            if (Diag::ETHERNET) DIAG(F("buffer:%e"), buffer);
+            if (Diag::ETHERNET) DIAG(F(",count=%d:%e"), socket,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++) {
@@ -228,11 +223,9 @@ 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();
     if (socketOut >= MAX_SOCK_NUM) {
@@ -240,17 +233,8 @@ 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-202408090945Z"
+#define GITHUB_SHA "devel-fozzie-202408080852Z"