reorganize the release-function
This commit is contained in:
@@ -78,6 +78,11 @@ class AMAN:
|
|||||||
self.Receiver.acquire(configPath, self.SystemConfig.Server, self)
|
self.Receiver.acquire(configPath, self.SystemConfig.Server, self)
|
||||||
|
|
||||||
def release(self):
|
def release(self):
|
||||||
|
if None != self.Workers:
|
||||||
|
for worker in self.Workers:
|
||||||
|
worker.release()
|
||||||
|
self.Workers = None
|
||||||
|
|
||||||
if None != self.Receiver:
|
if None != self.Receiver:
|
||||||
self.Receiver.release()
|
self.Receiver.release()
|
||||||
self.Receiver = None
|
self.Receiver = None
|
||||||
@@ -86,10 +91,6 @@ class AMAN:
|
|||||||
self.Weather.release()
|
self.Weather.release()
|
||||||
self.Weather = None
|
self.Weather = None
|
||||||
|
|
||||||
if None != self.Workers:
|
|
||||||
for worker in self.Workers:
|
|
||||||
worker.release()
|
|
||||||
self.Workers = None
|
|
||||||
|
|
||||||
def updateAircraftReport(self, report : AircraftReport_pb2.AircraftReport):
|
def updateAircraftReport(self, report : AircraftReport_pb2.AircraftReport):
|
||||||
# find the correct worker for the inbound
|
# find the correct worker for the inbound
|
||||||
|
|||||||
Reference in New Issue
Block a user