|
@@ -112,7 +112,7 @@ class AclTaskMixin:
|
112
|
112
|
if glob_cl.has_cl:
|
113
|
113
|
return
|
114
|
114
|
glob_cl.has_cl = True
|
115
|
|
- glob_cl.run_persistent_loop(self)
|
|
115
|
+ glob_cl.run_persistent_loop0(self)
|
116
|
116
|
glob_cl.acl = self.channel_layer
|
117
|
117
|
|
118
|
118
|
|
|
@@ -312,6 +312,22 @@ class globCL(GCLMixin):
|
312
|
312
|
# loop.create_task(self.persistent_fast_cb_loop())
|
313
|
313
|
loop.create_task(self.persistent_fast_cb_loop_min_timeout())
|
314
|
314
|
self.loop = loop
|
|
315
|
+
|
|
316
|
+
|
|
317
|
+ def _run_persistent_loop0(self,*a,**kw):
|
|
318
|
+ p("_run_persistent_loop:")
|
|
319
|
+ loop = asyncio.get_event_loop()
|
|
320
|
+ self.run_persistent_loop = nop
|
|
321
|
+ self.rman.persistent_loop_cb()
|
|
322
|
+ loop.create_task(self.persistent_loop())
|
|
323
|
+ # loop.create_task(self.persistent_fast_cb_loop())
|
|
324
|
+ loop.create_task(self.persistent_fast_cb_loop_min_timeout())
|
|
325
|
+ self.loop = loop
|
|
326
|
+ run_persistent_loop0 = _run_persistent_loop0
|
|
327
|
+
|
|
328
|
+
|
|
329
|
+
|
|
330
|
+
|
315
|
331
|
run_persistent_loop = _run_persistent_loop
|
316
|
332
|
run_persistent_loop2 = _run_persistent_loop2
|
317
|
333
|
run_persistent_loop3 = _run_persistent_loop3
|