X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=blobdiff_plain;f=processor.py;h=91519361e001167a9c2a9cdf92a8d3a8fe46c4b0;hp=9210fd615f373416a52264fc81b567dd289cf781;hb=7ff0c0c3850066a935e272f2ddd11422d0871042;hpb=a4a11fca8d0b078c429d9ff369de1bd1fed334a3 diff --git a/processor.py b/processor.py index 9210fd6..9151936 100644 --- a/processor.py +++ b/processor.py @@ -80,8 +80,6 @@ class RequestDispatcher(threading.Thread): self.daemon = True self.request_queue = queue.Queue() self.response_queue = queue.Queue() - self.internal_ids = {} - self.internal_id = 1 self.lock = threading.Lock() self.idlock = threading.Lock() self.sessions = [] @@ -99,22 +97,6 @@ class RequestDispatcher(threading.Thread): def pop_request(self): return self.request_queue.get() - def get_session_by_address(self, address): - for x in self.sessions: - if x.address == address: - return x - - def get_session_id(self, internal_id): - with self.idlock: - return self.internal_ids.pop(internal_id) - - def store_session_id(self, session, msgid): - with self.idlock: - self.internal_ids[self.internal_id] = session, msgid - r = self.internal_id - self.internal_id += 1 - return r - def run(self): if self.shared is None: raise TypeError("self.shared not set in Processor")