pg: add test cases for pg list_missing on EC pool

Reviewed-by: Guang Yang <yguang@yahoo-inc.com>

diff --git a/tasks/ec_lost_unfound.py b/tasks/ec_lost_unfound.py
index 5a9678d8c275ce8f7e5e02629e581e3ea99c483b..0fc107d55feb86a78b7d5933807b1834e93599d1 100644 (file)
--- a/tasks/ec_lost_unfound.py
+++ b/tasks/ec_lost_unfound.py
@@ -69,7 +69,7 @@ def task(ctx, config):
     manager.mark_down_osd(0)
     manager.kill_osd(3)
     manager.mark_down_osd(3)
-    
+
     for f in range(1, 10):
         rados(ctx, mon, ['-p', pool, 'put', 'new_%d' % f, dummyfile])
         rados(ctx, mon, ['-p', pool, 'put', 'existed_%d' % f, dummyfile])
@@ -99,6 +99,7 @@ def task(ctx, config):
 
     # mark stuff lost
     pgs = manager.get_pg_stats()
+    unfound_objs = {}
     for pg in pgs:
         if pg['stat_sum']['num_objects_unfound'] > 0:
             # verify that i can list them direct from the osd
@@ -106,6 +107,8 @@ def task(ctx, config):
                      pg['state']);
             m = manager.list_pg_missing(pg['pgid'])
             log.info('%s' % m)
+            for obj in m['objects']:
+                unfound_objs[obj['oid']['oid']] = True
             assert m['num_unfound'] == pg['stat_sum']['num_objects_unfound']
 
             log.info("reverting unfound in %s", pg['pgid'])
@@ -114,6 +117,12 @@ def task(ctx, config):
         else:
             log.info("no unfound in %s", pg['pgid'])
 
+    # Verify the unfound objects list
+    for f in range(1, 10):
+        assert unfound_objs['new_%d' % f] == True
+        assert unfound_objs['existed_%d' % f] == True
+        assert unfound_objs['existing_%d' % f] == True
+
     manager.raw_cluster_cmd('tell', 'osd.0', 'debug', 'kick_recovery_wq', '5')
     manager.raw_cluster_cmd('tell', 'osd.2', 'debug', 'kick_recovery_wq', '5')
     manager.raw_cluster_cmd('tell', 'osd.3', 'debug', 'kick_recovery_wq', '5')