X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FMain%2Ffg_io.cxx;h=36ca64433d3f6dc923acdfcdaa59374ea88856d7;hb=7cde2e800bccd4883f03eceb5283add24755b377;hp=82bcfeb35459a04dd48c1082d04feaae3dcbb6f6;hpb=b0bb63bf79debf3eb48fd4b21e65a2e9685f82fd;p=flightgear.git diff --git a/src/Main/fg_io.cxx b/src/Main/fg_io.cxx index 82bcfeb35..36ca64433 100644 --- a/src/Main/fg_io.cxx +++ b/src/Main/fg_io.cxx @@ -26,9 +26,9 @@ #include -#include // atoi() +#include // atoi() -#include STL_STRING +#include #include #include @@ -44,6 +44,7 @@ #include #include #include +#include #include #include #ifdef FG_JPEG_SERVER @@ -67,15 +68,16 @@ #include "globals.hxx" #include "fg_io.hxx" -SG_USING_STD(string); +using std::atoi; +using std::string; FGIO::FGIO() { } -#include STL_ALGORITHM -SG_USING_STD(for_each); +#include +using std::for_each; static void delete_ptr( FGProtocol* p ) { delete p; } @@ -135,6 +137,9 @@ FGIO::parse_port_config( const string& config ) } else if ( protocol == "AV400" ) { FGAV400 *av400 = new FGAV400; io = av400; + } else if ( protocol == "AV400Sim" ) { + FGAV400Sim *av400sim = new FGAV400Sim; + io = av400sim; } else if ( protocol == "garmin" ) { FGGarmin *garmin = new FGGarmin; io = garmin; @@ -182,10 +187,21 @@ FGIO::parse_port_config( const string& config ) FGRUL *rul = new FGRUL; io = rul; } else if ( protocol == "generic" ) { - int n = 6; - if (tokens[1] == "socket") n++; - else if (tokens[1] == "file") n--; - FGGeneric *generic = new FGGeneric( tokens[n] ); + size_t configToken; + if (tokens[1] == "socket") { + configToken = 7; + } else if (tokens[1] == "file") { + configToken = 5; + } else { + configToken = 6; + } + + if (configToken >= tokens.size()) { + SG_LOG( SG_IO, SG_ALERT, "Not enough tokens passed for the generic protocol."); + return NULL; + } + + FGGeneric *generic = new FGGeneric( tokens ); io = generic; } else if ( protocol == "multiplay" ) { if ( tokens.size() != 5 ) { @@ -238,6 +254,7 @@ FGIO::parse_port_config( const string& config ) string baud = tokens[5]; SG_LOG( SG_IO, SG_INFO, " baud = " << baud ); + SGSerial *ch = new SGSerial( device, baud ); io->set_io_channel( ch ); } else if ( medium == "file" ) { @@ -249,8 +266,18 @@ FGIO::parse_port_config( const string& config ) string file = tokens[4]; SG_LOG( SG_IO, SG_INFO, " file name = " << file ); - - SGFile *ch = new SGFile( file ); + int repeat = 1; + if (tokens.size() >= 7 && tokens[6] == "repeat") { + if (tokens.size() >= 8) { + repeat = atoi(tokens[7].c_str()); + FGGeneric* generic = dynamic_cast(io); + if (generic) + generic->setExitOnError(true); + } else { + repeat = -1; + } + } + SGFile *ch = new SGFile( file, repeat ); io->set_io_channel( ch ); } else if ( medium == "socket" ) { if ( tokens.size() < 6) { @@ -307,6 +334,11 @@ FGIO::init() } } +void +FGIO::reinit() +{ +} + // process any IO channel work void