]> review.fuel-infra Code Review - openstack-build/cinder-build.git/commitdiff
fix name 'update_volume_status' to 'update_volume_stats'
authorKun Huang <gareth@unitedstack.com>
Sat, 20 Jul 2013 18:00:33 +0000 (02:00 +0800)
committerKun Huang <gareth@unitedstack.com>
Mon, 22 Jul 2013 16:57:59 +0000 (00:57 +0800)
_update_volume_status() private method is called by
get_volume_stats(). This is confusing as the volume's
stats and not status gets updated.

fixes bug #1199327

Change-Id: I9f7971e457250798320c14d3f58bdc199c8cfceb

14 files changed:
cinder/tests/test_block_device.py
cinder/tests/test_volume.py
cinder/volume/driver.py
cinder/volume/drivers/block_device.py
cinder/volume/drivers/emc/emc_smis_common.py
cinder/volume/drivers/emc/emc_smis_iscsi.py
cinder/volume/drivers/gpfs.py
cinder/volume/drivers/huawei/huawei_iscsi.py
cinder/volume/drivers/lvm.py
cinder/volume/drivers/netapp/iscsi.py
cinder/volume/drivers/netapp/nfs.py
cinder/volume/drivers/nexenta/volume.py
cinder/volume/drivers/nfs.py
cinder/volume/drivers/storwize_svc.py

index cd928b2c926a558e5fb58c24b55f348d069ff234..b51424382d61f73755528f83ea731fcffa44ce0f 100644 (file)
@@ -101,7 +101,7 @@ class TestBlockDeviceDriver(cinder.test.TestCase):
             'provider_location': 'None:3260,None None '
                                  'None dev_path'})
 
-    def test_update_volume_status(self):
+    def test_update_volume_stats(self):
         self.mox.StubOutWithMock(self.drv, '_devices_sizes')
         self.drv._devices_sizes().AndReturn({'/dev/loop1': 1024,
                                              '/dev/loop2': 1024})
@@ -111,7 +111,7 @@ class TestBlockDeviceDriver(cinder.test.TestCase):
         self.configuration.safe_get('volume_backend_name'). \
             AndReturn('BlockDeviceDriver')
         self.mox.ReplayAll()
-        self.drv._update_volume_status()
+        self.drv._update_volume_stats()
         self.assertEquals(self.drv._stats,
                           {'total_capacity_gb': 2,
                            'free_capacity_gb': 2,
index 41c389b6e6e0a769257da4a801cbca85e61b6936..949e435a024e26637392ec66d9818bbf4202a29d 100644 (file)
@@ -1613,7 +1613,7 @@ class ISCSITestCase(DriverTestCase):
 
         self.volume.driver.set_execute(_emulate_vgs_execute)
 
-        self.volume.driver._update_volume_status()
+        self.volume.driver._update_volume_stats()
 
         stats = self.volume.driver._stats
 
index bb088573da049554ad09197c9f5dd3402121ed94..0543cbcd121e0631382e8194e53835bbdada4560 100644 (file)
@@ -467,19 +467,19 @@ class ISCSIDriver(VolumeDriver):
                 return l[l.index('=') + 1:].strip()
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
         backend_name = self.configuration.safe_get('volume_backend_name')
         data["volume_backend_name"] = backend_name or 'Generic_iSCSI'
index 130c642dfb5a5b91b1c007aab43051b7cf2f13d7..b94be1bf37a6a5bea5a1bf0816c64e30b9a367bd 100644 (file)
@@ -318,11 +318,11 @@ class BlockDeviceDriver(driver.ISCSIDriver):
 
     def get_volume_stats(self, refresh=False):
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
         dict_of_devices_sizes = self._devices_sizes()
         used_devices = self._get_used_devices()
         total_size = 0
@@ -332,7 +332,7 @@ class BlockDeviceDriver(driver.ISCSIDriver):
                 free_size += size
             total_size += size
 
-        LOG.debug("Updating volume status")
+        LOG.debug("Updating volume stats")
         backend_name = self.configuration.safe_get('volume_backend_name')
         data = {'total_capacity_gb': total_size / 1024,
                 'free_capacity_gb': free_size / 1024,
index 90ae06103a1e6164f5e67332561fbf4501ba97ec..7e22befdd55a11d2cb06c0e91f1b34b2a3bc8772 100644 (file)
@@ -852,9 +852,9 @@ class EMCSMISCommon():
         self.conn = self._get_ecom_connection()
         self._unmap_lun(volume, connector)
 
-    def update_volume_status(self):
-        """Retrieve status info."""
-        LOG.debug(_("Updating volume status"))
+    def update_volume_stats(self):
+        """Retrieve stats info."""
+        LOG.debug(_("Updating volume stats"))
         self.conn = self._get_ecom_connection()
         storage_type = self._get_storage_type()
 
index 41117429906d6e2b7a53feef1e6e99b0b368d730..24956246f2143b5ffe89e7656aaa1ff137b4101a 100644 (file)
@@ -221,19 +221,19 @@ class EMCSMISISCSIDriver(driver.ISCSIDriver):
         self.common.terminate_connection(volume, connector)
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self.update_volume_status()
+            self.update_volume_stats()
 
         return self._stats
 
-    def update_volume_status(self):
-        """Retrieve status info from volume group."""
-        LOG.debug(_("Updating volume status"))
-        data = self.common.update_volume_status()
+    def update_volume_stats(self):
+        """Retrieve stats info from volume group."""
+        LOG.debug(_("Updating volume stats"))
+        data = self.common.update_volume_stats()
         backend_name = self.configuration.safe_get('volume_backend_name')
         data['volume_backend_name'] = backend_name or 'EMCSMISISCSIDriver'
         data['storage_protocol'] = 'iSCSI'
index 901924c7e77b440fc5ccb040f7d6f539568f53b9..c076e561a99b943cbdb7d530ccef46d1e3067ae8 100644 (file)
@@ -332,20 +332,20 @@ class GPFSDriver(driver.VolumeDriver):
         pass
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, or stats have never been updated, run update
         the stats first.
         """
         if not self._stats or refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug("Updating volume status")
+        LOG.debug("Updating volume stats")
         data = {}
         backend_name = self.configuration.safe_get('volume_backend_name')
         data["volume_backend_name"] = backend_name or 'GPFS'
index 4c868668b147253b2653ed87c088abe129bc6248..ac66098e4fbb3966f7d8b922d01f5754c631e556 100644 (file)
@@ -546,12 +546,12 @@ class HuaweiISCSIDriver(driver.ISCSIDriver):
         self._delete_luncopy(luncopy_id)
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
@@ -1501,10 +1501,10 @@ class HuaweiISCSIDriver(driver.ISCSIDriver):
                 return False
         return True
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
         backend_name = self.configuration.safe_get('volume_backend_name')
         data["volume_backend_name"] = backend_name or 'HuaweiISCSIDriver'
index 18640c077df8d6ba9f199ebc50cfb6d41a122696..9b26468948a37aa409d60b14d9f1a6986df186ce 100644 (file)
@@ -531,19 +531,19 @@ class LVMISCSIDriver(LVMVolumeDriver, driver.ISCSIDriver):
         self.tgtadm.remove_iscsi_target(iscsi_target, 0, volume['id'])
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
 
         # Note(zhiteng): These information are driver/backend specific,
@@ -566,7 +566,7 @@ class LVMISCSIDriver(LVMVolumeDriver, driver.ISCSIDriver):
                                      self.configuration.volume_group,
                                      run_as_root=True)
         except exception.ProcessExecutionError as exc:
-            LOG.error(_("Error retrieving volume status: %s"), exc.stderr)
+            LOG.error(_("Error retrieving volume stats: %s"), exc.stderr)
             out = False
 
         if out:
@@ -659,18 +659,18 @@ class ThinLVMVolumeDriver(LVMISCSIDriver):
         self._do_lvm_snapshot(orig_lv_name, snapshot)
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
 
         backend_name = self.configuration.safe_get('volume_backend_name')
index a83e274a15d04e41ebc4fbe12e3e87f1d4b9cc44..266b926cf1d76d1a86ce95172c8a2a498416ad0b 100644 (file)
@@ -537,17 +537,17 @@ class NetAppDirectISCSIDriver(driver.ISCSIDriver):
         self._clone_lun(src_vol.name, new_name, 'true')
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
         raise NotImplementedError()
 
 
@@ -829,10 +829,10 @@ class NetAppDirectCmodeISCSIDriver(NetAppDirectISCSIDriver):
         else:
             self.client.set_vserver(None)
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
         netapp_backend = 'NetApp_iSCSI_Cluster_direct'
         backend_name = self.configuration.safe_get('volume_backend_name')
@@ -1112,10 +1112,10 @@ class NetAppDirect7modeISCSIDriver(NetAppDirectISCSIDriver):
             'is-space-reservation-enabled')
         return meta_dict
 
-    def _update_volume_status(self):
+    def _update_volume_stats(self):
         """Retrieve status info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
         netapp_backend = 'NetApp_iSCSI_7mode_direct'
         backend_name = self.configuration.safe_get('volume_backend_name')
index c15787584bb0d7bfe0ae87f03c0ab6204769c2ce..30d4b49b2b83f36be890104ea0eef17dab41c3c5 100644 (file)
@@ -182,9 +182,9 @@ class NetAppNFSDriver(nfs.NfsDriver):
 
         return {'provider_location': share}
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
-        super(NetAppNFSDriver, self)._update_volume_status()
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
+        super(NetAppNFSDriver, self)._update_volume_stats()
 
 
 class NetAppDirectNfsDriver (NetAppNFSDriver):
@@ -344,9 +344,9 @@ class NetAppDirectCmodeNfsDriver (NetAppDirectNfsDriver):
             'destination-path': dest_path})
         self._invoke_successfully(clone_create, vserver)
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
-        super(NetAppDirectCmodeNfsDriver, self)._update_volume_status()
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
+        super(NetAppDirectCmodeNfsDriver, self)._update_volume_stats()
         netapp_backend = 'NetApp_NFS_cluster_direct'
         backend_name = self.configuration.safe_get('volume_backend_name')
         self._stats["volume_backend_name"] = (backend_name or
@@ -476,9 +476,9 @@ class NetAppDirect7modeNfsDriver (NetAppDirectNfsDriver):
                 time.sleep(5)
             retry = retry - 1
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
-        super(NetAppDirect7modeNfsDriver, self)._update_volume_status()
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
+        super(NetAppDirect7modeNfsDriver, self)._update_volume_stats()
         netapp_backend = 'NetApp_NFS_7mode_direct'
         backend_name = self.configuration.safe_get('volume_backend_name')
         self._stats["volume_backend_name"] = (backend_name or
index 4bc3f68789baf165a6588e6645d9c156cf9b074f..d181361860992c018abd9182cebd0fa8a97a87bd 100644 (file)
@@ -284,17 +284,17 @@ class NexentaDriver(driver.ISCSIDriver):  # pylint: disable=R0921
                      {'target': target_name, 'exc': exc})
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info for Nexenta device."""
+    def _update_volume_stats(self):
+        """Retrieve stats info for Nexenta device."""
 
         # NOTE(jdg): Aimon Bustardo was kind enough to point out the
         # info he had regarding Nexenta Capabilities, ideally it would
@@ -303,7 +303,7 @@ class NexentaDriver(driver.ISCSIDriver):  # pylint: disable=R0921
         KB = 1024
         MB = KB ** 2
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
         backend_name = self.__class__.__name__
         if self.configuration:
index 275b61000081edb1596977d48871f9acf390e227..b851c4eb87ddc955202f5ba223d34c7750daede2 100644 (file)
@@ -436,17 +436,17 @@ class NfsDriver(RemoteFsDriver):
                 raise
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If 'refresh' is True, run update the stats first.
         """
         if refresh or not self._stats:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
         data = {}
         backend_name = self.configuration.safe_get('volume_backend_name')
index ad545c09f59831f59472c48c1c9dde4236c81db7..c339e34a89fe8deaf98a27688d30edcfcaa5c8f0 100755 (executable)
@@ -1343,20 +1343,20 @@ class StorwizeSVCDriver(san.SanISCSIDriver):
     """====================================================================="""
 
     def get_volume_stats(self, refresh=False):
-        """Get volume status.
+        """Get volume stats.
 
         If we haven't gotten stats yet or 'refresh' is True,
         run update the stats first.
         """
         if not self._stats or refresh:
-            self._update_volume_status()
+            self._update_volume_stats()
 
         return self._stats
 
-    def _update_volume_status(self):
-        """Retrieve status info from volume group."""
+    def _update_volume_stats(self):
+        """Retrieve stats info from volume group."""
 
-        LOG.debug(_("Updating volume status"))
+        LOG.debug(_("Updating volume stats"))
         data = {}
 
         data['vendor_name'] = 'IBM'
@@ -1373,7 +1373,7 @@ class StorwizeSVCDriver(san.SanISCSIDriver):
         ssh_cmd = 'svcinfo lssystem -delim !'
         attributes = self._execute_command_and_parse_attributes(ssh_cmd)
         if not attributes or not attributes['name']:
-            exception_message = (_('_update_volume_status: '
+            exception_message = (_('_update_volume_stats: '
                                    'Could not get system name'))
             raise exception.VolumeBackendAPIException(data=exception_message)
 
@@ -1386,7 +1386,7 @@ class StorwizeSVCDriver(san.SanISCSIDriver):
         attributes = self._execute_command_and_parse_attributes(ssh_cmd)
         if not attributes:
             LOG.error(_('Could not get pool data from the storage'))
-            exception_message = (_('_update_volume_status: '
+            exception_message = (_('_update_volume_stats: '
                                    'Could not get storage pool data'))
             raise exception.VolumeBackendAPIException(data=exception_message)