X-Git-Url: http://gitweb.hachti.de/?a=blobdiff_plain;f=pc-tools%2Fldc2%2Fsrc%2Fmain.cpp;h=068ca6e22439e3649ca89c65f6da2fd322ba07e8;hb=fed2c751d37bf5e314fd26c98909471157cc86c0;hp=3e1244b19e98690c7456d1682e49238ebf4321bb;hpb=ad324d29d885b9af1608a6e9c1f978bdcd202eb7;p=h316.git diff --git a/pc-tools/ldc2/src/main.cpp b/pc-tools/ldc2/src/main.cpp index 3e1244b..068ca6e 100644 --- a/pc-tools/ldc2/src/main.cpp +++ b/pc-tools/ldc2/src/main.cpp @@ -10,88 +10,345 @@ #include #include "tape_block.hh" -#include "argument_reader.hh" +#include "data_block_0.hh" + +#include "configuration_manager.hh" using namespace std; +static int in_fd, out_fd; + + int dump_vector(vector arguments){ int res=0; for (vector::iterator iter=arguments.begin();iter","File from where data is read",&infile_set,&infile); - ar.add_argument("","File to where output is redirected",&outfile_set,&outfile); + ar.add_option_switch("g","ignore_object_integrity_errors", + "Ignore errors caused by objects without proper end block. \ +Errors will be converted to warnings.", + &ignore_object_integrity_errors,true,true); + ar.add_option_switch("v","verbose", + "Be a bit more verbose.", + &verbose,true,true); + + ar.add_option_value("i","in_file", + "specify input file", + &infile_set,&infile, + "",true,false); + + ar.add_option_value("o","out_file", + "Specify output file.", + &outfile_set,&outfile, + "",true,true); + + ar.add_argument("File from where data is read", + &infile_set,&infile, + ""); + + ar.add_argument("File to where output is redirected", + &outfile_set,&outfile, + ""); + + ar.add_option_value("F","config_file", + "Use the specified configuration file.", + &config_file_set,&config_file, + "",false,true); - if((dump_vector(ar.read_args(argc,args))||help_wanted)){ + + // If there's a config file mentioned in the environment, take it! + char * env_ldc_config=getenv("LDC_CONFIG"); + if(env_ldc_config){ + fprintf(stderr,"Using config file:\"%s\"\n",env_ldc_config); + if(dump_vector(ar.read_file(env_ldc_config))){ + dump_vector(ar.get_help()); + exit(1); + } + } + + // Process command line first time + if(dump_vector(ar.read_args(argc,args))){ dump_vector(ar.get_help()); - exit(1); + exit(7); } - if(greet_want)printf("Hallo!\n"); + if (do_help) { + dump_vector(ar.get_help()); + exit(0); + } + + // If user has a config file, use it. + if (config_file_set){ + fprintf(stderr,"Using config file:\"%s\"\n",config_file.c_str()); + if(dump_vector(ar.read_file(config_file))){ + dump_vector(ar.get_help()); + exit(7); + } + + // Process command line a second time to override values from config file. + if(dump_vector(ar.read_args(argc,args))||do_help){ + dump_vector(ar.get_help()); + exit(7); + } + } + if (infile_set==1){ - printf("Opening file for input:%s\n",infile.c_str()); + fprintf(stderr,"Opening file for input:%s\n",infile.c_str()); in_fd=open(infile.c_str(),O_RDONLY); if (in_fd<0){ - printf("Error: could not open file:%s\n",infile.c_str()); - exit (3); + fprintf(stderr,"Error: could not open file \"%s\" for reading!\n",infile.c_str()); + exit (1); } } - vector tape; + if (outfile_set==1){ + fprintf(stderr,"Opening file for output:%s\n",outfile.c_str()); + out_fd=open(outfile.c_str(),O_WRONLY|O_TRUNC); + if (out_fd<0){ + fprintf(stderr,"Error: could not open file \"%s\" for writing!\n",outfile.c_str()); + exit (1); + } + } + // The configuration implications according to /cfg007/ + if (in_fd==0) pause_on_checksum_error=0; + if (pause_on_checksum_error==1) ignore_checksum_errors=1; + if (output_info||output_called||output_exported||output_unsatisfied) + list_contents=0; + + + // Now we go to read the data! + + vector tape; + vector > objects; + vector current_object; tape_block * block=0; - while(1){ + bool read_ahead=true; + int read_pointer=0; + int block_start=0; + int block_end=0; + int blocks_read=0; + bool in_object=false; + int errors=0; + int warnings=0; + int errcode=0; + + while(read_ahead){ block=tape_block::gen_from_fd(in_fd); - if (block->get_state()==tape_block::TBS_OK){ + + block_start=read_pointer+block->get_discarded_bytes(); + block_end=block_start+block->get_raw_size()-1; + read_pointer=block_end+1; + //printf("Discarded:%2x, Raw Size:%2x\n",block->get_discarded_bytes(),block->get_raw_size()); + switch(block->get_state()){ // switchy + case tape_block::TBS_EOF_LEGAL: + delete block; + if (!in_object){ + fprintf(stderr,"File successfully read.\n"); + } else { + if (ignore_object_integrity_errors){ + fprintf(stderr,"Warning: Object integrity check failed!\n"); + warnings++; + } else { + fprintf(stderr,"Error: Object integrity check failed!\n"); + errors++; + errcode=6; + } + } + read_ahead=false; + break; + case tape_block::TBS_EOF_ILLEGAL: + delete block; + if (ignore_block_errors){ + fprintf(stderr,"Warning: Block integrity check failed!\n"); + warnings++; + } else { + fprintf(stderr,"Error: Block integrity check failed!\n"); + errors++; + errcode=3; + } + read_ahead=false; + break; + case tape_block::TBS_CHECKSUM: + delete block; + if (ignore_checksum_errors){ + fprintf(stderr,"Warning: Block checksum wrong!\n"); + warnings++; + } else { + fprintf(stderr,"Error: Block checksum wrong!\n"); + errors++; + read_ahead=false; + errcode=4; + } + break; + case tape_block::TBS_DEFAULT: + delete block; + fprintf(stderr,"TBS_DEFAULT encountered ->> SEVERE INTERNAL ERROR!\n"); + errors++; + errcode=100; + read_ahead=false; + break; + case tape_block::TBS_IOERR: + delete block; + if (in_fd){ + fprintf(stderr,"Error: Could not read from \"%s\"!\n",infile.c_str()); + } else { + fprintf(stderr,"Error: Could not read from stdin!\n"); + } + errors++; + read_ahead=false; + errcode=2; + case tape_block::TBS_OK: tape.insert(tape.end(),block); - dump_vector(block->get_description()); - } - else break; - } + blocks_read++; + + if (verbose){ + char buffer[200]; + snprintf(buffer,200,"Block No. %3i: Start(hex):%5x End(hex):%5x Size(hex):%3x\n", + blocks_read-1, + block_start, + block_end, + block->get_raw_size()); + write (out_fd,buffer,strlen(buffer)); + } + + if(list_contents) + dump_vector(block->get_description()); + + if (block->get_type()==0x10){ // Unknown data block! + if (ignore_unknown_block_errors){ + fprintf(stderr,"Warning: Unknown block type!\n"); + warnings++; + }else { + fprintf(stderr,"Error: Unknown block type!\n"); + errors++; + errcode=5; + read_ahead=false; + } + } + + current_object.insert(current_object.end(),block); + + if ((block->get_type()==data_block::TBT_EOT) + ||((block->get_type()==0)&&(block->get_subtype()==3)) + ||((block->get_type()==4)||(block->get_type()==3)) + ||((block->get_type()==0)&&(block->get_subtype()==014))){ + in_object=false; + objects.insert(objects.end(),current_object); + current_object.clear(); + } else { + in_object=true; + } + + break; + } // switch + } // generate loop + close(in_fd); - switch(block->get_state()){ - case tape_block::TBS_EOF_LEGAL: printf("File successfully read.\n"); - break; - case tape_block::TBS_EOF_ILLEGAL: printf("EOF while in block!\n"); - break; - case tape_block::TBS_CHECKSUM: - printf("Checksum error!\n"); - break; - case tape_block::TBS_DEFAULT: - printf("TBS_DEFAULT encountered ->> SEVERY INTERNAL ERROR!\n"); - exit(88); - case tape_block::TBS_IOERR: - printf("I/O Error... Why?\n"); - exit (43); + // Now we have our blocks, tell the user about that! + char buffer[200]; + sprintf(buffer,"Bytes read:%i Blocks read:%i\nErrors:%i Warnings:%i\n", + read_pointer,blocks_read,errors,warnings); + if(output_info){ + write (out_fd,buffer,strlen(buffer)); + } else { + fprintf(stderr,buffer); + } + + if (errors>0){ + fprintf(stderr,"Errors make me sick. Goodbye!\n"); + exit(errcode); } + return 0; } // main()