self.responses = Queue.Queue()
self.unanswered_requests = {}
- def init_socket(self):
- pass
def poke(self):
# push a fake response so that the getting thread exits its loop
def __init__(self, host, port, proxy=None):
InterfaceAncestor.__init__(self, host, port, proxy)
+ self.init_socket()
def init_socket(self):
global proxy_modes
port = int(port)
self.protocol = protocol
- proxy = self.parse_proxy_options(config.get('proxy','none'))
+ proxy = self.parse_proxy_options(config.get('proxy'))
self.server = host + ':%d:%s'%(port, protocol)
#print protocol, host, port
def parse_proxy_options(self, s):
+ if type(s) == type({}): return s # fixme: type should be fixed
if type(s) != type(""): return None
if s.lower() == 'none': return None
proxy = { "mode":"socks5", "host":"localhost" }
def start_interface(self):
- self.interface.init_socket()
self.interface.start()
if self.interface.is_connected:
self.wallet.start_session(self.interface)