Reduce size (queue management)

Author: budulinek

arduino-modbus-rtu-tcp-gateway/02-modbus-tcp.ino

@@ -169,14 +169,6 @@ void processRequests() {
           queueHasRespondingSlaves = false;
         }
       }
-      while (queueHasRespondingSlaves == true && getSlaveResponding(queueHeaders.first().uid) == false) {
-        // move requests to non responding slaves to the tail of the queue
-        for (byte i = 0; i < queueHeaders.first().PDUlen; i++) {
-          queuePDUs.push(queuePDUs.shift());
-        }
-        queueRetries.push(queueRetries.shift());
-        queueHeaders.push(queueHeaders.shift());
-      }
       serialState = SENDING;  // trigger sendSerial()
     }
   }
@@ -196,13 +188,6 @@ byte checkRequest(byte buffer[], unsigned int bufferSize) {
       return 0xFF;  // reject: do nothing and return no error code
     }
   }
-  if (queueHeaders.isEmpty() == false && getSlaveResponding(address) == false) {  // allow only one request to non responding slaves
-    for (byte j = queueHeaders.size(); j > 0; j--) {                              // start searching from tail because requests to non-responsive slaves are usually towards the tail of the queue
-      if (queueHeaders[j - 1].uid == address) {
-        return 0x0B;  // return modbus error 11 (Gateway Target Device Failed to Respond) - usually means that target device (address) is not present
-      }
-    }
-  }
   // check if we have space in request queue
   if (queueHeaders.available() < 1 || (localConfig.enableRtuOverTcp && queuePDUs.available() < bufferSize - 1) || (!localConfig.enableRtuOverTcp && queuePDUs.available() < bufferSize - 7)) {
     return 0x06;  // return modbus error 6 (Slave Device Busy) - try again later