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

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