|
@@ -139,7 +139,8 @@ class globCL(GCLMixin):
|
139
|
139
|
def __init__(self,*a,**kw):
|
140
|
140
|
# for now we are not going to do any weird class stuff
|
141
|
141
|
self.acl = None
|
142
|
|
- self.has_cl = False self.rconn1 = connect_redis1()
|
|
142
|
+ self.has_cl = False
|
|
143
|
+ self.rconn1 = connect_redis1()
|
143
|
144
|
self.rconn = connect_redis()
|
144
|
145
|
self.rman = RldMan()
|
145
|
146
|
self.cbs_once = []
|
|
@@ -181,9 +182,6 @@ class globCL(GCLMixin):
|
181
|
182
|
self.cbs_asap2 = self.cbs_asap
|
182
|
183
|
self.cbs_asap=[]
|
183
|
184
|
await asyncio.sleep(self.fast_timeout)
|
184
|
|
-
|
185
|
|
-
|
186
|
|
-
|
187
|
185
|
async def persistent_loop(self,*a,**kw):
|
188
|
186
|
while 1:
|
189
|
187
|
for k,v in [*self.cbs.items()]:
|