Changeset 535:f42fe0ead68f for src/mlx

Timestamp:

09/01/13 09:15:58 (11 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

Implemented watchdog monitoring the FSUIPC and X-Plane connection handlers

Location:

src/mlx

Files:

• fsuipc.py (modified) (4 diffs)
• mlx.py (modified) (2 diffs)
• watchdog.py (added)
• xplane.py (modified) (4 diffs)

src/mlx/fsuipc.py

@@ -4 +4 @@
 import util
 import acft
+from watchdog import Watchdog
 
 import threading
@@ -244 +245 @@
         self._periodicRequests = []
 
+        self._watchdogClient = Watchdog.get().addClient(2.0, "fsuipc.Handler")
+
         self.daemon = True
 
@@ -441 +444 @@
         needReconnect = False
         try:
+            self._watchdogClient.set()
             try:
                 if not request.process(time):
@@ -459 +463 @@
                 return 0
         finally:
+            self._watchdogClient.clear()
             self._requestCondition.acquire()
 

src/mlx/mlx.py

@@ -5 +5 @@
 from util import secondaryInstallation
 from const import VERSION
+from watchdog import Watchdog
 
 import os
@@ -90 +91 @@
 
     try:
+        Watchdog().start()
+
         gui.build(programDirectory)
 

src/mlx/xplane.py

@@ -3 +3 @@
 import const
 import util
+from watchdog import Watchdog
 
 import threading
@@ -341 +342 @@
         self._periodicRequests = []
 
+        self._watchdogClient = Watchdog.get().addClient(2.0, "xplane.Handler")
+
         self.daemon = True
 
@@ -571 +574 @@
         needReconnect = False
         try:
+            self._watchdogClient.set()
             try:
                 if not request.process(time):
@@ -589 +593 @@
                 return 0
         finally:
+            self._watchdogClient.clear()
             self._requestCondition.acquire()