Elimino el bug que hacía que hubiera un byte inválido entre lecturas.

Se agrega el id de puerto en la respuesta (otro bug).

Modifico el poc para que muestre la cantidad de operaciones que puede realizar con una configuración básica. En mi sistema obtuve más de alrededor de 5k de operaciones, por lo que estamos bastante bien! Igual, voy a realizar un test que haga reportar a todos los puertos analógicos y que actúe sobre más puertos.

Author: Marco-GG

MLC/arduino/Firmware/Firmware.ino

@@ -1,8 +1,9 @@
 
-#define DEBUG 1
-
-#ifdef DEBUG
+#define DEBUG 0
+#if DEBUG
 #define LOG(x,y) Serial.print(x); Serial.println(y);
+#else
+#define LOG(x,y)
 #endif
 
 // defines ahorran ROM... aunque nos sobra de eso XD -- Verificar que los const vayan a la rom!
@@ -140,34 +141,36 @@ int actuate(const char* data)
   byte len = 1;  // Inicia en 1 para evitar pisar el id de comando
   for (int i = 1; i <= byte(INPUT_PORTS[0]); i++)
   {
+    response[len + 1] = INPUT_PORTS[i];
     if ( INPUT_PORTS[i] >= A0 )
     {
       int data = analogRead(INPUT_PORTS[i]-A0);
-      response[len + 1] = byte((data & 0xFF00) >> 8); // Se guarda el msb en el buffer
-      response[len + 2] = byte(data & 0xFF);        // Se guarda el lsb en el buffer
+      response[len + 2] = byte((data & 0xFF00) >> 8); // Se guarda el msb en el buffer
+      response[len + 3] = byte(data & 0xFF);        // Se guarda el lsb en el buffer
 
-      len += 2; // Cada lectura de un recurso analógico ocupa dos bytes. FIXME: se puede optimizar con bajas resoluciones
+      len += 3; // Cada lectura de un recurso analógico ocupa dos bytes. FIXME: se puede optimizar con bajas resoluciones
       LOG("Analog pin read: ", INPUT_PORTS[i]);
     } else
     {
       int data = digitalRead(INPUT_PORTS[i]);
-      response[len + 1] = byte(data);
-
-      len += 1;
+      response[len + 2] = byte(data);
+      len += 2;
       LOG("Digital pin read: ", INPUT_PORTS[i]);
     }
-  }
+  };
+
 
+  LOG("Reporting actuate results ", len - 1);
   response[1] = len - 1;
-  SerialUSB.write(response, len + 2); // 2 bytes extras por el id de comando y la longitud
+  SerialUSB.write(response, len + 1); // 2 bytes extras por el id de comando y la longitud y -1 por el padding
 
   return offset + 2;
 }
 
 void setup() {
   SerialUSB.begin(115200);
 
-  #ifdef DEBUG
+  #if DEBUG
   Serial.begin(115200);
   #endif
 

MLC/arduino/protocol.py

@@ -107,7 +107,7 @@ def actuate(self, data):
             raise Exception("Actuate error. Code: %s" % response)
 
         if response <> _PROTOCOL_CMDS["ACTUATE_REPORT"]:
-            raise Exception("Actuate error. Unknown response %s after actuate operation" % response)
+            raise Exception("Actuate error. Unknown response %s after actuate operation" % ord(response))
 
         length = ord(self._connection.recv(1))
         data = self._connection.recv(length)

tests/pocs/test_connection.py

@@ -3,13 +3,31 @@
 from MLC.arduino.protocol import ArduinoInterface
 from MLC.arduino import boards
 import sys
+import time
 
 def actuate(terminal):
     connection = SerialConnection(port=terminal)
     arduinoDue = ArduinoInterface(connection, boards.Due)
 
     arduinoDue.add_output(40)
-    arduinoDue.actuate([(40,1)])
+    arduinoDue.add_input(64)
+
+    last_time = time.time()
+    start_time = last_time
+    read_c = 0
+
+    for i in range(0, 100000):
+        arduinoDue.actuate([(40,1)])
+        read_c = read_c + 1
+        new_time = time.time()
+
+        if (new_time - start_time) > 1:
+           print str(read_c-1) # The current read was out of the period
+           read_c = 1
+           start_time = new_time
+
+        last_time = new_time
+
 
 if __name__ == "__main__":
     if (len(sys.argv) < 2):