Browse Source

auto commit

master
jfinn 3 years ago
parent
commit
88d5c5bd31
1 changed files with 7 additions and 3 deletions
  1. 7
    3
      wsps/tasks_loop.py

+ 7
- 3
wsps/tasks_loop.py View File

23
 def nop(*a,**kw):pass
23
 def nop(*a,**kw):pass
24
 class Edict(dict):pass
24
 class Edict(dict):pass
25
 class Eobj():pass
25
 class Eobj():pass
26
+def connect_redis1():
27
+	return redis.Redis(host='localhost', port=6379, db=1,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
26
 def connect_redis():
28
 def connect_redis():
27
-	return redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
29
+	# return redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
30
+	return redis.Redis(host='localhost', port=6379,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
28
 	r'''
31
 	r'''
29
-	
32
+
30
 	return {
33
 	return {
31
 	 "rconn0":redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
34
 	 "rconn0":redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
32
 	 "rconn1":redis.Redis(host='localhost', port=6379, db=1,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
35
 	 "rconn1":redis.Redis(host='localhost', port=6379, db=1,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
176
 		# for now we are not going to do any weird class stuff
179
 		# for now we are not going to do any weird class stuff
177
 		self.acl = None
180
 		self.acl = None
178
 		self.has_cl = False
181
 		self.has_cl = False
179
-		rconns = connect_redis()
182
+		# rconns = connect_redis()
183
+		self.rconn1 = connect_redis1()
180
 		self.rconn = connect_redis()
184
 		self.rconn = connect_redis()
181
 		self.rman = RldMan()
185
 		self.rman = RldMan()
182
 		self.cbs_once = []
186
 		self.cbs_once = []

Loading…
Cancel
Save