#json
self.message_id = 0
self.unanswered_requests = {}
- self.pending_transactions_for_notifications= []
# parse server
self.server = server
print_error("certificate has expired:", cert_path)
os.unlink(cert_path)
else:
- print_msg("wrong certificate", self.host)
+ print_error("wrong certificate", self.host)
return
except Exception:
print_error("wrap_socket failed", self.host)
self.queue.put(self)
+ def synchronous_get(self, requests, timeout=100000000):
+ queue = Queue.Queue()
+ ids = self.send(requests, lambda i,r: queue.put(r))
+ id2 = ids[:]
+ res = {}
+ while ids:
+ r = queue.get(True, timeout)
+ _id = r.get('id')
+ if _id in ids:
+ ids.remove(_id)
+ res[_id] = r.get('result')
+ out = []
+ for _id in id2:
+ out.append(res[_id])
+ return out
+
if __name__ == "__main__":