Diff: bootloader_cbx_handler.h

Revision:

67:cdedc64d9921

Child:

68:b54993674190

diff -r 3f1d22e69e7b -r cdedc64d9921 bootloader_cbx_handler.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bootloader_cbx_handler.h	Thu Oct 30 19:26:41 2014 +0000
@@ -0,0 +1,184 @@
+#ifndef __BOOTLOADER_CBX_HANDLER_H__
+#define __BOOTLOADER_CBX_HANDLER_H__
+
+#include "prompt.h"
+#include "debug.h"
+#include "vz_protocol.h"
+
+#define udp_idle 0x00
+#define udp_waiting_start_pkg 0x01
+#define udp_listen 0x02
+
+extern bool listen_udp;
+extern Timer bl_timer;
+extern UDPSocket bl_cbx_server;
+extern Endpoint bl_cbx_client;
+
+extern char last_client_ip[ 16 ];
+extern int last_client_port;
+
+int init_bl_handler( void );
+char * listen_bl_socket( char * buffer, int *length );
+int bl_handler( void );
+int bl_cbx_reply_to_eth( int ext, char * data );
+
+/*
+int is_start_pkg( uint8_t * data ){
+    //seq_num must to be 0s
+    if( !data ) return -1; 
+    
+    for( register int i = __VZ_HEADER_OFFSET__; i < __PROMPT_ETH_BUFFER_SIZE__; i++ ) if( data[ i ] ) return( 0 );
+    
+    return( 1 );
+}
+
+int is_stop_pkg( uint8_t * data ){
+    //seq_num must to be 0s
+    if( !data ) return -1; 
+    
+    for( register int i = __VZ_HEADER_OFFSET__; i < __PROMPT_ETH_BUFFER_SIZE__; i++ ) if( data[ i ] ) return( 0 );
+    
+    return( 1 );
+}
+
+int is_time_to_stop( uint8_t * data ){
+    static int count = 0;
+    if( !data ) return( 0 );
+    
+    if( is_stop_pkg( data ) == 1 ) count++;
+    
+    else count = 0;
+    
+    if( count == 10 ) return( 1 );
+    
+    else return( 0 );
+}
+
+*/
+
+
+/*
+char * listen_bl_socket( char * buffer, int *length ){
+    static UDPSocket server;
+    server.set_blocking( false, 2 );
+    server.bind( UDP_BOOTLOADER_PORT );
+    Endpoint client;
+    //bool valid_reboot = false;
+    uint8_t * data = NULL;
+    static int bl_ext;
+    static int bl_port;
+    //static uint8_t type;
+    static Timer t;
+    //static uint8_t status = udp_idle;
+    //static uint8_t seq_num = 0;
+    //OBS sizeof( buffer ) == 4 ????
+    //length = server.receiveFrom( client, buffer, sizeof( buffer ) );
+    *length = server.receiveFrom( client, buffer, __PROMPT_ETH_BUFFER_SIZE__ );
+    
+    if( *length == -1 ){
+        int ret = server.bind( UDP_BOOTLOADER_PORT );    
+        
+        if( ret == -1 ){
+            server.close(); 
+            server.bind( UDP_BOOTLOADER_PORT );
+        }
+    }
+    
+    if( *length > 0){
+        buffer[ *length ] = '\0';
+        buffer[ strlen( buffer ) - 1 ] = '\0';
+        t.start();
+        bl_timer.reset();
+        
+        return( NULL );
+    }
+        
+        //data = __parse_vz_pkg__( &bl_ext, &bl_port, __BOOT_LOADER__, (uint8_t *)buffer );
+        
+        if( !data ){
+            debug_msg("UDP pks parse failed");
+            server.sendTo( client, buffer, sizeof( buffer ) );
+            return( NULL );
+        }
+        */
+        
+        /*
+        if( status == udp_idle ){ 
+            data[ 0 ] |= BIT7;
+            strcpy( (char *)&data[ 1 ], "Received listen request" );
+            server.sendTo( client, buffer, sizeof( buffer ) );
+            status = udp_waiting_start_pkg;
+        }
+        */
+        
+        /*
+        if( status == udp_waiting_start_pkg ){
+            static int count = 0;
+            if( is_start_pkg( data ) == 1 ) 
+                if( count++ == __START_PKG_COUNT__ ) status = udp_listen;
+            
+            else{ 
+                count = 0;
+                status = udp_idle;
+            }
+        }
+        */
+        /*      
+        if( status == udp_listen ){
+            debug_msg( "Received start pkgs" ); // mandar msg pro server
+            if( t.read() < 60 ){
+                server.set_blocking( true, 10 );
+                t.reset();
+                do{
+                    wdt.kick();
+                    *length = server.receiveFrom( client, buffer, sizeof( buffer ) );
+                    //data = __parse_vz_pkg__( &bl_ext, &_blport, &type, (uint8_t *)buffer );
+                    if( data ){
+                        if( !( is_start_pkg( data ) ) ) break;
+                    }else{
+                        debug_msg("UDP pks parse failed");
+                        // reenvia pkg dizendo que podemos comecar com a transacao de dados
+                    }
+                }while( t.read() < 60 );
+                
+                if( t.read() < 60 ){
+                    //tratar o primeiro pkg depois dos zeros aqui
+                    //a ideia é ir recebendo e colocando no arquivo "se for pra header" ou mandar
+                    //pro cb depois,
+                    if( !( ext || port ) ){ // pkg pra header
+                        debug_msg("criando arquivo");
+                    }else{
+                        debug_msg("Mandando pkg pro cb");
+                    }
+                    //FIXME mudar essa condicao de parada
+                    while( !( is_time_to_stop( data ) == 1 ) ){
+                        wdt.kick();
+                        *length = server.receiveFrom( client, buffer, sizeof( buffer ) );
+                        if( ( data[ 0 ] - seq_num ) != 1 ){
+                            //perdi algum pacote    
+                            //solicitar re-envio mandando o ultimo seq_num recebido talvez ...
+                            continue;
+                        }else{
+                            debug_msg("+(%d,%d)-%s+", ext, port, data );
+                        }
+                    }
+                    //pensar em como validar os pacotes recebidos, cks ... e o que mais ?
+                    //se validado os pkgs, dar reset com os dados no arquivo bla, caso contrario, ignorar ...
+                    //if( valid_reboot ) NVIC_SystemReset();
+                    
+                    //else{
+                    //    server.set_blocking( false, 1 );
+                    //    t.stop();
+                    //    t.reset();
+                    //    debug_msg("Nao Resetando ... ");
+                    //}
+                    
+                }
+            }
+        }else return( buffer );
+    *length = 0;
+    return( NULL );
+    //return( NULL );
+}
+*/  
+#endif
\ No newline at end of file