Diff: file_system_manager.cpp

Revision:

117:e9facba9db27

Parent:

116:39a41ebb675c

Child:

119:ee6a53069455

--- a/file_system_manager.cpp	Thu Apr 23 20:24:09 2015 +0000
+++ b/file_system_manager.cpp	Thu Apr 23 21:53:28 2015 +0000
@@ -2,166 +2,506 @@
 
 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 ){
     FILE * fip = fopen("/qspi/myip.txt", "w");
-    if ( fip )
-    {
-        fprintf( fip, "%s\n\r", new_header_ip  );
-        fclose( fip );
-    }    
+    fprintf( fip, "%s\n\r", new_header_ip  );
+    fclose( fip );
 }
 
 void set_header_ext( int new_header_ext ){
     FILE * fext = fopen( "/qspi/myext.txt", "w" );
-    if ( fext )
-    {
-        fprintf( fext, "%i\n\r", new_header_ext );
-        fclose( fext );
-    }
+    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");
-    if ( fport )
-    {
-        fprintf( fport,"%i\n\r", new_header_sip_port );
-        fclose( fport );
-    }
+    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");
-    if ( fsip )
-    {
-        fprintf( fsip,"%s\n\r", new_server_ip );
-        fclose( fsip );
-    }
+    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");
-    if ( fserext )
-    {
-        fprintf( fserext , "%i\n\r", new_server_ext );
-        fclose( fserext );
-    }
+    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");   
-    if ( fsport )
-    {
-        fprintf(fsport,"%i\n\r", new_server_port );
-        fclose( fsport );
-    }
+    fprintf(fsport,"%i\n\r", new_server_port );
+    fclose( fsport );
 }
 
 void set_mask( char * new_mask ){
     FILE * fmask = fopen("/qspi/mymask.txt", "w");
-    if ( fmask )
-    {
-        fprintf(fmask,"%s\n\r",new_mask );
-        fclose( fmask );
-    }
+    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");
-    if ( fgate )
-    {
-        fprintf(fgate,"%s\n\r", new_gateway );
-        fclose( fgate );
-    }
+    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" );
-    if ( fudpport )
-    {
-        fprintf( fudpport, "%i\n\r",new_udp_port_listener );
-        fclose( fudpport );
-    }
+    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" );
-    if ( ftcpport )
-    {
-        fprintf( ftcpport, "%i\n\r",new_tcp_port_listener );
-        fclose( ftcpport );
-    }
+    fprintf( ftcpport, "%i\n\r",new_tcp_port_listener );
+    fclose( ftcpport );
+}
+
+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_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_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_fw_port( const int new_fw_port ){
+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_fw_port( int new_fw_port ){
     FILE * ffwport = fopen("/qspi/fw_port.txt", "w" );
-    if ( ffwport )
-    {
-        fprintf(ffwport,"%i\n\r", new_fw_port );
-        fclose( ffwport );
-    }
+    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 ){
+    if( fmex ){
         fprintf( fmex, "%i\n\r", new_max_ext );
+        //debug_msg("");
         fclose( fmex );
+        //debug_msg("");
     }
 }
 
 void set_min_ext( 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 && !( from_eth ) )  pc.printf( "Failed to open %s", fname);
+        if( debug_file ) if( debug_uart3 ) pc.printf( "Failed to open %s", fname);
         return;
     }
     
     while( ( num = fread( buff, 1, 512, fp ) ) > 0 ){
         buff[ num ] = '\0';
-        if( debug_uart3 && !( from_eth ) )  pc.printf( buff );
+        if( debug_uart3 ) pc.printf( buff );
         if( from_eth ){
-            if( tcp_session && !udp_query ) while( !( tcp_client.send_all( buff, strlen( buff ) ) ) );
+            if( tcp_session ) while( !( tcp_client.send_all( buff, strlen( buff ) ) ) );
             
-            else if( udp_query ){
-                udp_query_send_msg( buff );
+            else if( udp_request ){
+                udp_server.sendTo( udp_client, buff, strlen( buff ) );
             }
         }
     }
     fclose(fp);
 }
 
-void set_shift_port( 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");
+/*
+//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;
+        }
     }
-        else
-    {
-        if( debug_file ) debug_msg("Cannot open /qspi/shift_port.txt");
-    }
-}
\ No newline at end of file
+}
+*/
\ No newline at end of file