*
* 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.
*
*
**************************************************************************/
*
*
*****************************************************************************/
+
+#ifdef HAVE_CONFIG_H
+# include "config.h"
+#endif
+
#include <stdlib.h>
#include <time.h>
#include <iostream>
#include <algorithm>
#include <plib/sg.h>
+#include <plib/ul.h>
#include <simgear/compiler.h>
#include <simgear/math/polar3d.hxx>
#include <AIModel/AIFlightPlan.hxx>
#include <AIModel/AIBase.hxx>
#include <Airports/simple.hxx>
-#include <Main/fg_init.hxx> // That's pretty ugly, but I need fgFindAirportID
+#include <Main/fg_init.hxx>
*****************************************************************************/
FGTrafficManager::FGTrafficManager()
{
+ score = 0;
+ runCount = 0;
+}
+
+FGTrafficManager:: ~FGTrafficManager()
+{
+ for (ScheduleVectorIterator sched = scheduledAircraft.begin(); sched != scheduledAircraft.end(); sched++)
+ {
+ delete (*sched);
+ }
+ scheduledAircraft.clear();
+ // for (FGScheduledFlightVecIterator flt = flights.begin(); flt != flights.end(); flt++)
+// {
+// delete (*flt);
+// }
+// flights.clear();
}
void FGTrafficManager::init()
{
//cerr << "Initializing Schedules" << endl;
- time_t now = time(NULL) + fgGetLong("/sim/time/warp");
- currAircraft = scheduledAircraft.begin();
- while (currAircraft != scheduledAircraft.end())
+ //time_t now = time(NULL) + fgGetLong("/sim/time/warp");
+ //currAircraft = scheduledAircraft.begin();
+ //while (currAircraft != scheduledAircraft.end())
+ // {
+ // if (!(currAircraft->init()))
+ // {
+ // currAircraft=scheduledAircraft.erase(currAircraft);
+ // //cerr << "Erasing " << currAircraft->getRegistration() << endl;
+ // }
+ // else
+ // {
+ // currAircraft++;
+ // }
+ // }
+ // Sort by points: Aircraft with frequent visits to the
+ // startup airport will be processed first
+ ulDir* d, *d2;
+ ulDirEnt* dent, *dent2;
+ SGPath aircraftDir = globals->get_fg_root();
+
+ /* keep the following three lines (which mimicks the old "fixed path" behavior)
+ * until we have some AI models with traffic in the base package
+ */
+ SGPath path = aircraftDir;
+ path.append("Traffic/fgtraffic.xml");
+ if (path.exists())
+ readXML(path.str(),*this);
+
+ aircraftDir.append("AI/Aircraft");
+ if (aircraftDir.exists())
{
- if (!(currAircraft->init()))
- {
- currAircraft=scheduledAircraft.erase(currAircraft);
- //cerr << "Erasing " << currAircraft->getRegistration() << endl;
- currAircraft--;
- }
- else
- {
- currAircraft++;
- }
+ if((d = ulOpenDir(aircraftDir.c_str())) == NULL)
+ return;
+ while((dent = ulReadDir(d)) != NULL) {
+ //cerr << "Scanning : " << dent->d_name << endl;
+ 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"))
+ {
+ //cerr << "found " << dent2->d_name << " for parsing" << endl;
+ 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);
}
- //cerr << "Sorting by distance " << endl;
- sort(scheduledAircraft.begin(), scheduledAircraft.end());
+ // Sort by points: Aircraft with frequent visits to the
+ // startup airport will be processed first
+ sort(scheduledAircraft.begin(), scheduledAircraft.end(), compareSchedules);
currAircraft = scheduledAircraft.begin();
currAircraftClosest = scheduledAircraft.begin();
//cerr << "Done initializing schedules" << endl;
}
-void FGTrafficManager::update(double something)
+void FGTrafficManager::update(double /*dt*/)
{
+ //SG_LOG( SG_GENERAL, SG_INFO, "Running TrafficManager::Update() ");
+ // Hack alert: Skip running for the first frames 1000 after
+ // initialization to allow proper initialization of wheather stuff
+ // and runway assignments
+ if (runCount < 1000)
+ {
+ runCount++;
+ return;
+ }
+ //runCount = 0;
time_t now = time(NULL) + fgGetLong("/sim/time/warp");
+ if (scheduledAircraft.size() == 0) {
+ //SG_LOG( SG_GENERAL, SG_INFO, "Returned Running TrafficManager::Update() ");
+ return;
+ }
if(currAircraft == scheduledAircraft.end())
{
//cerr << "resetting schedule " << endl;
currAircraft = scheduledAircraft.begin();
}
- if (!(currAircraft->update(now)))
+ if (!((*currAircraft)->update(now)))
{
// after proper initialization, we shouldnt get here.
// But let's make sure
- cerr << "Failed to update aircraft schedule in traffic manager" << endl;
+ SG_LOG( SG_GENERAL, SG_ALERT, "Failed to update aircraft schedule in traffic manager");
}
currAircraft++;
+ //SG_LOG( SG_GENERAL, SG_INFO, "Done Running TrafficManager::Update() ");
}
void FGTrafficManager::release(int id)
//cerr << "Pusing back flight " << callsign << endl;
//cerr << callsign << " " << fltrules << " "<< departurePort << " " << arrivalPort << " "
// << cruiseAlt << " " << departureTime<< " "<< arrivalTime << " " << repeat << endl;
- flights.push_back(FGScheduledFlight(callsign,
+
+ //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,
else if (element == string("aircraft"))
{
//cerr << "Pushing back aircraft " << registration << endl;
- scheduledAircraft.push_back(FGAISchedule(mdl,
+ scheduledAircraft.push_back(new FGAISchedule(mdl,
livery,
registration,
heavy,
flighttype,
radius,
offset,
+ score,
flights));
- while(flights.begin() != flights.end())
- flights.pop_back();
+ // while(flights.begin() != flights.end()) {
+// flights.pop_back();
+// }
+ 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::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 << ')');
}
projects / flightgear.git / blobdiff