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( |
|
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( |
|
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( |
|
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( |
|
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