aboutsummaryrefslogtreecommitdiff
path: root/src/zenstore/filecas.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/zenstore/filecas.cpp')
-rw-r--r--src/zenstore/filecas.cpp26
1 files changed, 26 insertions, 0 deletions
diff --git a/src/zenstore/filecas.cpp b/src/zenstore/filecas.cpp
index f64427807..339e5de0a 100644
--- a/src/zenstore/filecas.cpp
+++ b/src/zenstore/filecas.cpp
@@ -43,8 +43,20 @@ ZEN_THIRD_PARTY_INCLUDES_START
#endif
ZEN_THIRD_PARTY_INCLUDES_END
+#include <zencore/memory/llm.h>
+
+//////////////////////////////////////////////////////////////////////////
+
namespace zen {
+const FLLMTag&
+GetFileCasTag()
+{
+ static FLLMTag _("file", FLLMTag("cas"));
+
+ return _;
+}
+
namespace {
template<typename T>
void Reset(T& V)
@@ -150,6 +162,7 @@ FileCasStrategy::~FileCasStrategy()
void
FileCasStrategy::Initialize(const std::filesystem::path& RootDirectory, bool IsNewStore)
{
+ ZEN_MEMSCOPE(GetFileCasTag());
ZEN_TRACE_CPU("FileCas::Initialize");
using namespace filecas::impl;
@@ -248,6 +261,8 @@ FileCasStrategy::Initialize(const std::filesystem::path& RootDirectory, bool IsN
bool
FileCasStrategy::UpdateIndex(const IoHash& ChunkHash, uint64_t ChunkSize)
{
+ ZEN_MEMSCOPE(GetFileCasTag());
+
uint64 OldChunkSize = 0;
{
RwLock::ExclusiveLockScope _(m_Lock);
@@ -270,6 +285,8 @@ FileCasStrategy::UpdateIndex(const IoHash& ChunkHash, uint64_t ChunkSize)
CasStore::InsertResult
FileCasStrategy::InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash, CasStore::InsertMode Mode)
{
+ ZEN_MEMSCOPE(GetFileCasTag());
+
ZEN_TRACE_CPU("FileCas::InsertChunk");
ZEN_ASSERT(m_IsInitialized);
@@ -708,6 +725,8 @@ FileCasStrategy::IterateChunks(std::function<void(const IoHash& Hash, IoBuffer&&
void
FileCasStrategy::Flush()
{
+ ZEN_MEMSCOPE(GetFileCasTag());
+
ZEN_TRACE_CPU("FileCas::Flush");
m_CasLog.Flush();
@@ -717,6 +736,8 @@ FileCasStrategy::Flush()
void
FileCasStrategy::ScrubStorage(ScrubContext& Ctx)
{
+ ZEN_MEMSCOPE(GetFileCasTag());
+
ZEN_TRACE_CPU("FileCas::ScrubStorage");
if (Ctx.IsSkipCas())
@@ -896,6 +917,7 @@ FileCasStrategy::ValidateEntry(const FileCasIndexEntry& Entry, std::string& OutR
void
FileCasStrategy::MakeIndexSnapshot()
{
+ ZEN_MEMSCOPE(GetFileCasTag());
ZEN_TRACE_CPU("FileCas::MakeIndexSnapshot");
using namespace filecas::impl;
@@ -1208,6 +1230,7 @@ public:
virtual void CompactStore(GcCtx& Ctx, GcCompactStoreStats& Stats, const std::function<uint64_t()>&) override
{
+ ZEN_MEMSCOPE(GetFileCasTag());
ZEN_TRACE_CPU("FileCas::CompactStore");
auto Log = [&Ctx]() { return Ctx.Logger; };
@@ -1351,6 +1374,7 @@ public:
GcStats& Stats,
const GetUnusedReferencesFunc& GetUnusedReferences) override
{
+ ZEN_MEMSCOPE(GetFileCasTag());
ZEN_TRACE_CPU("FileCas::RemoveUnreferencedData");
auto Log = [&Ctx]() { return Ctx.Logger; };
@@ -1432,6 +1456,8 @@ FileCasStrategy::GetGcName(GcCtx&)
GcReferencePruner*
FileCasStrategy::CreateReferencePruner(GcCtx& Ctx, GcReferenceStoreStats&)
{
+ ZEN_MEMSCOPE(GetFileCasTag());
+
ZEN_TRACE_CPU("FileCas::CreateReferencePruner");
auto Log = [&Ctx]() { return Ctx.Logger; };