Intern
Red Hat
May 2015 – August 2015 (4 months)
Worked on the QoS part of Ceph RADOS. Implemented a customized, scalable prototype of mClock (http://dl.acm.org/citation.cfm?id=1924974) algorithm that runs on OSDs to make sure the Ceph clients could meet their Service Level Objectives (SLO) expressed in terms of three parameters: Reservation (R), Proportional (P), and Limit(L).

hpe/hpe_3par_common.py
class HPE3PARCommon(object):
  hpe_qos_keys = ['minIOPS', 'maxIOPS', 'minBWS', 'maxBWS', 'latency',
                  'priority']

  def create_volume(self, volume):
    self.get_volume_settings_from_type
      self.get_volume_settings_from_type_id(type_id, pool)
        self.get_type_info(type_id)
          qos = self._get_qos_by_volume_type(volume_type)
    self._add_volume_to_volume_set
      self._set_qos_rule(qos, vvs_name)

hpe/hpe_3par_iscsi.py
class HPE3PARISCSIDriver(driver.TransferVD,
                         driver.ManageableVD,
                         driver.ExtendVD,
                         driver.SnapshotVD,
                         driver.ManageableSnapshotsVD,
                         driver.MigrateVD,
                         driver.ConsistencyGroupVD,
                         driver.BaseVD):
  def create_volume(self, volume):
    common = self._login()
      common = self._init_common()
        return hpecommon.HPE3PARCommon(self.configuration,
                                       self._active_backend_id)

hpe/hpe_3par_fc.py
class HPE3PARFCDriver(driver.TransferVD,
                      driver.ManageableVD,
                      driver.ExtendVD,
                      driver.SnapshotVD,
                      driver.ManageableSnapshotsVD,
                      driver.MigrateVD,
                      driver.ConsistencyGroupVD,
                      driver.BaseVD):
  def create_volume(self, volume):
    common = self._login()
      common = self._init_common()
        return hpecommon.HPE3PARCommon(self.configuration,
                                       self._active_backend_id)

netapp/utils.py
QOS_KEYS = frozenset(['maxIOPS', 'maxIOPSperGiB', 'maxBPS', 'maxBPSperGiB'])

netapp/dataontap/block_base.py
class NetAppBlockStorageLibrary(object):
  def create_volume(self, volume):
    self._setup_qos_for_volume

netapp/dataontap/block_cmode.py
class NetAppBlockStorageCmodeLibrary(block_base.NetAppBlockStorageLibrary):
  def _setup_qos_for_volume(self, volume, extra_specs)

netapp/dataontap/nfs_base.py
class NetAppNfsDriver(driver.ManageableVD,
                      driver.CloneableImageVD,
                      driver.SnapshotVD,
                      nfs.NfsDriver):
  def create_volume(self, volume):
    self._do_qos_for_volume

netapp/dataontap/nfs_cmode.py
class NetAppCmodeNfsDriver(nfs_base.NetAppNfsDriver):
  def _do_qos_for_volume(self, volume, extra_specs, cleanup=True)

// 比较奇怪，其它厂商都是在 create_volume 处设置 QoS
emc/scaleio.py
class ScaleIODriver(driver.VolumeDriver):
  def initialize_connection(self, volume, connector):
    qos_specs = self._get_volumetype_qos(volume)

solidfire.py
class SolidFireDriver(san.SanISCSIDriver):
  sf_qos_dict = {'slow': {'minIOPS': 100,
                          'maxIOPS': 200,
                          'burstIOPS': 200},
                 medium': {'minIOPS': 200,
                           'maxIOPS': 400,
                           'burstIOPS': 400},
                 'fast': {'minIOPS': 500,
                          'maxIOPS': 1000,
                          'burstIOPS': 1000},
                 'performant': {'minIOPS': 2000,
                                'maxIOPS': 4000,
                                'burstIOPS': 4000},
                 'off': None}
  sf_qos_keys = ['minIOPS', 'maxIOPS', 'burstIOPS']

  def create_volume(self, volume):
    qos = self._retrieve_qos_setting(volume)
    self._do_volume_create(sf_account, params)

huawei/huawei_driver.py
class HuaweiBaseDriver(driver.VolumeDriver):
  def create_volume(self, volume):
    self._create_base_type_volume(opts, volume, volume_type))
      qos = smartx.SmartQos.get_qos_by_volume_type(volume_type)

huawei/constants.py
HUAWEI_VALID_KEYS = ['maxIOPS', 'minIOPS', 'minBandWidth',
                     'maxBandWidth', 'latency', 'IOType']
QOS_KEYS = [i.upper() for i in HUAWEI_VALID_KEYS]