ceph/src/pybind/mgr/dashboard/services/tcmu_service.py

   1 from mgr_util import get_most_recent_rate
   2
   3 from dashboard.services.ceph_service import CephService
   4
   5 from .. import mgr
   6
   7 try:
   8     from typing import Dict
   9 except ImportError:
  10     pass  # Just for type checking
  11
  12
  13 SERVICE_TYPE = 'tcmu-runner'
  14
  15
  16 class TcmuService(object):
  17     # pylint: disable=too-many-nested-blocks
  18     # pylint: disable=too-many-branches
  19     @staticmethod
  20     def get_iscsi_info():
  21         daemons = {}  # type: Dict[str, dict]
  22         images = {}  # type: Dict[str, dict]
  23         for service in CephService.get_service_list(SERVICE_TYPE):
  24             metadata = service['metadata']
  25             if metadata is None:
  26                 continue
  27             status = service['status']
  28             hostname = service['hostname']
  29
  30             daemon = daemons.get(hostname, None)
  31             if daemon is None:
  32                 daemon = {
  33                     'server_hostname': hostname,
  34                     'version': metadata['ceph_version'],
  35                     'optimized_paths': 0,
  36                     'non_optimized_paths': 0
  37                 }
  38                 daemons[hostname] = daemon
  39
  40             service_id = service['id']
  41             device_id = service_id.split(':')[-1]
  42             image = images.get(device_id)
  43             if image is None:
  44                 image = {
  45                     'device_id': device_id,
  46                     'pool_name': metadata['pool_name'],
  47                     'name': metadata['image_name'],
  48                     'id': metadata.get('image_id', None),
  49                     'optimized_paths': [],
  50                     'non_optimized_paths': []
  51                 }
  52                 images[device_id] = image
  53
  54             if status.get('lock_owner', 'false') == 'true':
  55                 daemon['optimized_paths'] += 1
  56                 image['optimized_paths'].append(hostname)
  57
  58                 perf_key_prefix = "librbd-{id}-{pool}-{name}.".format(
  59                     id=metadata.get('image_id', ''),
  60                     pool=metadata['pool_name'],
  61                     name=metadata['image_name'])
  62                 perf_key = "{}lock_acquired_time".format(perf_key_prefix)
  63                 perf_value = mgr.get_counter('tcmu-runner',
  64                                              service_id,
  65                                              perf_key)[perf_key]
  66                 if perf_value:
  67                     lock_acquired_time = perf_value[-1][1] / 1000000000
  68                 else:
  69                     lock_acquired_time = 0
  70                 if lock_acquired_time > image.get('optimized_since', 0):
  71                     image['optimized_daemon'] = hostname
  72                     image['optimized_since'] = lock_acquired_time
  73                     image['stats'] = {}
  74                     image['stats_history'] = {}
  75                     for s in ['rd', 'wr', 'rd_bytes', 'wr_bytes']:
  76                         perf_key = "{}{}".format(perf_key_prefix, s)
  77                         rates = CephService.get_rates('tcmu-runner', service_id, perf_key)
  78                         image['stats'][s] = get_most_recent_rate(rates)
  79                         image['stats_history'][s] = rates
  80             else:
  81                 daemon['non_optimized_paths'] += 1
  82                 image['non_optimized_paths'].append(hostname)
  83
  84         # clear up races w/ tcmu-runner clients that haven't detected
  85         # loss of optimized path
  86         for image in images.values():
  87             optimized_daemon = image.get('optimized_daemon', None)
  88             if optimized_daemon:
  89                 for daemon_name in image['optimized_paths']:
  90                     if daemon_name != optimized_daemon:
  91                         daemon = daemons[daemon_name]
  92                         daemon['optimized_paths'] -= 1
  93                         daemon['non_optimized_paths'] += 1
  94                         image['non_optimized_paths'].append(daemon_name)
  95                 image['optimized_paths'] = [optimized_daemon]
  96
  97         return {
  98             'daemons': sorted(daemons.values(),
  99                               key=lambda d: d['server_hostname']),
 100             'images': sorted(images.values(), key=lambda i: ['id']),
 101         }
 102
 103     @staticmethod
 104     def get_image_info(pool_name, image_name, get_iscsi_info):
 105         for image in get_iscsi_info['images']:
 106             if image['pool_name'] == pool_name and image['name'] == image_name:
 107                 return image
 108         return None