def print_log(*args):
args = [str(item) for item in args]
with print_lock:
- sys.stderr.write(" ".join(args) + "\n")
+ sys.stderr.write(timestr() + " " + " ".join(args) + "\n")
sys.stderr.flush()
except:
pass
- if session.protocol_version < 0.6:
- print_log("stopping session from old client", session.protocol_version)
- session.stop()
+ #if session.protocol_version < 0.6:
+ # print_log("stopping session from old client", session.protocol_version)
+ # session.stop()
def get_sessions(self):
with self.lock:
addr = None
if self.subscriptions:
- print_log( timestr(), self.name, self.address, addr, len(self.subscriptions), self.version )
+ print_log( "%4s"%self.name, "%14s"%self.address, "%35s"%addr, "%3d"%len(self.subscriptions), self.version )
def stopped(self):
with self.lock: