|
|
@@ -120,8 +120,9 @@ class AconMixin(DbgMixin):
|
|
120
|
120
|
|
|
121
|
121
|
class AclTaskMixin:
|
|
122
|
122
|
async def ws_disconn(self):
|
|
123
|
|
- for group in self.groups_set:
|
|
124
|
|
-
|
|
|
123
|
+ # for group in self.groups_set:
|
|
|
124
|
+ pass
|
|
|
125
|
+
|
|
125
|
126
|
async def ws_conn0(self):
|
|
126
|
127
|
self.groups_set = set()
|
|
127
|
128
|
if glob_cl.has_cl:
|
|
|
@@ -251,8 +252,10 @@ class globCL(GCLMixin):
|
|
251
|
252
|
glob_cl.cbs_once.append(group_add(*a,**kw))
|
|
252
|
253
|
async def dev_group_add(self,group_name,consumer):
|
|
253
|
254
|
channel_layer = glob_cl.acl
|
|
254
|
|
- if not consumer.channel_name in consumer.groups_set:
|
|
255
|
|
- consumer.groups_set.add(groups)
|
|
|
255
|
+ # if not consumer.channel_name in consumer.groups_set:
|
|
|
256
|
+ # consumer.groups_set.add(groups)
|
|
|
257
|
+ if not consumer.channel_name in consumer.groups:
|
|
|
258
|
+ consumer.groups.append(groups)
|
|
256
|
259
|
await channel_layer.group_add(group_name,consumer.channel_name)
|
|
257
|
260
|
|
|
258
|
261
|
|