auth = get_identity_auth(project=self.conf.doctor_project)
session = get_session(auth=auth)
auth = get_identity_auth(project=self.conf.doctor_project)
session = get_session(auth=auth)
- if self.conf.update_neutron_port_dp_status:
+ if self.conf.inspector.update_neutron_port_dp_status:
self.neutron = neutron_client(session)
self.servers = collections.defaultdict(list)
self.neutron = neutron_client(session)
self.servers = collections.defaultdict(list)
self.hostnames.append(hostname)
thr1 = self._disable_compute_host(hostname)
thr2 = self._vms_reset_state('error', hostname)
self.hostnames.append(hostname)
thr1 = self._disable_compute_host(hostname)
thr2 = self._vms_reset_state('error', hostname)
- if self.conf.update_neutron_port_dp_status:
+ if self.conf.inspector.update_neutron_port_dp_status:
thr3 = self._set_ports_data_plane_status('DOWN', hostname)
thr1.join()
thr2.join()
thr3 = self._set_ports_data_plane_status('DOWN', hostname)
thr1.join()
thr2.join()
- if self.conf.update_neutron_port_dp_status:
+ if self.conf.inspector.update_neutron_port_dp_status:
thr3.join()
@utils.run_async
thr3.join()
@utils.run_async
#type = local
#ip = 127.0.0.1
#username = root
#type = local
#ip = 127.0.0.1
#username = root
-#update_neutron_port_dp_status = False
#type = sample
#ip = 127.0.0.1
#port = 12345
#type = sample
#ip = 127.0.0.1
#port = 12345
+#update_neutron_port_dp_status = False
[consumer]
#type = sample
[consumer]
#type = sample