move init_socket in constructor
This commit is contained in:
parent
a95e834e2e
commit
1a781036cf
|
@ -60,8 +60,6 @@ class InterfaceAncestor(threading.Thread):
|
||||||
self.responses = Queue.Queue()
|
self.responses = Queue.Queue()
|
||||||
self.unanswered_requests = {}
|
self.unanswered_requests = {}
|
||||||
|
|
||||||
def init_socket(self):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def poke(self):
|
def poke(self):
|
||||||
# push a fake response so that the getting thread exits its loop
|
# push a fake response so that the getting thread exits its loop
|
||||||
|
@ -210,6 +208,7 @@ class TcpStratumInterface(InterfaceAncestor):
|
||||||
|
|
||||||
def __init__(self, host, port, proxy=None):
|
def __init__(self, host, port, proxy=None):
|
||||||
InterfaceAncestor.__init__(self, host, port, proxy)
|
InterfaceAncestor.__init__(self, host, port, proxy)
|
||||||
|
self.init_socket()
|
||||||
|
|
||||||
def init_socket(self):
|
def init_socket(self):
|
||||||
global proxy_modes
|
global proxy_modes
|
||||||
|
@ -435,7 +434,6 @@ class WalletSynchronizer(threading.Thread):
|
||||||
|
|
||||||
|
|
||||||
def start_interface(self):
|
def start_interface(self):
|
||||||
self.interface.init_socket()
|
|
||||||
self.interface.start()
|
self.interface.start()
|
||||||
if self.interface.is_connected:
|
if self.interface.is_connected:
|
||||||
self.wallet.start_session(self.interface)
|
self.wallet.start_session(self.interface)
|
||||||
|
|
|
@ -1,9 +1,9 @@
|
||||||
#!/usr/bin/env python
|
#!/usr/bin/env python
|
||||||
|
|
||||||
from electrum import Interface
|
import electrum
|
||||||
|
|
||||||
|
i = electrum.Interface({'server':'electrum.novit.ro:50001:t'})
|
||||||
|
|
||||||
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
|
||||||
i.init_socket()
|
|
||||||
i.start()
|
i.start()
|
||||||
i.send([('blockchain.numblocks.subscribe',[])])
|
i.send([('blockchain.numblocks.subscribe',[])])
|
||||||
|
|
||||||
|
|
|
@ -10,7 +10,6 @@ except:
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
|
|
||||||
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
||||||
i.init_socket()
|
|
||||||
i.start()
|
i.start()
|
||||||
i.send([('blockchain.address.get_history',[addr])])
|
i.send([('blockchain.address.get_history',[addr])])
|
||||||
|
|
||||||
|
|
|
@ -158,7 +158,6 @@ if __name__ == '__main__':
|
||||||
conn = mdb.connect(db_instance, db_user, db_password, db_name);
|
conn = mdb.connect(db_instance, db_user, db_password, db_name);
|
||||||
|
|
||||||
i = Interface({'server':"%s:%d:t"%(electrum_server, 50001)})
|
i = Interface({'server':"%s:%d:t"%(electrum_server, 50001)})
|
||||||
i.init_socket()
|
|
||||||
i.start()
|
i.start()
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -3,7 +3,6 @@
|
||||||
from electrum import Interface
|
from electrum import Interface
|
||||||
|
|
||||||
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
||||||
i.init_socket()
|
|
||||||
i.start()
|
i.start()
|
||||||
i.send([('server.peers.subscribe',[])])
|
i.send([('server.peers.subscribe',[])])
|
||||||
|
|
||||||
|
|
|
@ -10,7 +10,6 @@ except:
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
|
|
||||||
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
i = Interface({'server':'electrum.novit.ro:50001:t'})
|
||||||
i.init_socket()
|
|
||||||
i.start()
|
i.start()
|
||||||
i.send([('blockchain.address.subscribe',[addr])])
|
i.send([('blockchain.address.subscribe',[addr])])
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue