X-Git-Url: https://git.llucax.com/z.facultad/66.09/etherled.git/blobdiff_plain/a54d8f292cffe00cf141efc7d6c49cbb598c1d21..6add33161e732ed834469f217a7ba97200694d63:/src/main.c?ds=sidebyside

diff --git a/src/main.c b/src/main.c
index c679ac8..f980df1 100644
--- a/src/main.c
+++ b/src/main.c
@@ -2,6 +2,7 @@
 
 #include "debug.h"
 #include "leds.h"
+#include "reg51.h"
 #include "netdev.h"
 #include "eth.h"
 #include "ip.h"
@@ -9,16 +10,24 @@
 
 void main(void)
 {
-    // Apagamos todos los leds
-    leds(0);
+    // Inicializamos leds
+    leds_init();
+
+    // Hacemos prueba simple de los leds
+    leds_test();
 
     // Inicializamos dispositivo de red
     if (!netdev_init())
     {
-        leds(0xFFFF);
-        while(1); // Si falla init nos quedamos bobos
+        // Si hubo un error, quedan prendidos todos los leds
+        leds_write(0xFFFF);
+        return;
     }
 
+    // Comienza a 'dibujar'
+    EA  = 1; // Habilita interrupciones globalmente
+    TR2 = 1; // Pone a correr el 'dibujado'
+
     // Inicializo IP
     ip_addr_local[0] = 10;
     ip_addr_local[1] = 10;
@@ -26,13 +35,14 @@ void main(void)
     ip_addr_local[3] = 100;
 
     // Inicializo puerto UDP
-    udp_port_local = 9000;
+    udp_port_local = 9876;
 
     while (1) // Forever
     {
-        byte i;
-        byte len = netdev_recv_start();
-        printb(len, 0x1);
+        byte i; //XXX
+        byte len;
+
+        len = netdev_recv_start();
         if (!len) // no recibimos nada (válido)
             continue; // Probamos de nuevo
 
@@ -47,7 +57,7 @@ void main(void)
         // Vemos que protocolo transporta
         switch (eth_proto)
         {
-            case ETH_ARP: // FIXME, implementar ARP!
+            case ETH_ARP: // TODO: implementar ARP!
                 goto drop; // Tiramos el paquete
 
             case ETH_IP:
@@ -60,7 +70,7 @@ void main(void)
                 // Vemos que protocolo transporta
                 switch (ip_proto)
                 {
-                    case IP_ICMP: // FIXME, implementar ICMP!
+                    case IP_ICMP: // TODO: implementar ICMP!
                         goto drop; // Tiramos el paquete
 
                     case IP_UDP:
@@ -69,22 +79,37 @@ void main(void)
                         if (!udp_read_dgram_header()) // No es un buen header
                             goto drop; // Tiramos el paquete
 
-                        printb(udp_dgram_len, 0x40);
+                        //printb(udp_dgram_len, 0x40);
                         // TODO
                         // Nuestro protocolo, por ahora un simple echo!
-                        for (i = 8; i < udp_dgram_len; ++i) // 8 por la cabecera UDP
-                        {
-                            leds0 = ~netdev_recv_byte();
-                            leds1 = ~i;
-                            sleep(8);
-                        }
-                        i = (udp_dgram_len % 2) ? udp_dgram_len : (udp_dgram_len + 1);
-                        for (i += 34; i < len; ++i) // 8 por la cabecera UDP
-                            netdev_recv_byte();
-drop:
+                        len = udp_dgram_len - UDP_HEADER_SIZE;
+                        netdev_read_start(len);
+                        leds_matrix_len = len;
+                        for (i = 0; i < len; ++i)
+                            leds_matrix[i] = udp_read_byte();
+                        netdev_read_end();
+                        if (!udp_checksum_ok())
+                            goto drop;
                         netdev_recv_end();
+
+                        // Respuesta
+                        netdev_send_start();
+                        eth_write_frame_header();
+                        //udp_dgram_len = UDP_HEADER_SIZE+len;
+                        //ip_packet_len = IP_HEADER_SIZE+udp_dgram_len;
+                        ip_write_packet_header();
+                        udp_write_dgram_header();
+                        netdev_write_start(len);
+                        for (i = 0; i < len; ++i)
+                            udp_write_byte(leds_matrix[i]);
+                        netdev_write_end();
+                        udp_write_checksum(ETH_HEADER_SIZE+IP_HEADER_SIZE);
+                        netdev_send_end(ETH_HEADER_SIZE+IP_HEADER_SIZE+udp_dgram_len);
                 }
         }
+        continue;
+drop:
+        netdev_recv_end();
     }
 }