interface = self.wallet.interface
if self.funds_error:
text = "Not enough funds"
- elif interface.is_connected:
+ elif interface and interface.is_connected:
self.network_button.set_tooltip_text("Connected to %s:%d.\n%d blocks"%(interface.host, interface.port, self.wallet.blocks))
if self.wallet.blocks == -1:
self.status_image.set_from_stock(gtk.STOCK_NO, gtk.ICON_SIZE_MENU)
if u: text += "[%s unconfirmed]"%( format_satoshis(u,True,self.wallet.num_zeros).strip() )
else:
self.status_image.set_from_stock(gtk.STOCK_NO, gtk.ICON_SIZE_MENU)
- self.network_button.set_tooltip_text("Trying to contact %s.\n%d blocks"%(interface.host, self.wallet.blocks))
+ self.network_button.set_tooltip_text("Trying to contact %s.\n%d blocks"%(self.wallet.server, self.wallet.blocks))
text = "Not connected"
self.status_bar.pop(self.context_id)
def __init__(self, host, port):
Interface.__init__(self, host, port)
+
+ def init_socket(self):
self.s = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
self.s.settimeout(5*60)
self.s.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
self.daemon = True
self.wallet = wallet
self.loop = loop
- self.start_interface()
+ self.init_interface()
+
+ def init_interface(self):
+ try:
+ host, port, protocol = self.wallet.server.split(':')
+ port = int(port)
+ except:
+ self.wallet.pick_random_server()
+ host, port, protocol = self.wallet.server.split(':')
+ port = int(port)
+
+ #print protocol, host, port
+ if protocol == 't':
+ InterfaceClass = TcpStratumInterface
+ elif protocol == 'h':
+ InterfaceClass = HttpStratumInterface
+ else:
+ print "unknown protocol"
+ InterfaceClass = TcpStratumInterface
+
+ self.interface = InterfaceClass(host, port)
+ self.wallet.interface = self.interface
def handle_response(self, r):
def start_interface(self):
- try:
- host, port, protocol = self.wallet.server.split(':')
- port = int(port)
- except:
- self.wallet.pick_random_server()
- host, port, protocol = self.wallet.server.split(':')
- port = int(port)
-
- #print protocol, host, port
- if protocol == 't':
- InterfaceClass = TcpStratumInterface
- elif protocol == 'h':
- InterfaceClass = HttpStratumInterface
- else:
- print "unknown protocol"
- InterfaceClass = TcpStratumInterface
-
- self.interface = InterfaceClass(host, port)
+ self.interface.init_socket()
self.interface.start()
- self.wallet.interface = self.interface
-
if self.interface.is_connected:
self.wallet.start_session(self.interface)
def run(self):
import socket, time
+ self.start_interface()
while True:
while self.interface.is_connected:
new_addresses = self.wallet.synchronize()
self.wallet.gui_callback()
if self.loop:
time.sleep(5)
+ self.init_interface()
self.start_interface()
continue
else: