Diff: file_system_manager.cpp

Revision:

119:ee6a53069455

Parent:

117:e9facba9db27

Child:

121:ee02790d00b7

--- a/file_system_manager.cpp	Fri Apr 24 13:54:24 2015 +0000
+++ b/file_system_manager.cpp	Thu Apr 30 15:42:41 2015 +0000
@@ -2,506 +2,166 @@
 
 QSPIFileSystem qspifs("qspi");
 
-/*
-void init_fsystem(){                 
-   //  init file system and check if files exist
-    if (!qspifs.isformatted()) {
-        qspifs.format();
-        send_msg("\n\rFile system configured!!\n\r");
-    }
-    debug_msg("");
-    files('i');   // check if the files are created
-    debug_msg("");
-    //files('c');
-    debug_msg("");
-    send_msg("\n\r*******File System Ready*******\n\r");
-}
-
-*/
-
-void set_ip( char * new_header_ip ){
+void set_ip( const char * new_header_ip ){
     FILE * fip = fopen("/qspi/myip.txt", "w");
-    fprintf( fip, "%s\n\r", new_header_ip  );
-    fclose( fip );
+    if ( fip )
+    {
+        fprintf( fip, "%s\n\r", new_header_ip  );
+        fclose( fip );
+    }    
 }
 
-void set_header_ext( int new_header_ext ){
+void set_header_ext( const int new_header_ext ){
     FILE * fext = fopen( "/qspi/myext.txt", "w" );
-    fprintf( fext, "%i\n\r", new_header_ext );
-    fclose( fext );
-}
-
-void set_header_sip_port( int new_header_sip_port ){
-    FILE * fport = fopen("/qspi/mysipport.txt", "w");
-    fprintf( fport,"%i\n\r", new_header_sip_port );
-    fclose( fport );
-}
-
-void set_server_ip( char * new_server_ip ){
-    FILE * fsip = fopen("/qspi/serverip.txt", "w");
-    fprintf( fsip,"%s\n\r", new_server_ip );
-    fclose( fsip );
-}
-
-void set_server_ext( int new_server_ext ){
-    FILE * fserext = fopen("/qspi/peerext.txt", "w");
-    fprintf( fserext , "%i\n\r", new_server_ext );
-    fclose( fserext );
-}
-
-void set_server_port( int new_server_port ){
-    FILE * fsport = fopen("/qspi/serverport.txt", "w");   
-    fprintf(fsport,"%i\n\r", new_server_port );
-    fclose( fsport );
+    if ( fext )
+    {
+        fprintf( fext, "%i\n\r", new_header_ext );
+        fclose( fext );
+    }
 }
 
-void set_mask( char * new_mask ){
-    FILE * fmask = fopen("/qspi/mymask.txt", "w");
-    fprintf(fmask,"%s\n\r",new_mask );
-    fclose( fmask );
-}
-
-void set_gateway( char * new_gateway ){
-    //fgate = fopen("/qspi/mygateway.txt", "w");
-    FILE * fgate = fopen("/qspi/mygateway.txt", "w");
-    fprintf(fgate,"%s\n\r", new_gateway );
-    fclose( fgate );
-}
-
-void set_udp_port_listener( int new_udp_port_listener ){
-    FILE * fudpport = fopen( "/qspi/udpport.txt", "w" );
-    fprintf( fudpport, "%i\n\r",new_udp_port_listener );
-    fclose( fudpport );
-}
-
-void set_tcp_port_listener( int new_tcp_port_listener ){
-    FILE * ftcpport = fopen( "/qspi/tcpport.txt", "w" );
-    fprintf( ftcpport, "%i\n\r",new_tcp_port_listener );
-    fclose( ftcpport );
+void set_header_sip_port( const int new_header_sip_port ){
+    FILE * fport = fopen("/qspi/mysipport.txt", "w");
+    if ( fport )
+    {
+        fprintf( fport,"%i\n\r", new_header_sip_port );
+        fclose( fport );
+    }
 }
 
-void set_telemetry_ip( char * new_telemetry_ip ){
-    FILE * ftip = fopen("/qspi/telemetry_ip.txt", "w" );
-    fprintf(ftip,"%s\n\r", new_telemetry_ip );
-    fclose( ftip );
-}
-
-void set_telemetry_port( int new_telemetry_port ){
-    FILE * ftport = fopen("/qspi/telemetry_port.txt", "w" );
-    fprintf(ftport,"%i\n\r", new_telemetry_port );
-    fclose( ftport );
+void set_server_ip( const char * new_server_ip ){
+    FILE * fsip = fopen("/qspi/serverip.txt", "w");
+    if ( fsip )
+    {
+        fprintf( fsip,"%s\n\r", new_server_ip );
+        fclose( fsip );
+    }
 }
 
-void set_fw_ip( char * new_fw_ip ){
-    FILE * ffwip = fopen("/qspi/fw_ip.txt", "w" );
-    fprintf(ffwip,"%s\n\r", new_fw_ip );
-    fclose( ffwip );
+void set_server_ext( const int new_server_ext ){
+    FILE * fserext = fopen("/qspi/peerext.txt", "w");
+    if ( fserext )
+    {
+        fprintf( fserext , "%i\n\r", new_server_ext );
+        fclose( fserext );
+    }
 }
 
-void set_fw_port( int new_fw_port ){
-    FILE * ffwport = fopen("/qspi/fw_port.txt", "w" );
-    fprintf(ffwport,"%i\n\r", new_fw_port );
-    fclose( ffwport );
-}
-
-void set_max_ext( int new_max_ext ){
-    FILE * fmex = fopen( "/qspi/maxext.txt", "w" );
-    if( fmex ){
-        fprintf( fmex, "%i\n\r", new_max_ext );
-        //debug_msg("");
-        fclose( fmex );
-        //debug_msg("");
+void set_server_port( const int new_server_port ){
+    FILE * fsport = fopen("/qspi/serverport.txt", "w");   
+    if ( fsport )
+    {
+        fprintf(fsport,"%i\n\r", new_server_port );
+        fclose( fsport );
     }
 }
 
-void set_min_ext( int new_min_ext ){
+void set_mask( const char * new_mask ){
+    FILE * fmask = fopen("/qspi/mymask.txt", "w");
+    if ( fmask )
+    {
+        fprintf(fmask,"%s\n\r",new_mask );
+        fclose( fmask );
+    }
+}
+
+void set_gateway( const char * new_gateway ){
+    //fgate = fopen("/qspi/mygateway.txt", "w");
+    FILE * fgate = fopen("/qspi/mygateway.txt", "w");
+    if ( fgate )
+    {
+        fprintf(fgate,"%s\n\r", new_gateway );
+        fclose( fgate );
+    }
+}
+
+void set_udp_port_listener( const int new_udp_port_listener ){
+    FILE * fudpport = fopen( "/qspi/udpport.txt", "w" );
+    if ( fudpport )
+    {
+        fprintf( fudpport, "%i\n\r",new_udp_port_listener );
+        fclose( fudpport );
+    }
+}
+
+void set_tcp_port_listener( const int new_tcp_port_listener ){
+    FILE * ftcpport = fopen( "/qspi/tcpport.txt", "w" );
+    if ( ftcpport )
+    {
+        fprintf( ftcpport, "%i\n\r",new_tcp_port_listener );
+        fclose( ftcpport );
+    }
+}
+
+void set_fw_ip( const char * new_fw_ip ){
+    FILE * ffwip = fopen("/qspi/fw_ip.txt", "w" );
+    if ( ffwip )
+    {
+        fprintf(ffwip,"%s\n\r", new_fw_ip );
+        fclose( ffwip );
+    }
+}
+
+void set_fw_port( const int new_fw_port ){
+    FILE * ffwport = fopen("/qspi/fw_port.txt", "w" );
+    if ( ffwport )
+    {
+        fprintf(ffwport,"%i\n\r", new_fw_port );
+        fclose( ffwport );
+    }
+}
+
+void set_max_ext( const int new_max_ext ){
+    FILE * fmex = fopen( "/qspi/maxext.txt", "w" );
+    if ( fmex ){
+        fprintf( fmex, "%i\n\r", new_max_ext );
+        fclose( fmex );
+    }
+}
+
+void set_min_ext( const int new_min_ext ){
     FILE * fmin = fopen( "/qspi/minext.txt", "w" );
-    if( fmin ){
+    if ( fmin ){
         fprintf( fmin, "%i\n\r", new_min_ext );
         fclose( fmin );
     }
 }
 
 // Print the content of a given file
-void cat(const char * fname){
+void cat( const char * fname ){
     char buff[513];
     int num;
     
-    FILE *fp = fopen(fname, "r");
+    FILE *fp = fopen( fname, "r" );
     if (fp == NULL) {
-        if( debug_file ) if( debug_uart3 ) pc.printf( "Failed to open %s", fname);
+        if( debug_file ) if( debug_uart3 && !( from_eth ) )  pc.printf( "Failed to open %s", fname);
         return;
     }
     
     while( ( num = fread( buff, 1, 512, fp ) ) > 0 ){
         buff[ num ] = '\0';
-        if( debug_uart3 ) pc.printf( buff );
+        if( debug_uart3 && !( from_eth ) )  pc.printf( buff );
         if( from_eth ){
-            if( tcp_session ) while( !( tcp_client.send_all( buff, strlen( buff ) ) ) );
+            if( tcp_session && !udp_query ) while( !( tcp_client.send_all( buff, strlen( buff ) ) ) );
             
-            else if( udp_request ){
-                udp_server.sendTo( udp_client, buff, strlen( buff ) );
+            else if( udp_query ){
+                udp_query_send_msg( buff );
             }
         }
     }
     fclose(fp);
 }
 
-/*
-//operantion with the system config files
-void files( const char type ){
-    FILE    *fip = NULL, 
-            *fmask = NULL,
-            *fgate = NULL,
-            *fport = NULL,
-            *fsip = NULL,
-            *fsport = NULL,
-            *fext = NULL,
-            *fserext = NULL,
-            *fudpport = NULL,
-            *ftcpport = NULL,
-            *ftip = NULL,
-            *ftport = NULL;
-
-    //fixme mudar o nome dessa variable
-    
-    //#define MIN_EXT 5100
-    //#define MAX_EXT 5139
-    char string_msg[ 1024 ];
-    // show files
-    switch( type ){    
-        case 's' : {
-            if( debug_uart3 ) pc.printf("Header IP " );
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Header IP " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/myip.txt");
-            
-            if( debug_uart3 ) pc.printf("Header ext ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Header ext " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/myext.txt");
-            
-            if( debug_uart3 ) pc.printf("Header port ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Header port " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/mysipport.txt");
-            
-            if( debug_uart3 ) pc.printf("Server IP ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Server IP " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/serverip.txt");
-            
-            if( debug_uart3 ) pc.printf("Server ext ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Server ext " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/peerext.txt");
-            
-            if( debug_uart3 ) pc.printf("Server port ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Server port " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            cat("/qspi/serverport.txt");
-            
-            if( debug_uart3 ) pc.printf("Mascara de rede ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Mascara de rede " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            cat("/qspi/mymask.txt");
-            
-            if( debug_uart3 ) pc.printf("Gateway IP ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Gateway IP " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            cat("/qspi/mygateway.txt");
-            
-            if( debug_uart3 ) pc.printf("UDP Port ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "UDP Port " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/udpport.txt");
-            
-            if( debug_uart3 ) pc.printf("TCP Port ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "TCP Port " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/tcpport.txt");
-            
-            if( debug_uart3 ) pc.printf("Telemetry Server IP ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Telemetry Server IP " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-            
-            cat("/qspi/telemetry_ip.txt");
-            
-            if( debug_uart3 ) pc.printf("Telemetry Server Port ");
-            if( from_eth ){
-                snprintf( string_msg, __PROMPT_ETH_BUFFER_SIZE__, "Telemetry Server Port " );
-                if( tcp_session ) while( !( tcp_client.send_all( string_msg, strlen( string_msg ) ) ) );
-                
-                else if( udp_request ){
-                    udp_server.sendTo( udp_client, string_msg, strlen( string_msg ) );
-                }
-            }
-        
-            cat("/qspi/telemetry_port.txt");
-            break;
-        }
-    
-        case 'c' : {                
-            // close all files
-            debug_msg("");
-            if( fip != NULL ) fclose( fip );
-            if( fmask != NULL ) fclose( fmask );
-            if( fgate != NULL ) fclose( fgate );
-            if( fport != NULL ) fclose( fport );
-            if( fsip != NULL ) fclose( fsip );
-            if( fsport != NULL ) fclose( fsport );
-            if( fext != NULL ) fclose( fext );
-            if( fserext != NULL ) fclose( fserext );
-            if( fudpport != NULL ) fclose( fudpport );
-            if( ftcpport != NULL ) fclose( ftcpport );
-            debug_msg("");
-            break;
-        }    
-        
-        case 'i' : {
-            // Check if files exist, if not create the files
-            //fixme criar um bool pra cada file
-            bool exists = true;
-            
-            debug_msg("");
-            fip = fopen("/qspi/myip.txt", "r");
-            if( fip == NULL){
-                set_ip( __MY_IP__ );
-                exists = false;
-            }
-            debug_msg("");
-            fserext = fopen("/qspi/myext.txt", "r");
-            if( fserext == NULL ){
-                set_header_ext( __MY_EXT__ );
-                exists = false;
-            }
-            debug_msg("");
-            fport = fopen("/qspi/mysipport.txt", "r");
-            if (fport == NULL){
-                set_header_sip_port( __MY_PORT__ );
-                exists = false;
-            }
-            debug_msg("");
-            fsip = fopen("/qspi/serverip.txt", "r");
-            if (fsip == NULL){
-                 set_server_ip( __SERVER_IP__ );
-                 exists = false;
-            }
-            debug_msg("");
-            fext = fopen("/qspi/peerext.txt", "r");
-            if ( fext == NULL ){
-                 set_server_ext( __PEER_EXT__ );
-                 exists = false;
-            }
-            debug_msg("");
-            fsport = fopen("/qspi/serverport.txt", "r");
-            if (fsport == NULL){
-                set_server_port( __SERVER_PORT__ );
-                exists = false;
-            }
-            debug_msg("");
-            fmask = fopen("/qspi/mymask.txt", "r");
-            if (fmask == NULL){
-                set_mask( __MY_MSK__ );
-                exists = false;
-            }
-            debug_msg("");
-            fgate = fopen("/qspi/mygateway.txt", "r");
-            if (fgate == NULL){
-                set_gateway( __MY_GTW__ );
-                exists = false;
-            }
-            debug_msg("");
-            fudpport = fopen("/qspi/udpport.txt", "r" );
-            if( fudpport == NULL ){
-                set_udp_port_listener( UDP_PORT_LISTENER );
-                exists = false;
-            }
-            debug_msg("");
-            ftcpport = fopen("/qspi/tcpport.txt", "r" );
-            if( ftcpport == NULL ){
-                set_tcp_port_listener( TCP_PORT_LISTENER );
-                exists = false;
-            }
-            debug_msg("");
-            ftip = fopen("/qspi/telemetry_ip.txt", "r" );
-            if( ftip == NULL ){
-                set_telemetry_ip( __TELEMETRY_SERVER_IP__ );
-                exists = false;
-            }
-            debug_msg("");
-            ftport = fopen("/qspi/telemetry_port.txt", "r" );
-            if( ftport == NULL ){
-                set_telemetry_port( __TELEMETRY_SERVER_PORT__ );
-                exists = false;
-            }
-            debug_msg("");
-            if( !exists ){ 
-                send_msg("\n\rDefault configurations set!\n\r");
-            }
-            debug_msg("");
-            break;
-        }
-        
-        case 'r' : {
-            // Just open for read
-            fip = fopen("/qspi/myip.txt", "r");
-            fmask = fopen("/qspi/mymask.txt", "r");
-            fgate = fopen("/qspi/mygateway.txt", "r");
-            fport = fopen("/qspi/mysipport.txt", "r");
-            fsip = fopen("/qspi/serverip.txt", "r");
-            fsport = fopen("/qspi/serverport.txt", "r");
-            fext = fopen( "/qspi/myext.txt", "r" );
-            fserext = fopen( "/qspi/peerext.txt", "r" );
-            fudpport = fopen( "/qspi/udpport.txt", "r" );
-            ftcpport = fopen( "/qspi/tcpport.txt", "r" );
-            ftip = fopen("/qspi/telemetry_ip.txt", "r" );
-            ftport = fopen("/qspi/telemetry_port.txt", "r" );
-            break;
-        }
-            
-        case 'w' : {
-            // Create and write the default configs
-            
-            set_ip( __MY_IP__ );
-            
-            set_header_sip_port( __MY_PORT__ );
-            
-            set_header_ext( __MY_EXT__ );
-            
-            set_server_ip( __SERVER_IP__ );
-            
-            set_server_ext( __PEER_EXT__ );
-            
-            set_server_port( __SERVER_PORT__ );
-        
-            set_mask( __MY_MSK__ );
-            
-            set_gateway( __MY_GTW__ );
-            
-            set_udp_port_listener( UDP_PORT_LISTENER );
-            
-            set_tcp_port_listener( TCP_PORT_LISTENER );
-            
-            set_telemetry_ip( __TELEMETRY_SERVER_IP__ );
-                
-            set_telemetry_port( __TELEMETRY_SERVER_PORT__ );
-            
-            send_msg( "Default configurations set!" );
-            break;
-        }
-        
-        case 'e' : {
-            //Erase configs
-            fip = fopen("/qspi/myip.txt", "w");
-            fmask = fopen("/qspi/mymask.txt", "w");
-            fgate = fopen("/qspi/mygateway.txt", "w");
-            fport = fopen("/qspi/mysipport.txt", "w");
-            fsip = fopen("/qspi/serverip.txt", "w");
-            fsport = fopen("/qspi/serverport.txt", "w");   
-            fext = fopen( "/qspi/myext.txt", "w" );
-            fserext = fopen( "/qspi/peerext.txt", "w" );
-            fudpport = fopen( "/qspi/udpport.txt", "w" );
-            ftcpport = fopen( "/qspi/tcpport.txt", "w" );
-            ftip = fopen("/qspi/telemetry_ip.txt", "w" );
-            ftport = fopen("/qspi/telemetry_port.txt", "w" );
-            
-            //FIXME verificar se deveria colocar tudo para %s
-            fprintf( fip, "%s\n\r", ""  ); 
-            fprintf( fport, "%i\n\r", 0 );
-            fprintf( fext, "%i\n\r", 0 ); 
-            
-            fprintf( fsip, "%s\n\r", ""  );
-            fprintf( fserext, "%i\n\r", 0 );
-            fprintf( fsport, "%i\n\r", 0 ); 
-            
-            fprintf( fmask, "%s\n\r","" );  
-            fprintf( fgate, "%s\n\r", "" );
-            
-            fprintf( fudpport, "%i\n\r", 0 );
-            fprintf( ftcpport, "%i\n\r", 0 );
-            
-            fprintf( ftip, "%s\n\r","" );
-            fprintf( ftport, "%i\n\r",0 );
-            
-            files('c');
-            
-            send_msg("\n\rErased configurations set!\n\r");
-            break;
-        }
+void set_shift_port( const int new_shift_port ){
+    FILE * shift_port = fopen("/qspi/shift_port.txt", "w" );
+    if( shift_port )
+    {
+        fprintf( shift_port,"%i\n\r", new_shift_port );
+        fclose( shift_port );
+        if( debug_file ) debug_msg("Set /qspi/shift_port.txt");
     }
-}
-*/
\ No newline at end of file
+        else
+    {
+        if( debug_file ) debug_msg("Cannot open /qspi/shift_port.txt");
+    }
+}
\ No newline at end of file