unfortunately there is a scoping issue here

server-ca/daemon_common.py

@@ -5,6 +5,9 @@
 import time, binascii
 from Crypto import Random
 
+import redis
+log_redis = redis.Redis()
+
 def signal_handler(a, b):
     global clean_shutdown
     clean_shutdown = True
@@ -27,6 +30,6 @@ def random_raw():
 
 def log(msg, session = None):
     if session:
-        r.publish("logs", "%s: %s" % (short(session), msg))
+        log_redis.publish("logs", "%s: %s" % (short(session), msg))
     else:
-        r.publish("logs", "%s" % session)
+        log_redis.publish("logs", "%s" % session)

server-ca/issue-daemon.py

@@ -7,7 +7,6 @@ import redis, redis_lock, CSR, sys, signal
 from sni_challenge.verify import verify_challenge
 from Crypto import Random
 
-global r
 r = redis.Redis()
 ps = r.pubsub()
 issue_lock = redis_lock.redis_lock(r, "issue_lock")

server-ca/logging-daemon.py

@@ -4,7 +4,6 @@
 
 import redis, signal, sys
 
-global r
 r = redis.Redis()
 ps = r.pubsub()
 

server-ca/makechallenge-daemon.py

@@ -5,7 +5,6 @@
 
 import redis, time, sys, signal
 
-global r
 r = redis.Redis()
 ps = r.pubsub()
 

server-ca/payment-daemon.py

@@ -26,7 +26,6 @@
 
 import redis, signal, sys
 
-global r
 r = redis.Redis()
 ps = r.pubsub()
 

server-ca/testchallenge-daemon.py

@@ -9,7 +9,6 @@ import policy
 from redis_lock import redis_lock
 from sni_challenge.verify import verify_challenge
 
-global r
 r = redis.Redis()
 ps = r.pubsub()