Changeset 148:453ebaea9090 for src/mlx/fsuipc.py

Timestamp:

05/03/12 18:27:13 (12 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

hg-Phase:

(<MercurialRepository 1 'hg:/home/ivaradi/mlx/hg' '/'>, 'public')

Message:

Implemented FS time synchronization

File:

• src/mlx/fsuipc.py (modified) (6 diffs)

src/mlx/fsuipc.py

@@ -471 +471 @@
                    (0x0580, "d") ]           # Heading
 
+    TIME_SYNC_INTERVAL = 3.0
+
     @staticmethod
     def _getTimestamp(data):
@@ -514 +516 @@
         self._scroll = False
 
+        self._syncTime = False
+        self._nextSyncTime = -1
+        
         self._normalRequestID = None
 
@@ -536 +541 @@
         self._handler.connect()
         if self._normalRequestID is None:
+            self._nextSyncTime = -1
             self._startDefaultNormal()
 
@@ -638 +644 @@
             data.append( (offset, "u", long(level * 128.8 * 65536.0)) )
         self._handler.requestWrite(data, self._handleFuelWritten)
+
+    def enableTimeSync(self):
+        """Enable the time synchronization."""
+        self._nextSyncTime = -1
+        self._syncTime = True
+            
+    def disableTimeSync(self):
+        """Enable the time synchronization."""
+        self._syncTime = False
+        self._nextSyncTime = -1
             
     def disconnect(self):
@@ -678 +694 @@
 
         self._scroll = data[7]!=0
+
+        self._checkTimeSync()
         
         if self._monitoringRequested and not self._monitoring:
@@ -691 +709 @@
             self._aircraft.handleState(aircraftState)
 
+    def _checkTimeSync(self):
+        """Check if we need to synchronize the FS time."""
+        if not self._syncTime: return
+
+        now = time.time()
+        seconds = time.gmtime(now).tm_sec
+
+        if seconds>30 and seconds<59:
+            if self._nextSyncTime > (now - 0.49):
+                return
+            
+            self._handler.requestWrite([(0x023a, "b", int(seconds))],
+                                       self._handleTimeSynced)
+            
+            #print "Set the seconds to ", seconds
+
+            if self._nextSyncTime<0:
+                self._nextSyncTime = now
+                
+            self._nextSyncTime += Simulator.TIME_SYNC_INTERVAL
+        else:
+            self._nextSyncTime = -1
+
+    def _handleTimeSynced(self, success, extra):
+        """Callback for the time sync result."""
+        pass
+        
     def _setAircraftName(self, timestamp, name, airPath):
         """Set the name of the aicraft and if it is different from the