Changeset 535:f42fe0ead68f for src/mlx


Ignore:
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:
1 added
3 edited

Legend:

Unmodified
Added
Removed
  • src/mlx/fsuipc.py

    r530 r535  
    44import util
    55import acft
     6from watchdog import Watchdog
    67
    78import threading
     
    244245        self._periodicRequests = []
    245246
     247        self._watchdogClient = Watchdog.get().addClient(2.0, "fsuipc.Handler")
     248
    246249        self.daemon = True
    247250
     
    441444        needReconnect = False
    442445        try:
     446            self._watchdogClient.set()
    443447            try:
    444448                if not request.process(time):
     
    459463                return 0
    460464        finally:
     465            self._watchdogClient.clear()
    461466            self._requestCondition.acquire()
    462467
  • src/mlx/mlx.py

    r402 r535  
    55from util import secondaryInstallation
    66from const import VERSION
     7from watchdog import Watchdog
    78
    89import os
     
    9091
    9192    try:
     93        Watchdog().start()
     94
    9295        gui.build(programDirectory)
    9396
  • src/mlx/xplane.py

    r505 r535  
    33import const
    44import util
     5from watchdog import Watchdog
    56
    67import threading
     
    341342        self._periodicRequests = []
    342343
     344        self._watchdogClient = Watchdog.get().addClient(2.0, "xplane.Handler")
     345
    343346        self.daemon = True
    344347
     
    571574        needReconnect = False
    572575        try:
     576            self._watchdogClient.set()
    573577            try:
    574578                if not request.process(time):
     
    589593                return 0
    590594        finally:
     595            self._watchdogClient.clear()
    591596            self._requestCondition.acquire()
    592597
Note: See TracChangeset for help on using the changeset viewer.