gevent(thread=False)

Asyncio Engine fails on exit if gevent patched thread code.


git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/branches/0.7@2738 b32b6428-25c9-4566-ad07-03861ab6144f

devices/protocols/Aqara/xaal/aqara/gw.py

-from gevent import monkey; monkey.patch_all()
+from gevent import monkey; monkey.patch_all(thread=False)
 
 from xaal.lib import tools,Device
 from .network import AqaraConnector,AqaraDiscovery

devices/protocols/Edisio/xaal/edisio/gw.py

-
-from gevent import monkey; monkey.patch_all()
+from gevent import monkey; monkey.patch_all(thread=False)
 import gevent
 
 from xaal.lib import tools,Engine,Device

devices/protocols/IPX-800/xaal/ipx800/gw.py

-
-from gevent import monkey; monkey.patch_all()
+from gevent import monkey; monkey.patch_all(thread=False)
 import gevent
 
 

devices/protocols/KNX/xaal/knx/gw.py

-from gevent import monkey;monkey.patch_all()
+from gevent import monkey;monkey.patch_all(thread=False)
 import gevent
 
 from xaal.lib import tools,Device,Engine

devices/protocols/Netatmo/xaal/netatmo/gw.py

@@ -7,6 +7,9 @@ RATE = 300 # update every 5 min
 PACKAGE_NAME = "xaal.netatmo"
 logger = logging.getLogger(PACKAGE_NAME)
 
+from xaal.aiolib.core import spawn
+
+
 class GW:
     def __init__(self,engine):
         filename=tools.get_cfg_filename(PACKAGE_NAME)
@@ -72,6 +75,7 @@ class GW:
             if m.macId == macId :
                 m.update_sensors(attr)   
 
+    @spawn
     def readweatherstation(self):
         netatmo_data = netatmo.API(self.cfg).get_data()
         if netatmo_data == None:

devices/protocols/Tuya/xaal/tuya/gw.py

-from gevent import monkey;monkey.patch_all()
+from gevent import monkey;monkey.patch_all(thread=False)
 
 
 from xaal.lib import tools,Device

devices/protocols/Yeelight/xaal/yeelight/gw.py

-from gevent import monkey; monkey.patch_all()
+from gevent import monkey; monkey.patch_all(thread=False)
 
 
 from xaal.lib import tools

devices/protocols/bugOne/xaal/bugone/gw.py

-from __future__ import print_function
-
-from gevent import monkey; monkey.patch_all()
+from gevent import monkey; monkey.patch_all(thread=False)
 import gevent
 import platform
 import logging