optional wait parameter for interface
This commit is contained in:
13
electrum
13
electrum
@@ -124,7 +124,7 @@ if __name__ == '__main__':
|
|||||||
|
|
||||||
interface = Interface(config, True)
|
interface = Interface(config, True)
|
||||||
wallet.interface = interface
|
wallet.interface = interface
|
||||||
interface.start()
|
interface.start(wait = False)
|
||||||
interface.send([('server.peers.subscribe',[])])
|
interface.send([('server.peers.subscribe',[])])
|
||||||
|
|
||||||
gui = gui.ElectrumGui(wallet, config)
|
gui = gui.ElectrumGui(wallet, config)
|
||||||
@@ -239,11 +239,7 @@ if __name__ == '__main__':
|
|||||||
|
|
||||||
if not options.offline:
|
if not options.offline:
|
||||||
interface = Interface(config)
|
interface = Interface(config)
|
||||||
interface.start()
|
interface.start(wait=True)
|
||||||
interface.connect_event.wait()
|
|
||||||
if not interface.is_connected:
|
|
||||||
print_msg("Not connected, aborting.")
|
|
||||||
sys.exit(1)
|
|
||||||
wallet.interface = interface
|
wallet.interface = interface
|
||||||
verifier = WalletVerifier(interface, config)
|
verifier = WalletVerifier(interface, config)
|
||||||
wallet.set_verifier(verifier)
|
wallet.set_verifier(verifier)
|
||||||
@@ -361,11 +357,6 @@ if __name__ == '__main__':
|
|||||||
interface = Interface(config)
|
interface = Interface(config)
|
||||||
interface.register_callback('connected', lambda: sys.stderr.write("Connected to " + interface.connection_msg + "\n"))
|
interface.register_callback('connected', lambda: sys.stderr.write("Connected to " + interface.connection_msg + "\n"))
|
||||||
interface.start()
|
interface.start()
|
||||||
# wait until connected
|
|
||||||
interface.connect_event.wait()
|
|
||||||
if not interface.is_connected:
|
|
||||||
print_msg("Not connected, aborting.")
|
|
||||||
sys.exit(1)
|
|
||||||
wallet.interface = interface
|
wallet.interface = interface
|
||||||
verifier = WalletVerifier(interface, config)
|
verifier = WalletVerifier(interface, config)
|
||||||
wallet.set_verifier(verifier)
|
wallet.set_verifier(verifier)
|
||||||
|
|||||||
@@ -586,6 +586,15 @@ class Interface(threading.Thread):
|
|||||||
return out
|
return out
|
||||||
|
|
||||||
|
|
||||||
|
def start(self, wait=True):
|
||||||
|
threading.Thread.start(self)
|
||||||
|
if wait:
|
||||||
|
# wait until connection is established
|
||||||
|
self.connect_event.wait()
|
||||||
|
if not self.is_connected:
|
||||||
|
print_msg("Not connected, aborting.")
|
||||||
|
sys.exit(1)
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
while True:
|
while True:
|
||||||
self.init_interface()
|
self.init_interface()
|
||||||
|
|||||||
Reference in New Issue
Block a user