#undef dout_prefix
#define dout_prefix *_dout << "cephfs::mirror::FSMirror " << __func__
+using namespace std;
+
namespace cephfs {
namespace mirror {
: fs_mirror(fs_mirror) {
}
- void acquire_directory(string_view dir_path) override {
+ void acquire_directory(std::string_view dir_path) override {
fs_mirror->handle_acquire_directory(dir_path);
}
- void release_directory(string_view dir_path) override {
+ void release_directory(std::string_view dir_path) override {
fs_mirror->handle_release_directory(dir_path);
}
};
void shutdown_instance_watcher();
void handle_shutdown_instance_watcher(int r);
- void handle_acquire_directory(string_view dir_path);
- void handle_release_directory(string_view dir_path);
+ void handle_acquire_directory(std::string_view dir_path);
+ void handle_release_directory(std::string_view dir_path);
};
} // namespace mirror
#undef dout_prefix
#define dout_prefix *_dout << "cephfs::mirror::InstanceWatcher " << __func__
+using namespace std;
+
namespace cephfs {
namespace mirror {
virtual ~Listener() {
}
- virtual void acquire_directory(string_view dir_path) = 0;
- virtual void release_directory(string_view dir_path) = 0;
+ virtual void acquire_directory(std::string_view dir_path) = 0;
+ virtual void release_directory(std::string_view dir_path) = 0;
};
static InstanceWatcher *create(librados::IoCtx &ioctx,
#define dout_prefix *_dout << "cephfs::mirror::PeerReplayer(" \
<< m_peer.uuid << ") " << __func__
+using namespace std;
+
namespace cephfs {
namespace mirror {
void shutdown();
// add a directory to mirror queue
- void add_directory(string_view dir_root);
+ void add_directory(std::string_view dir_root);
// remove a directory from queue
- void remove_directory(string_view dir_root);
+ void remove_directory(std::string_view dir_root);
// admin socket helpers
void peer_status(Formatter *f);
#include <vector>
+using namespace std;
+
void usage() {
std::cout << "usage: cephfs-mirror [options...]" << std::endl;
std::cout << "options:\n";