diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 18:45:59 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 18:45:59 +0000 |
commit | 19fcec84d8d7d21e796c7624e521b60d28ee21ed (patch) | |
tree | 42d26aa27d1e3f7c0b8bd3fd14e7d7082f5008dc /src/os/ObjectStore.cc | |
parent | Initial commit. (diff) | |
download | ceph-19fcec84d8d7d21e796c7624e521b60d28ee21ed.tar.xz ceph-19fcec84d8d7d21e796c7624e521b60d28ee21ed.zip |
Adding upstream version 16.2.11+ds.upstream/16.2.11+dsupstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r-- | src/os/ObjectStore.cc | 133 |
1 files changed, 133 insertions, 0 deletions
diff --git a/src/os/ObjectStore.cc b/src/os/ObjectStore.cc new file mode 100644 index 000000000..dc606bd2c --- /dev/null +++ b/src/os/ObjectStore.cc @@ -0,0 +1,133 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab +/* + * Ceph - scalable distributed file system + * + * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net> + * + * This is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software + * Foundation. See file COPYING. + * + */ +#include <ctype.h> +#include <sstream> +#include "ObjectStore.h" +#include "common/Formatter.h" +#include "common/safe_io.h" + +#ifndef WITH_SEASTAR +#include "filestore/FileStore.h" +#include "memstore/MemStore.h" +#endif +#if defined(WITH_BLUESTORE) +#include "bluestore/BlueStore.h" +#endif +#ifndef WITH_SEASTAR +#include "kstore/KStore.h" +#endif + +using std::string; + +ObjectStore *ObjectStore::create(CephContext *cct, + const string& type, + const string& data, + const string& journal, + osflagbits_t flags) +{ +#ifndef WITH_SEASTAR + if (type == "filestore") { + return new FileStore(cct, data, journal, flags); + } + if (type == "memstore") { + return new MemStore(cct, data); + } +#endif +#if defined(WITH_BLUESTORE) + if (type == "bluestore") { + return new BlueStore(cct, data); + } +#ifndef WITH_SEASTAR + if (type == "random") { + if (rand() % 2) { + return new FileStore(cct, data, journal, flags); + } else { + return new BlueStore(cct, data); + } + } +#endif +#else +#ifndef WITH_SEASTAR + if (type == "random") { + return new FileStore(cct, data, journal, flags); + } +#endif +#endif +#ifndef WITH_SEASTAR + if (type == "kstore" && + cct->check_experimental_feature_enabled("kstore")) { + return new KStore(cct, data); + } +#endif + return NULL; +} + +int ObjectStore::probe_block_device_fsid( + CephContext *cct, + const string& path, + uuid_d *fsid) +{ + int r; + +#if defined(WITH_BLUESTORE) + // first try bluestore -- it has a crc on its header and will fail + // reliably. + r = BlueStore::get_block_device_fsid(cct, path, fsid); + if (r == 0) { + lgeneric_dout(cct, 0) << __func__ << " " << path << " is bluestore, " + << *fsid << dendl; + return r; + } +#endif + +#ifndef WITH_SEASTAR + // okay, try FileStore (journal). + r = FileStore::get_block_device_fsid(cct, path, fsid); + if (r == 0) { + lgeneric_dout(cct, 0) << __func__ << " " << path << " is filestore, " + << *fsid << dendl; + return r; + } +#endif + + return -EINVAL; +} + +int ObjectStore::write_meta(const std::string& key, + const std::string& value) +{ + string v = value; + v += "\n"; + int r = safe_write_file(path.c_str(), key.c_str(), + v.c_str(), v.length(), 0600); + if (r < 0) + return r; + return 0; +} + +int ObjectStore::read_meta(const std::string& key, + std::string *value) +{ + char buf[4096]; + int r = safe_read_file(path.c_str(), key.c_str(), + buf, sizeof(buf)); + if (r <= 0) + return r; + // drop trailing newlines + while (r && isspace(buf[r-1])) { + --r; + } + *value = string(buf, r); + return 0; +} |