self.memorypool_update()
t3 = time.time()
- print "mempool:", len(self.mempool_addresses), len(self.mempool_hist), "%.3fs"%(t3 - t2)
+ # print "mempool:", len(self.mempool_addresses), len(self.mempool_hist), "%.3fs"%(t3 - t2)
if self.sent_height != self.height:
elif method == 'server.stop':
self.shared.stop()
- result = 'ok'
+ result = 'stopping, please wait until all threads terminate.'
elif method == 'server.info':
result = map(lambda s: { "time":s.time,
def run_rpc_command(command, stratum_tcp_port):
import socket, json
- s = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
- s.connect(( host, int(stratum_tcp_port )))
+ try:
+ s = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
+ s.connect(( host, int(stratum_tcp_port )))
+ except:
+ print "cannot connect to server."
+ return
+
method = 'server.' + command
request = json.dumps( { 'id':0, 'method':method, 'params':[password] } )
s.send(request + '\n')