option: "update_neutron_port_dp_status" 31/43631/2
authorRyota MIBU <r-mibu@cq.jp.nec.com>
Fri, 29 Sep 2017 13:01:03 +0000 (13:01 +0000)
committerRyota Mibu <r-mibu@cq.jp.nec.com>
Fri, 29 Sep 2017 13:44:34 +0000 (13:44 +0000)
This patch introduces new boolean option "update_neutron_port_dp_status",
which disabled by default.

Change-Id: Iaf7503d5854251fabf816b9bf3fcc1964c231a68
Signed-off-by: Ryota MIBU <r-mibu@cq.jp.nec.com>
(cherry picked from commit 9f91aba7ef33d7ad88c3bd004fdf7c5fef65f151)

doctor_tests/inspector/__init__.py
doctor_tests/inspector/sample.py
etc/doctor.sample.conf

index 3be79e5..a9a86ec 100644 (file)
@@ -26,6 +26,10 @@ OPTS = [
                default='12345',
                help='the port of default for inspector',
                required=False),
+    cfg.BoolOpt('update_neutron_port_dp_status',
+                default=False,
+                help='Update data plane status of affected neutron ports',
+                required=False),
 ]
 
 
index 114e4eb..fcdb48f 100644 (file)
@@ -35,7 +35,8 @@ class SampleInspector(BaseInspector):
 
         auth = get_identity_auth(project=self.conf.doctor_project)
         session = get_session(auth=auth)
-        self.neutron = neutron_client(session)
+        if self.conf.update_neutron_port_dp_status:
+            self.neutron = neutron_client(session)
 
         self.servers = collections.defaultdict(list)
         self.hostnames = list()
@@ -94,10 +95,12 @@ class SampleInspector(BaseInspector):
                 self.hostnames.append(hostname)
                 thr1 = self._disable_compute_host(hostname)
                 thr2 = self._vms_reset_state('error', hostname)
-                thr3 = self._set_ports_data_plane_status('DOWN', hostname)
+                if self.conf.update_neutron_port_dp_status:
+                    thr3 = self._set_ports_data_plane_status('DOWN', hostname)
                 thr1.join()
                 thr2.join()
-                thr3.join()
+                if self.conf.update_neutron_port_dp_status:
+                    thr3.join()
 
     @utils.run_async
     def _disable_compute_host(self, hostname):
index f81d3b2..56fc828 100644 (file)
@@ -37,6 +37,7 @@
 #type = local
 #ip = 127.0.0.1
 #username = root
+#update_neutron_port_dp_status = False
 
 [monitor]
 #type = sample