![](/media/cache/group/default_image.jpg.50x50_q85.jpg)
Modularizando o src
Dependencies: EALib EthernetInterface_vz mbed-rtos mbed
Fork of header_main_colinas_V0-20-09-14 by
Diff: file_system_manager.cpp
- Revision:
- 116:39a41ebb675c
- Parent:
- 114:472502b31a12
- Child:
- 117:e9facba9db27
--- a/file_system_manager.cpp Thu Apr 23 13:57:54 2015 +0000 +++ b/file_system_manager.cpp Thu Apr 23 20:24:09 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 ){ 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 ){ FILE * fext = fopen( "/qspi/myext.txt", "w" ); - fprintf( fext, "%i\n\r", new_header_ext ); - fclose( fext ); + if ( 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"); - fprintf( fport,"%i\n\r", new_header_sip_port ); - fclose( fport ); + if ( 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"); - fprintf( fsip,"%s\n\r", new_server_ip ); - fclose( fsip ); + if ( 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"); - fprintf( fserext , "%i\n\r", new_server_ext ); - fclose( fserext ); + if ( 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"); - fprintf(fsport,"%i\n\r", new_server_port ); - fclose( fsport ); + if ( fsport ) + { + fprintf(fsport,"%i\n\r", new_server_port ); + fclose( fsport ); + } } void set_mask( char * new_mask ){ FILE * fmask = fopen("/qspi/mymask.txt", "w"); - fprintf(fmask,"%s\n\r",new_mask ); - fclose( fmask ); + if ( 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"); - fprintf(fgate,"%s\n\r", new_gateway ); - fclose( fgate ); + if ( 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" ); - fprintf( fudpport, "%i\n\r",new_udp_port_listener ); - fclose( fudpport ); + if ( 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" ); - 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 ); + if ( ftcpport ) + { + fprintf( ftcpport, "%i\n\r",new_tcp_port_listener ); + fclose( ftcpport ); + } } -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_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_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 ){ +void set_fw_port( const int new_fw_port ){ FILE * ffwport = fopen("/qspi/fw_port.txt", "w" ); - fprintf(ffwport,"%i\n\r", new_fw_port ); - fclose( ffwport ); + if ( 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 ) 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( 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