Support scenery reloading (needs simgear update).

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

diff --git a/src/Main/fg_io.cxx b/src/Main/fg_io.cxx
index dda35d069d4d0ce44bdb5109ea9778b722f87cdb..47c302f8763b8a043f6ef929dde1007bbcc5dfc1 100644 (file)
--- a/src/Main/fg_io.cxx
+++ b/src/Main/fg_io.cxx
@@ -65,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"
@@ -213,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;
        }
@@ -223,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;
@@ -253,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" ) {
@@ -262,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;
@@ -306,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
@@ -339,30 +348,31 @@ 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();
 
     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