##// END OF EJS Templates
don't use in threads inproc://monitor
MinRK -
Show More
@@ -66,13 +66,13 b' class ControllerFactory(HubFactory):'
66 children = self.children
66 children = self.children
67 mq = import_item(self.mq_class)
67 mq = import_item(self.mq_class)
68
68
69 maybe_inproc = 'inproc://monitor' if self.usethreads else self.monitor_url
69 # maybe_inproc = 'inproc://monitor' if self.usethreads else self.monitor_url
70 # IOPub relay (in a Process)
70 # IOPub relay (in a Process)
71 q = mq(zmq.PUB, zmq.SUB, zmq.PUB, 'N/A','iopub')
71 q = mq(zmq.PUB, zmq.SUB, zmq.PUB, 'N/A','iopub')
72 q.bind_in(self.client_info['iopub'])
72 q.bind_in(self.client_info['iopub'])
73 q.bind_out(self.engine_info['iopub'])
73 q.bind_out(self.engine_info['iopub'])
74 q.setsockopt_out(zmq.SUBSCRIBE, '')
74 q.setsockopt_out(zmq.SUBSCRIBE, '')
75 q.connect_mon(maybe_inproc)
75 q.connect_mon(self.monitor_url)
76 q.daemon=True
76 q.daemon=True
77 children.append(q)
77 children.append(q)
78
78
@@ -81,7 +81,7 b' class ControllerFactory(HubFactory):'
81 q.bind_in(self.client_info['mux'])
81 q.bind_in(self.client_info['mux'])
82 q.setsockopt_in(zmq.IDENTITY, 'mux')
82 q.setsockopt_in(zmq.IDENTITY, 'mux')
83 q.bind_out(self.engine_info['mux'])
83 q.bind_out(self.engine_info['mux'])
84 q.connect_mon(maybe_inproc)
84 q.connect_mon(self.monitor_url)
85 q.daemon=True
85 q.daemon=True
86 children.append(q)
86 children.append(q)
87
87
@@ -90,7 +90,7 b' class ControllerFactory(HubFactory):'
90 q.bind_in(self.client_info['control'])
90 q.bind_in(self.client_info['control'])
91 q.setsockopt_in(zmq.IDENTITY, 'control')
91 q.setsockopt_in(zmq.IDENTITY, 'control')
92 q.bind_out(self.engine_info['control'])
92 q.bind_out(self.engine_info['control'])
93 q.connect_mon(maybe_inproc)
93 q.connect_mon(self.monitor_url)
94 q.daemon=True
94 q.daemon=True
95 children.append(q)
95 children.append(q)
96 # Task Queue (in a Process)
96 # Task Queue (in a Process)
@@ -101,7 +101,7 b' class ControllerFactory(HubFactory):'
101 q.bind_in(self.client_info['task'][1])
101 q.bind_in(self.client_info['task'][1])
102 q.setsockopt_in(zmq.IDENTITY, 'task')
102 q.setsockopt_in(zmq.IDENTITY, 'task')
103 q.bind_out(self.engine_info['task'])
103 q.bind_out(self.engine_info['task'])
104 q.connect_mon(maybe_inproc)
104 q.connect_mon(self.monitor_url)
105 q.daemon=True
105 q.daemon=True
106 children.append(q)
106 children.append(q)
107 elif self.scheme == 'none':
107 elif self.scheme == 'none':
General Comments 0
You need to be logged in to leave comments. Login now