|
@@ -275,6 +275,16 @@ class globCL(GCLMixin):
|
275
|
275
|
|
276
|
276
|
|
277
|
277
|
await asyncio.sleep(self.timeout)
|
|
278
|
+ def _run_persistent_loop2(self,*a,**kw):
|
|
279
|
+ p("_run_persistent_loop2:",self,a,kw)
|
|
280
|
+ self.run_persistent_loop = nop
|
|
281
|
+ self.rman.persistent_loop_cb()
|
|
282
|
+ loop = asyncio.get_event_loop()
|
|
283
|
+ loop.create_task(self.persistent_loop())
|
|
284
|
+ # loop.create_task(self.persistent_fast_cb_loop())
|
|
285
|
+ loop.create_task(self.persistent_fast_cb_loop_min_timeout())
|
|
286
|
+ self.loop = loop
|
|
287
|
+
|
278
|
288
|
def _run_persistent_loop(self,*a,**kw):
|
279
|
289
|
p("_run_persistent_loop:",self,a,kw)
|
280
|
290
|
loop = asyncio.get_event_loop()
|
|
@@ -285,6 +295,7 @@ class globCL(GCLMixin):
|
285
|
295
|
loop.create_task(self.persistent_fast_cb_loop_min_timeout())
|
286
|
296
|
self.loop = loop
|
287
|
297
|
run_persistent_loop = _run_persistent_loop
|
|
298
|
+ run_persistent_loop2 = _run_persistent_loop2
|
288
|
299
|
|
289
|
300
|
|
290
|
301
|
def sync_dev_group_discard(self,*a,**kw):
|
|
@@ -333,7 +344,7 @@ class RldMan(RldManMixin):
|
333
|
344
|
]
|
334
|
345
|
|
335
|
346
|
|
336
|
|
- # self.add_files(file_list)
|
|
347
|
+ self.add_files(file_list)
|
337
|
348
|
# self.add_files(file_list,{"run"})
|
338
|
349
|
def persistent_loop_cb(self,*a,**kw):
|
339
|
350
|
base_path = "/usr/games/repos/ign4/py_rld/djc/edan_hrld/"
|
|
@@ -341,7 +352,7 @@ class RldMan(RldManMixin):
|
341
|
352
|
file_list = [
|
342
|
353
|
base_path+"f0.py",
|
343
|
354
|
]
|
344
|
|
- # self.add_files(file_list)
|
|
355
|
+ self.add_files(file_list)
|
345
|
356
|
def add_files(self,files):
|
346
|
357
|
for file in files:
|
347
|
358
|
if type(file)==str:
|