lightweight build unify database record to nsrs

[osm/RO.git] / lcm / osm_common / msglocal.py

diff --git a/lcm/osm_common/msglocal.py b/lcm/osm_common/msglocal.py
index 5045181..a380e61 100644 (file)
--- a/lcm/osm_common/msglocal.py
+++ b/lcm/osm_common/msglocal.py
@@ -58,8 +58,10 @@ class msgLocal(MsgBase):
         except Exception as e:  # TODO refine
             raise MsgException(str(e))
 
-    async def aioread(self, loop, topic):
+    async def aioread(self, topic, loop=None):
         try:
+            if not loop:
+                loop = asyncio.get_event_loop()
             if topic not in self.files:
                 self.files[topic] = open(self.path + topic, "r+")
                 # ignore previous content