in src/rosbridge/server.py [0:0]
def __init__(self, url, make_env):
self.url = url
self.make_env = make_env
self.env = None
self.env_name = None
self.session_id = None
self.session_last_use = 0.0
self.session_owner = None
self.log_msgs = []
self.ctx = zmq.Context()
self.sock = self.ctx.socket(zmq.REP)
self.sock.bind(self.url)
self.monitor_sock = self.sock.get_monitor_socket()
self.rpc_lock = threading.Lock()
self.rpc_rd = threading.Condition(self.rpc_lock)
self.monitor_thr = threading.Thread(target = self.run_monitor)
self.monitor_thr.daemon = True
self.monitor_thr.start()
self.timeout_thr = threading.Thread(target = self.run_timeout)
self.timeout_thr.daemon = True
self.timeout_thr.start()