djc_srv/wsps/tasks_loop.py

import asyncio
import time

import redis

import os
import copy
import json

import traceback
import inspect


'''
	umod
# '''

p=print

async def anop(*a,**kw):pass
def nop(*a,**kw):pass

def connect_redis():
	return redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")


'''
# '''


class AclTaskMixin:
	async def ws_conn0(self):
		glob_cl.init_gcl(self)
		print("++++++++++++++++++++++++++")
		# oinfo(glob_cl)
	async def ws_conn_once(self,*a,**kw):
		print("\t\tws_conn_once:","AclTaskMixin")




# GCLMixin
class globCL():
	init_cnt = 0
	def __init__(self,*a,**kw):
		# for now we are not going to do any weird class stuff
		cls = self.__class__
		cls.init_cnt += 1
		self.r = connect_redis()
		pass
	async def persistent_loop(self,*a,**kw):
		pass
	def run_persistent_loop(self,*a,**kw):
		pass


# p("300 globCL.init_cnt:",globCL.init_cnt)
glob_cl =  globCL()
# p("400 globCL.init_cnt:",globCL.init_cnt)
# glob_cl_b =  globCL()
# p("501 globCL.init_cnt:",globCL.init_cnt)

# print("..",end="\n",flush=True)











def redis_info():
	rconn = glob_cl.r
	keys = rconn.keys()
	for k in keys:
		p(":",k)

	p("len(keys)",len(keys))
	print("",end="",flush=True)
	# rconn.flushall()
redis_info()
r"""

def atexit_fn():
    pass
    # rconn.flushall()
    print("ATEXIT FN")
    rinfo_len()
    keys = rconn.keys()
    print(keys)
    print(len(keys))
    print("t 000")
    # time.sleep(10)
    print("t 010")
    # time.sleep(20)
    print("t 020")
    print("ATEXIT FN...")
    rconn.flushall()
atexit.register(atexit_fn)



# """