[BugFix: ZSTACK-34935] handle Ceph EC pool

Signed-off-by: Qun Li <qun.li@zstack.io>

Author: live4thee

zstacklib/zstacklib/utils/ceph.py

@@ -32,7 +32,21 @@ def getCephPoolsCapacity():
             crush_rule = pool.crush_rule
         else:
             crush_rule = pool.crush_ruleset
-        poolCapacity = CephPoolCapacity(pool.pool_name, pool.size, crush_rule)
+
+        if pool.type == 1:
+            poolCapacity = CephPoolCapacity(pool.pool_name, pool.size, crush_rule)
+        elif pool.type == 3:
+            prof = shell.call('ceph osd erasure-code-profile get %s -f json' % pool.erasure_code_profile)
+            jprof = jsonobject.loads(prof)
+            if not jprof.k or not jprof.m:
+                raise Exception('unexpected erasure-code-profile for pool: %s' % pool.pool_name)
+            k = int(jprof.k)
+            m = int(jprof.m)
+            r = float(k+m)/k
+            poolCapacity = CephPoolCapacity(pool.pool_name, pool.size, crush_rule, r)
+        else:
+            raise Exception("unexpected pool type: %s:%d" % (pool.pool_name, pool.type))
+
         result.append(poolCapacity)
 
     # fill crushRuleItemName
@@ -119,21 +133,24 @@ def findAllChilds(node):
                 poolCapacity.availableCapacity = poolCapacity.availableCapacity + osd.kb_avail * 1024
                 poolCapacity.usedCapacity = poolCapacity.usedCapacity + osd.kb_used * 1024
 
+        r = poolCapacity.ecRedundancy if poolCapacity.ecRedundancy else poolCapacity.replicatedSize
+
         if poolCapacity.crushItemOsdsTotalSize != 0 and poolCapacity.replicatedSize != 0:
-            poolCapacity.poolTotalSize = poolCapacity.crushItemOsdsTotalSize / poolCapacity.replicatedSize
+            poolCapacity.poolTotalSize = poolCapacity.crushItemOsdsTotalSize / r
         if poolCapacity.availableCapacity != 0 and poolCapacity.replicatedSize != 0:
-            poolCapacity.availableCapacity = poolCapacity.availableCapacity / poolCapacity.replicatedSize
+            poolCapacity.availableCapacity = poolCapacity.availableCapacity / r
         if poolCapacity.usedCapacity != 0 and poolCapacity.replicatedSize != 0:
-            poolCapacity.usedCapacity = poolCapacity.usedCapacity / poolCapacity.replicatedSize
+            poolCapacity.usedCapacity = poolCapacity.usedCapacity / r
 
     return result
 
 
 class CephPoolCapacity:
 
-    def __init__(self, poolName, replicatedSize, crushRuleSet):
+    def __init__(self, poolName, replicatedSize, crushRuleSet, ecRedundancy=None):
         self.poolName = poolName
         self.replicatedSize = replicatedSize
+        self.ecRedundancy = ecRedundancy
         self.crushRuleSet = crushRuleSet
         self.availableCapacity = 0
         self.usedCapacity = 0