#include "include/buffer_fwd.h"
-namespace ceph::buffer {
+namespace crimson {
seastar::future<> write_file(ceph::buffer::list&& bl,
seastar::sstring fn,
seastar::file_permissions= // 0644
ceph_assert(ch);
ch->encode(bl);
std::string fn = fmt::format("{}/{}", path, col);
- return ceph::buffer::write_file(std::move(bl), fn);
+ return crimson::write_file(std::move(bl), fn);
}).then([&collections, this] {
ceph::bufferlist bl;
ceph::encode(collections, bl);
std::string fn = fmt::format("{}/collections", path);
- return ceph::buffer::write_file(std::move(bl), fn);
+ return crimson::write_file(std::move(bl), fn);
});
});
}
ceph::bufferlist bl;
std::set<coll_t> collections;
ceph::encode(collections, bl);
- return ceph::buffer::write_file(std::move(bl), fn);
+ return crimson::write_file(std::move(bl), fn);
}).then([this] {
return write_meta("type", "memstore");
});
keyring.encode_plaintext(bl);
const auto permissions = (seastar::file_permissions::user_read |
seastar::file_permissions::user_write);
- return ceph::buffer::write_file(std::move(bl), path, permissions);
+ return crimson::write_file(std::move(bl), path, permissions);
}
}).handle_exception_type([path](const fs::filesystem_error& e) {
seastar::fprint(std::cerr, "FATAL: writing new keyring to %s: %s\n", path, e.what());