NetBurner Community Forum

Code: Select all

#define FTP_BUFFER_SIZE  ( 500 * 1024 )
static char FTP_buffer[FTP_BUFFER_SIZE] __attribute__( ( aligned( 16 ) ) );


	int ftp = FTP_InitializeSession( AsciiToIp( SERVER_IP_ADDR ),
	                                        FTP_PORT,
	                                        USER,
	                                        PASS,
	                                        200 );

    if ( ftp > 0 ) // if the var ftp is > 0, it is the session handle
    {

		int fd = FTPGetFile(ftp, fileName, TRUE, 5 * TICKS_PER_SECOND);
		if(fd > 0)
		{
			wfile = fs_open( fileName, "w+" );

			int bytes_read;
			int bytes_written;
			int retry;
			int FtpBufIndex = 0;  // position in buffer
			   /* This loop will read the file data from the client, accumulate
			    * data until FTP_BUFFER_SIZE is reached, then write the data to
			    * flash in one write.
			    */
			   do
			   {
			      bytes_read = ReadWithTimeout( fd, FTP_buffer + FtpBufIndex,
			    		                        FTP_BUFFER_SIZE - FtpBufIndex,
			    		                        TICKS_PER_SECOND * 20 );
			      iprintf("Bytes read: %d\r\n", bytes_read );

			      if ( bytes_read > 0 )
			      {
			    	 FtpBufIndex += bytes_read;
			         iprintf( "FtpBufIndex: %d\r\n", FtpBufIndex );
			      }

			      if ( FtpBufIndex == FTP_BUFFER_SIZE )
			      {
			         bytes_written = 0;
			         retry = 0;
			         do {
			            //  buffer, size of item, number of items, file handle
			        	bytes_written = fs_write( FTP_buffer, 1, FtpBufIndex, wfile );
			        	iprintf("bytes_written: %d\r\n", bytes_written);

			            if ( bytes_written < FtpBufIndex )
			            {
			               iprintf("Retry: %d\r\n", retry);
			               OSTimeDly( TICKS_PER_SECOND / 4 );
			               retry++;
			            }
			         } while ( (bytes_written < FtpBufIndex) && ( retry < 10 ) );

			         FtpBufIndex = 0;
			      }
			   }  while ( ( bytes_read > 0 ) && ( retry < 10 ) );

			   if ( retry >= 10 )
			   {
			      iprintf("Error - could not write file: %s\r\n", file_name);
			      do {
			         bytes_read = ReadWithTimeout( fd, FTP_buffer, FTP_BUFFER_SIZE, TICKS_PER_SECOND * 2 );
			         //iprintf("Bytes read: %d\r\n", bytes_read );
			      } while ( bytes_read > 0 );

			      fs_close( wfile );
			      fs_delete( file_name );
			      return ( FTPD_FAIL );
			   }

			   iprintf("FtpBufIndex: %d\r\n", FtpBufIndex);
			   if ( FtpBufIndex )
			   {
			      bytes_written = fs_write( FTP_buffer, 1, FtpBufIndex, wfile );
			      iprintf( "wrote %d bytes\r\n", bytes_written );
			      if ( bytes_written < FtpBufIndex )
			      {
			         iprintf("Error - could not write file: %s\r\n", file_name);
			         do {
			            bytes_read = ReadWithTimeout( fd, FTP_buffer, FTP_BUFFER_SIZE, TICKS_PER_SECOND * 2 );
			            //iprintf("Bytes read: %d\r\n", bytes_read );
			         } while ( bytes_read > 0 );
			         fs_close( wfile );
			         fs_delete( file_name );
			         return ( FTPD_FAIL );
			      }
			   }

			   fs_close( wfile );
			   return( FTPD_OK );
		}
    }

Code: Select all

			
close(fd);

rv = FTPGetCommandResult( ftp, tmp_resultbuff, 255, 5 * TICKS_PER_SECOND );
if ( rv != 226 )
{

sprintf(buffer,"\n\r1Error Command result = %d %s\r\n",rv,tmp_resultbuff);
writestring(fdDebugSerial,buffer);

}

}