Automatic tower positioning

[flightgear.git] / src / Main / fg_io.cxx

diff --git a/src/Main/fg_io.cxx b/src/Main/fg_io.cxx
index 3ab62f82df4677929c166e9977ceb0a3ea64e0b0..47c302f8763b8a043f6ef929dde1007bbcc5dfc1 100644 (file)
--- a/src/Main/fg_io.cxx
+++ b/src/Main/fg_io.cxx
@@ -29,6 +29,7 @@
 #include <cstdlib>             // atoi()
 
 #include <string>
+#include <algorithm>
 
 #include <simgear/debug/logstream.hxx>
 #include <simgear/io/iochannel.hxx>
@@ -64,6 +65,9 @@
 #include <Network/rul.hxx>
 #include <Network/generic.hxx>
 #include <Network/multiplay.hxx>
+#ifdef FG_HAVE_HLA
+#include <Network/HLA/hla.hxx>
+#endif
 
 #include "globals.hxx"
 #include "fg_io.hxx"
@@ -76,15 +80,13 @@ FGIO::FGIO()
 {
 }
 
-#include <algorithm>
-using std::for_each;
 
-static void delete_ptr( FGProtocol* p ) { delete p; }
+
+
 
 FGIO::~FGIO()
 {
-    shutdown_all();
-    for_each( io_channels.begin(), io_channels.end(), delete_ptr );
+    
 }
 
 
@@ -94,7 +96,7 @@ FGIO::parse_port_config( const string& config )
 {
     SG_LOG( SG_IO, SG_INFO, "Parse I/O channel request: " << config );
 
-    vector<string> tokens = simgear::strutils::split( config, "," );
+    string_list tokens = simgear::strutils::split( config, "," );
     if (tokens.empty())
     {
        SG_LOG( SG_IO, SG_ALERT,
@@ -214,6 +216,10 @@ FGIO::parse_port_config( const string& config )
            string host = tokens[3];
            string port = tokens[4];
            return new FGMultiplay(dir, atoi(rate.c_str()), host, atoi(port.c_str()));
+#ifdef FG_HAVE_HLA
+       } else if ( protocol == "hla" ) {
+           return new FGHLA(tokens);
+#endif
        } else {
            return NULL;
        }
@@ -224,7 +230,7 @@ FGIO::parse_port_config( const string& config )
        delete io;
        return 0;
     }
-    
+
     if (tokens.size() < 3) {
       SG_LOG( SG_IO, SG_ALERT, "Incompatible number of network arguments.");
       return NULL;
@@ -254,7 +260,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" ) {
@@ -263,7 +269,7 @@ FGIO::parse_port_config( const string& config )
           SG_LOG( SG_IO, SG_ALERT, "Incompatible number of arguments for file I/O.");
          return NULL;
         }
-         
+
        string file = tokens[4];
        SG_LOG( SG_IO, SG_INFO, "  file name = " << file );
         int repeat = 1;
@@ -307,6 +313,8 @@ FGIO::init()
     // SG_LOG( SG_IO, SG_INFO, "I/O Channel initialization, " <<
     //         globals->get_channel_options_list()->size() << " requests." );
 
+    _realDeltaTime = fgGetNode("/sim/time/delta-realtime-sec");
+    
     FGProtocol *p;
 
     // we could almost do this in a single step except pushing a valid
@@ -315,9 +323,8 @@ FGIO::init()
 
     // parse the configuration strings and store the results in the
     // appropriate FGIOChannel structures
-    typedef vector<string> container;
-    container::iterator i = globals->get_channel_options_list()->begin();
-    container::iterator end = globals->get_channel_options_list()->end();
+    string_list::iterator i = globals->get_channel_options_list()->begin();
+    string_list::iterator end = globals->get_channel_options_list()->end();
     for (; i != end; ++i )
     {
        p = parse_port_config( *i );
@@ -334,54 +341,58 @@ FGIO::init()
     }
 }
 
+void
+FGIO::reinit()
+{
+}
 
 // process any IO channel work
 void
-FGIO::update( double delta_time_sec )
+FGIO::update( double /* delta_time_sec */ )
 {
-    // cout << "processing I/O channels" << endl;
-    // cout << "  Elapsed time = " << delta_time_sec << endl;
+  // use wall-clock, not simulation, delta time, so that network
+  // protocols update when the simulation is paused
+  // see http://code.google.com/p/flightgear-bugs/issues/detail?id=125
+    double delta_time_sec = _realDeltaTime->getDoubleValue();
 
-    typedef vector< FGProtocol* > container;
-    container::iterator i = io_channels.begin();
-    container::iterator end = io_channels.end();
+    ProtocolVec::iterator i = io_channels.begin();
+    ProtocolVec::iterator end = io_channels.end();
     for (; i != end; ++i ) {
-       FGProtocol* p = *i;
-
-       if ( p->is_enabled() ) {
+      FGProtocol* p = *i;
+      if (!p->is_enabled()) {
+        continue;
+      }
+      
            p->dec_count_down( delta_time_sec );
            double dt = 1 / p->get_hz();
            if ( p->get_count_down() < 0.33 * dt ) {
              p->process();
              p->inc_count();
              while ( p->get_count_down() < 0.33 * dt ) {
-               p->inc_count_down( dt );
+          p->inc_count_down( dt );
              }
-             // double ave = elapsed_time / p->get_count();
-             // cout << "  ave rate = " << ave << endl;
-           }
-       }
-    }
+           } // of channel processing
+    } // of io_channels iteration
 }
 
-
 void
-FGIO::shutdown_all() {
+FGIO::shutdown()
+{
     FGProtocol *p;
 
-    // cout << "shutting down all I/O channels" << endl;
-
-    typedef vector< FGProtocol* > container;
-    container::iterator i = io_channels.begin();
-    container::iterator end = io_channels.end();
+    ProtocolVec::iterator i = io_channels.begin();
+    ProtocolVec::iterator end = io_channels.end();
     for (; i != end; ++i )
     {
-       p = *i;
-
-       if ( p->is_enabled() ) {
-           p->close();
-       }
+      p = *i;
+      if ( p->is_enabled() ) {
+          p->close();
+      }
+      
+      delete p;
     }
+
+  io_channels.clear();
 }
 
 void