self.mount_a.umount_wait()
with self.assert_cluster_log("inode table repaired", invert_match=True):
- self.fs.mds_asok(["scrub_path", "/", "repair", "recursive"])
+ out_json = self.fs.mds_asok(["scrub_path", "/", "repair", "recursive"])
+ self.assertNotEqual(out_json, None)
self.mds_cluster.mds_stop()
self.mds_cluster.mds_fail()
self.fs.wait_for_daemons()
with self.assert_cluster_log("inode table repaired"):
- self.fs.mds_asok(["scrub_path", "/", "repair", "recursive"])
+ out_json = self.fs.mds_asok(["scrub_path", "/", "repair", "recursive"])
+ self.assertNotEqual(out_json, None)
self.mds_cluster.mds_stop()
table_text = self.fs.table_tool(["0", "show", "inode"])
"oh i'm sorry did i overwrite your xattr?")
with self.assert_cluster_log("bad backtrace on inode"):
- self.fs.mds_asok(["scrub_path", "/", "repair", "recursive"])
+ out_json = self.fs.mds_asok(["scrub_path", "/", "repair", "recursive"])
+ self.assertNotEqual(out_json, None)
self.fs.mds_asok(["flush", "journal"])
backtrace = self.fs.read_backtrace(file_ino)
self.assertEqual(['alpha', 'parent_a'],
self._filesystem.wait_for_daemons()
def validate(self):
- self._filesystem.mds_asok(["scrub_path", "/", "recursive", "repair"])
+ out_json = self._filesystem.mds_asok(["scrub_path", "/", "recursive", "repair"])
+ self.assertNotEqual(out_json, None)
self.assertTrue(self._filesystem.are_daemons_healthy())
return self._errors
# Apply any data damage the workload wants
workload.damage()
- self.fs.mds_asok(["scrub_path", "/", "recursive", "repair"])
+ out_json = self.fs.mds_asok(["scrub_path", "/", "recursive", "repair"])
+ self.assertNotEqual(out_json, None)
# See that the files are present and correct
errors = workload.validate()