shared.stop()
sys.exit(0)
- print "blockchain is up to date."
+ print_log( "blockchain is up to date." )
threading.Timer(10, self.main_iteration).start()
self.db.Write(batch, sync = sync)
t3 = time.time()
- if t3 - t0 > 10:
+ if t3 - t0 > 10 and not sync:
print_log("block", block_height,
"parse:%0.2f "%(t00 - t0),
"read:%0.2f "%(t1 - t00),
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()
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:
run_rpc_command(sys.argv[1], stratum_tcp_port)
sys.exit(0)
- from processor import Dispatcher
+ from processor import Dispatcher, print_log
from backends.irc import ServerProcessor
backend_name = config.get('server', 'backend')
print "Unknown backend '%s' specified\n" % backend_name
sys.exit(1)
- print "\n\n\n\nStarting Electrum server on", host
+ for i in range(5): print ""
+ print_log( "Starting Electrum server on", host)
# Create hub
dispatcher = Dispatcher()
except:
shared.stop()
- print "Electrum Server stopped"
+ print_log( "Electrum Server stopped")