def run(self):
ircname = self.getname()
+ print_log("joining IRC")
while not self.processor.shared.stopped():
try:
s.settimeout(0.1)
except:
s.close()
+ print_log("IRC: reconnect in 10 s")
time.sleep(10)
continue
line = line.strip('\r')
if not line:
continue
+ # print_log("<--", line)
line = line.split()
if line[0] == 'PING':
out_msg.append('PONG ' + line[1] + '\n')
elif method == 'server.version':
result = VERSION
+ elif method == 'server.getpid':
+ import os
+ result = os.getpid()
+
elif method == 'server.stop':
self.shared.stop()
result = 'stopping, please wait until all threads terminate.'