X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Fadmin_socket%2Fosd_requests;fp=src%2Fceph%2Fsrc%2Ftest%2Fadmin_socket%2Fosd_requests;h=f748d9dc176797ab0688fbdd3afe2f312126437c;hb=812ff6ca9fcd3e629e49d4328905f33eee8ca3f5;hp=0000000000000000000000000000000000000000;hpb=15280273faafb77777eab341909a3f495cf248d9;p=stor4nfv.git

diff --git a/src/ceph/src/test/admin_socket/osd_requests b/src/ceph/src/test/admin_socket/osd_requests
new file mode 100644
index 0000000..f748d9d
--- /dev/null
+++ b/src/ceph/src/test/admin_socket/osd_requests
@@ -0,0 +1,28 @@
+#!/usr/bin/env python
+
+import json
+import sys
+
+def main():
+    """
+    Read json output of admin socket command 'dump_ops_in_flight' from
+    stdin, and check that it is consistent.
+    """
+    read = sys.stdin.read()
+    records = json.loads(read)
+
+    info_types = ['num_ops', 'ops']
+    assert sorted(records.keys()) == sorted(info_types)
+    assert(records['num_ops'] == len(records['ops']))
+    
+    for op in records['ops']:
+        assert op['description'] is not None
+        assert op['received_at'] is not None
+        assert op['age'] is not None
+        assert op['flag_point'] is not None
+        if op['client_info']:
+            assert op['client_info']['client'] is not None
+            assert op['client_info']['tid'] is not None
+
+if __name__ == '__main__':
+    main()