Signed-off-by: Sage Weil <sage@redhat.com>
dout(20) << __func__ << " journal size=" << size << dendl;
return size;
}
+
+void FileJournal::get_devices(set<string> *ls)
+{
+ char dev_node[PATH_MAX];
+ BlkDev blkdev(fd);
+ if (int rc = blkdev.wholedisk(dev_node, PATH_MAX); rc) {
+ return rc;
+ }
+ ls->insert(dev_node);
+ if (strncmp(dev_node, "dm-", 3) == 0) {
+ get_dm_parents(dev_node, ls);
+ }
+}
void flush() override;
+ void get_devices(set<string> *ls) override;
+
void reserve_throttle_and_backoff(uint64_t count) override;
bool is_writeable() override {
if (strncmp(dev_node, "dm-", 3) == 0) {
get_dm_parents(dev_node, ls);
}
+ if (journal) {
+ journal->get_devices(ls);
+ }
return 0;
}
virtual void flush() = 0;
+ virtual void get_devices(set<string> *ls) {}
+
/**
* reserve_throttle_and_backoff
*