X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=processor.py;h=20fdbfd7e26b914c1be6a7157195a46cabe0a11f;hb=3051f46df11fc6c9ebe321c9ef6d726e65310129;hp=1ea96495765f7af1217506fc9a3e0b05bae015ec;hpb=d59253c43af31da62b0fa247a54ab632e7473976;p=electrum-server.git diff --git a/processor.py b/processor.py index 1ea9649..20fdbfd 100644 --- a/processor.py +++ b/processor.py @@ -89,6 +89,11 @@ 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.lock: return self.internal_ids.pop(internal_id) @@ -165,6 +170,7 @@ class Session: self.address = '' self.name = '' self.version = 'unknown' + self.time = time.time() threading.Timer(2, self.info).start() # Debugging method. Doesn't need to be threadsafe.