RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-01 08:32:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

librgw: add depth and make_path to RGWFileHandle

Browse Source 
This just (mostly) efficiently builds a full path from its segments
on demand.

Signed-off-by: Matt Benjamin <mbenjamin@redhat.com>
This commit is contained in:
Matt Benjamin 2015-11-30 12:29:39 -05:00
parent 443e9c9c4a
commit 6691da0441
1 changed files with 35 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/rgw/rgw_file.h
View File

@ -12,6 +12,7 @@
#include <atomic>
#include <mutex>
#include <boost/intrusive_ptr.hpp>
#include <boost/range/adaptor/reversed.hpp>
#include "xxhash.h"
#include "include/buffer.h"
#include "common/cohort_lru.h"
@ -111,6 +112,7 @@ namespace rgw {
RGWFHRef parent;
/* const */ std::string name; /* XXX file or bucket name */
/* const */ fh_key fhk;
struct state {
uint64_t dev;
size_t size;
@ -120,11 +122,15 @@ namespace rgw {
struct timespec atime;
state() : dev(0), size(0), nlink(1), ctime{0,0}, mtime{0,0}, atime{0,0} {}
} state;
uint16_t depth;
uint32_t flags;
public:
const static string root_name;
static constexpr uint16_t MAX_DEPTH = 256;
static constexpr uint32_t FLAG_NONE = 0x0000;
static constexpr uint32_t FLAG_OPEN = 0x0001;
static constexpr uint32_t FLAG_ROOT = 0x0002;
@ -134,7 +140,7 @@ namespace rgw {
private:
RGWFileHandle(RGWLibFS* _fs, uint32_t fs_inst)
: refcnt(1), fs(_fs), parent(nullptr), flags(FLAG_ROOT)
: refcnt(1), fs(_fs), parent(nullptr), depth(0), flags(FLAG_ROOT)
{
/* root */
fh.fh_type = RGW_FS_TYPE_DIRECTORY;
@ -161,6 +167,8 @@ namespace rgw {
fh.fh_type = parent->is_root()
? RGW_FS_TYPE_DIRECTORY : RGW_FS_TYPE_FILE;
depth = parent->depth + 1;
/* save constant fhk */
fh_key fhk(parent->name, name);
fh.fh_hk = fhk.fh_hk; /* XXX redundant in fh_hk */
@ -173,7 +181,9 @@ namespace rgw {
return fhk;
}
const size_t get_size() { return state.size; }
size_t get_size() const { return state.size; }
uint16_t get_depth() const { return depth; }
struct rgw_file_handle* get_fh() { return &fh; }
@ -219,6 +229,29 @@ namespace rgw {
const std::string& object_name() const { return name; }
std::string make_path() {
if (depth <= 1) {
return object_name();
}
std::string path;
std::vector<const std::string*> segments = { &object_name() };
int reserve = object_name().length();
while (parent && !parent->is_bucket()) {
segments.push_back(&parent->object_name());
reserve += (1 + parent->object_name().length());
}
bool first = true;
path.reserve(reserve);
for (auto& s : boost::adaptors::reverse(segments)) {
if (! first) {
path += "/";
first = false;
}
path += *s;
}
return path;
}
bool is_open() const { return flags & FLAG_OPEN; }
bool is_root() const { return flags & FLAG_ROOT; }
bool is_bucket() const { return (fh.fh_type == RGW_FS_TYPE_DIRECTORY); }