diff options
Diffstat (limited to '')
-rw-r--r-- | src/os/FuseStore.h | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/src/os/FuseStore.h b/src/os/FuseStore.h new file mode 100644 index 00000000..db39ca5e --- /dev/null +++ b/src/os/FuseStore.h @@ -0,0 +1,54 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#ifndef CEPH_OS_FUSESTORE_H +#define CEPH_OS_FUSESTORE_H + +#include <string> +#include <map> +#include <mutex> +#include <functional> + +#include "common/Thread.h" +#include "include/buffer.h" + +class ObjectStore; + +class FuseStore { +public: + ObjectStore *store; + std::string mount_point; + struct fs_info *info; + std::mutex lock; + + struct OpenFile { + std::string path; + bufferlist bl; + bool dirty = false; + int ref = 0; + }; + std::map<std::string,OpenFile*> open_files; + + int open_file(std::string p, struct fuse_file_info *fi, + std::function<int(bufferlist *bl)> f); + + class FuseThread : public Thread { + FuseStore *fs; + public: + explicit FuseThread(FuseStore *f) : fs(f) {} + void *entry() override { + fs->loop(); + return NULL; + } + } fuse_thread; + + FuseStore(ObjectStore *s, std::string p); + ~FuseStore(); + + int main(); + int start(); + int loop(); + int stop(); +}; + +#endif |