X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FTraffic%2FTrafficMgr.cxx;h=07d0cd0ab2626f0ac1c4842f8f8377ff4c3f171f;hb=f9de92f53db91c45e4bd885ba606749e9597fdbb;hp=07f804b2b80b385710f4bb9d0f04f2879cc95d88;hpb=b3e969726249e772da4c9d1aa6eb212e6472aed3;p=flightgear.git diff --git a/src/Traffic/TrafficMgr.cxx b/src/Traffic/TrafficMgr.cxx index 07f804b2b..07d0cd0ab 100644 --- a/src/Traffic/TrafficMgr.cxx +++ b/src/Traffic/TrafficMgr.cxx @@ -14,14 +14,16 @@ * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * * **************************************************************************/ -/* This a prototype version of a top-level flight plan manager for Flightgear. - * It parses the fgtraffic.txt file and determine for a specific time/date, - * where each aircraft listed in this file is at the current time. +/* + * Traffic manager parses airlines timetable-like data and uses this to + * determine the approximate position of each AI aircraft in its database. + * When an AI aircraft is close to the user's position, a more detailed + * AIModels based simulation is set up. * * I'm currently assuming the following simplifications: * 1) The earth is a perfect sphere @@ -33,6 +35,11 @@ * * *****************************************************************************/ + +#ifdef HAVE_CONFIG_H +# include "config.h" +#endif + #include #include #include @@ -41,56 +48,310 @@ #include #include +#include #include +#include #include #include #include +#include #include #include #include #include +#include #include -#include +#include #include -#include
// That's pretty ugly, but I need fgFindAirportID +#include
#include "TrafficMgr.hxx" +using std::sort; /****************************************************************************** * TrafficManager *****************************************************************************/ FGTrafficManager::FGTrafficManager() { + //score = 0; + //runCount = 0; + acCounter = 0; +} + +FGTrafficManager:: ~FGTrafficManager() +{ + for (ScheduleVectorIterator sched = scheduledAircraft.begin(); sched != scheduledAircraft.end(); sched++) + { + delete (*sched); + } + scheduledAircraft.clear(); + flights.clear(); } void FGTrafficManager::init() -{ - currAircraft = scheduledAircraft.begin(); +{ + ulDir* d, *d2; + ulDirEnt* dent, *dent2; + SGPath aircraftDir = globals->get_fg_root(); + + SGPath path = aircraftDir; + + aircraftDir.append("AI/Traffic"); + if ((d = ulOpenDir(aircraftDir.c_str())) != NULL) + { + while((dent = ulReadDir(d)) != NULL) { + if (string(dent->d_name) != string(".") && + string(dent->d_name) != string("..") && + dent->d_isdir) + { + SGPath currACDir = aircraftDir; + currACDir.append(dent->d_name); + if ((d2 = ulOpenDir(currACDir.c_str())) == NULL) + return; + while ((dent2 = ulReadDir(d2)) != NULL) { + SGPath currFile = currACDir; + currFile.append(dent2->d_name); + if (currFile.extension() == string("xml")) + { + SGPath currFile = currACDir; + currFile.append(dent2->d_name); + SG_LOG(SG_GENERAL, SG_INFO, "Scanning " << currFile.str() << " for traffic"); + readXML(currFile.str(),*this); + } + } + ulCloseDir(d2); + } + } + ulCloseDir(d); + } + time_t now = time(NULL) + fgGetLong("/sim/time/warp"); + + currAircraft = scheduledAircraft.begin(); + currAircraftClosest = scheduledAircraft.begin(); } -void FGTrafficManager::update(double something) +void FGTrafficManager::update(double /*dt*/) { - //static const SGPropertyNode *warp = globals->get_props()->getNode("/sim/time/warp"); - - //time_t now = time(NULL) + globals->get_warp(); time_t now = time(NULL) + fgGetLong("/sim/time/warp"); - // cerr << "TrafficManager update" << globals->get_warp() << endl; - if(currAircraft == scheduledAircraft.end()) + if (scheduledAircraft.size() == 0) { + return; + } + if(currAircraft == scheduledAircraft.end()) + { currAircraft = scheduledAircraft.begin(); - currAircraft->update(now); - currAircraft++; + } + if (!((*currAircraft)->update(now))) + { + // NOTE: With traffic manager II, this statement below is no longer true + // after proper initialization, we shouldnt get here. + // But let's make sure + //SG_LOG( SG_GENERAL, SG_ALERT, "Failed to update aircraft schedule in traffic manager"); + } + currAircraft++; } +void FGTrafficManager::release(int id) +{ + releaseList.push_back(id); +} + +bool FGTrafficManager::isReleased(int id) +{ + IdListIterator i = releaseList.begin(); + while (i != releaseList.end()) + { + if ((*i) == id) + { + releaseList.erase(i); + return true; + } + i++; + } + return false; +} +/* +void FGTrafficManager::readTimeTableFromFile(SGPath infileName) +{ + string model; + string livery; + string homePort; + string registration; + string flightReq; + bool isHeavy; + string acType; + string airline; + string m_class; + string FlightType; + double radius; + double offset; + + char buffer[256]; + string buffString; + vector tokens, depTime,arrTime; + vector ::iterator it; + ifstream infile(infileName.str().c_str()); + while (1) { + infile.getline(buffer, 256); + if (infile.eof()) { + break; + } + //cerr << "Read line : " << buffer << endl; + buffString = string(buffer); + tokens.clear(); + Tokenize(buffString, tokens, " \t"); + //for (it = tokens.begin(); it != tokens.end(); it++) { + // cerr << "Tokens: " << *(it) << endl; + //} + //cerr << endl; + if (!tokens.empty()) { + if (tokens[0] == string("AC")) { + if (tokens.size() != 13) { + SG_LOG(SG_GENERAL, SG_ALERT, "Error parsing traffic file " << infileName.str() << " at " << buffString); + exit(1); + } + model = tokens[12]; + livery = tokens[6]; + homePort = tokens[1]; + registration = tokens[2]; + if (tokens[11] == string("false")) { + isHeavy = false; + } else { + isHeavy = true; + } + acType = tokens[4]; + airline = tokens[5]; + flightReq = tokens[3] + tokens[5]; + m_class = tokens[10]; + FlightType = tokens[9]; + radius = atof(tokens[8].c_str()); + offset = atof(tokens[7].c_str());; + //cerr << "Found AC string " << model << " " << livery << " " << homePort << " " + // << registration << " " << flightReq << " " << isHeavy << " " << acType << " " << airline << " " << m_class + // << " " << FlightType << " " << radius << " " << offset << endl; + scheduledAircraft.push_back(new FGAISchedule(model, + livery, + homePort, + registration, + flightReq, + isHeavy, + acType, + airline, + m_class, + FlightType, + radius, + offset)); + } + if (tokens[0] == string("FLIGHT")) { + //cerr << "Found flight " << buffString << " size is : " << tokens.size() << endl; + if (tokens.size() != 10) { + SG_LOG(SG_GENERAL, SG_ALERT, "Error parsing traffic file " << infileName.str() << " at " << buffString); + exit(1); + } + string callsign = tokens[1]; + string fltrules = tokens[2]; + string weekdays = tokens[3]; + string departurePort = tokens[5]; + string arrivalPort = tokens[7]; + int cruiseAlt = atoi(tokens[8].c_str()); + string depTimeGen = tokens[4]; + string arrTimeGen = tokens[6]; + string repeat = "WEEK"; + string requiredAircraft = tokens[9]; + + if (weekdays.size() != 7) { + cerr << "Found misconfigured weekdays string" << weekdays << endl; + exit(1); + } + depTime.clear(); + arrTime.clear(); + Tokenize(depTimeGen, depTime, ":"); + Tokenize(arrTimeGen, arrTime, ":"); + double dep = atof(depTime[0].c_str()) + (atof(depTime[1].c_str()) / 60.0); + double arr = atof(arrTime[0].c_str()) + (atof(arrTime[1].c_str()) / 60.0); + //cerr << "Using " << dep << " " << arr << endl; + bool arrivalWeekdayNeedsIncrement = false; + if (arr < dep) { + arrivalWeekdayNeedsIncrement = true; + } + for (int i = 0; i < 7; i++) { + if (weekdays[i] != '.') { + char buffer[4]; + snprintf(buffer, 4, "%d/", i); + string departureTime = string(buffer) + depTimeGen + string(":00"); + string arrivalTime; + if (!arrivalWeekdayNeedsIncrement) { + arrivalTime = string(buffer) + arrTimeGen + string(":00"); + } + if (arrivalWeekdayNeedsIncrement && i != 6 ) { + snprintf(buffer, 4, "%d/", i+1); + arrivalTime = string(buffer) + arrTimeGen + string(":00"); + } + if (arrivalWeekdayNeedsIncrement && i == 6 ) { + snprintf(buffer, 4, "%d/", 0); + arrivalTime = string(buffer) + arrTimeGen + string(":00"); + } + cerr << "Adding flight: " << callsign << " " + << fltrules << " " + << departurePort << " " + << arrivalPort << " " + << cruiseAlt << " " + << departureTime << " " + << arrivalTime << " " + << repeat << " " + << requiredAircraft << endl; + + flights[requiredAircraft].push_back(new FGScheduledFlight(callsign, + fltrules, + departurePort, + arrivalPort, + cruiseAlt, + departureTime, + arrivalTime, + repeat, + requiredAircraft)); + } + } + } + } + + } + //exit(1); +}*/ + +/* +void FGTrafficManager::Tokenize(const string& str, + vector& tokens, + const string& delimiters) +{ + // Skip delimiters at beginning. + string::size_type lastPos = str.find_first_not_of(delimiters, 0); + // Find first "non-delimiter". + string::size_type pos = str.find_first_of(delimiters, lastPos); + + while (string::npos != pos || string::npos != lastPos) + { + // Found a token, add it to the vector. + tokens.push_back(str.substr(lastPos, pos - lastPos)); + // Skip delimiters. Note the "not_of" + lastPos = str.find_first_not_of(delimiters, pos); + // Find next "non-delimiter" + pos = str.find_first_of(delimiters, lastPos); + } +} +*/ + void FGTrafficManager::startXML () { //cout << "Start XML" << endl; + requiredAircraft = ""; + homePort = ""; } void FGTrafficManager::endXML () { @@ -107,24 +368,44 @@ void FGTrafficManager::startElement (const char * name, const XMLAttributes &at if (attval != 0) { //cout << "including " << attval << endl; - string path = - globals->get_fg_root() + - string("/Traffic/") + - string(attval); - readXML(path, *this); + SGPath path = + globals->get_fg_root(); + path.append("/Traffic/"); + path.append(attval); + readXML(path.str(), *this); } + elementValueStack.push_back( "" ); // cout << " " << atts.getName(i) << '=' << atts.getValue(i) << endl; } void FGTrafficManager::endElement (const char * name) { //cout << "End element " << name << endl; string element(name); + string value = elementValueStack.back(); + elementValueStack.pop_back(); + if (element == string("model")) mdl = value; else if (element == string("livery")) livery = value; + else if (element == string("home-port")) + homePort = value; else if (element == string("registration")) registration = value; + else if (element == string("airline")) + airline = value; + else if (element == string("actype")) + acType = value; + else if (element == string("required-aircraft")) + requiredAircraft = value; + else if (element == string("flighttype")) + flighttype = value; + else if (element == string("radius")) + radius = atoi(value.c_str()); + else if (element == string("offset")) + offset = atoi(value.c_str()); + else if (element == string("performance-class")) + m_class = value; else if (element == string("heavy")) { if(value == string("true")) @@ -161,35 +442,107 @@ void FGTrafficManager::endElement (const char * name) { //cerr << "Pusing back flight " << callsign << endl; //cerr << callsign << " " << fltrules << " "<< departurePort << " " << arrivalPort << " " // << cruiseAlt << " " << departureTime<< " "<< arrivalTime << " " << repeat << endl; - flights.push_back(FGScheduledFlight(callsign, - fltrules, - departurePort, - arrivalPort, - cruiseAlt, - departureTime, - arrivalTime, - repeat)); + + //Prioritize aircraft + string apt = fgGetString("/sim/presets/airport-id"); + //cerr << "Airport information: " << apt << " " << departurePort << " " << arrivalPort << endl; + //if (departurePort == apt) score++; + //flights.push_back(new FGScheduledFlight(callsign, + // fltrules, + // departurePort, + // arrivalPort, + // cruiseAlt, + // departureTime, + // arrivalTime, + // repeat)); + if (requiredAircraft == "") { + char buffer[16]; + snprintf(buffer, 16, "%d", acCounter); + requiredAircraft = buffer; } + SG_LOG(SG_GENERAL, SG_DEBUG, "Adding flight: " << callsign << " " + << fltrules << " " + << departurePort << " " + << arrivalPort << " " + << cruiseAlt << " " + << departureTime << " " + << arrivalTime << " " + << repeat << " " + << requiredAircraft); + + flights[requiredAircraft].push_back(new FGScheduledFlight(callsign, + fltrules, + departurePort, + arrivalPort, + cruiseAlt, + departureTime, + arrivalTime, + repeat, + requiredAircraft)); + requiredAircraft = ""; + } else if (element == string("aircraft")) { - //cerr << "Pushing back aircraft " << registration << endl; - scheduledAircraft.push_back(FGAISchedule(mdl, - livery, - registration, - heavy, - flights)); - while(flights.begin() != flights.end()) - flights.pop_back(); + int proportion = (int) (fgGetDouble("/sim/traffic-manager/proportion") * 100); + int randval = rand() & 100; + if (randval < proportion) { + //scheduledAircraft.push_back(new FGAISchedule(mdl, + // livery, + // registration, + // heavy, + // acType, + // airline, + // m_class, + // flighttype, + // radius, + // offset, + // score, + // flights)); + if (requiredAircraft == "") { + char buffer[16]; + snprintf(buffer, 16, "%d", acCounter); + requiredAircraft = buffer; + } + if (homePort == "") { + homePort = departurePort; + } + scheduledAircraft.push_back(new FGAISchedule(mdl, + livery, + homePort, + registration, + requiredAircraft, + heavy, + acType, + airline, + m_class, + flighttype, + radius, + offset)); + + // while(flights.begin() != flights.end()) { +// flights.pop_back(); +// } + } + acCounter++; + requiredAircraft = ""; + homePort = ""; + //for (FGScheduledFlightVecIterator flt = flights.begin(); flt != flights.end(); flt++) + // { + // delete (*flt); + // } + //flights.clear(); + SG_LOG( SG_GENERAL, SG_BULK, "Reading aircraft : " + << registration + << " with prioritization score " + << score); + score = 0; } } void FGTrafficManager::data (const char * s, int len) { string token = string(s,len); //cout << "Character data " << string(s,len) << endl; - if ((token.find(" ") == string::npos && (token.find('\n')) == string::npos)) - value += token; - else - value = string(""); + elementValueStack.back() += token; } void FGTrafficManager::pi (const char * target, const char * data) { @@ -197,11 +550,10 @@ void FGTrafficManager::pi (const char * target, const char * data) { } void FGTrafficManager::warning (const char * message, int line, int column) { - cout << "Warning: " << message << " (" << line << ',' << column << ')' - << endl; + SG_LOG(SG_IO, SG_WARN, "Warning: " << message << " (" << line << ',' << column << ')'); } void FGTrafficManager::error (const char * message, int line, int column) { - cout << "Error: " << message << " (" << line << ',' << column << ')' - << endl; + SG_LOG(SG_IO, SG_ALERT, "Error: " << message << " (" << line << ',' << column << ')'); } +