mirror of
https://github.com/facebook/sapling.git
synced 2024-10-10 08:47:12 +03:00
34598d4337
Summary: The EdenFS codebase uses folly/logging/xlog to log, but we were still relying on glog for the various CHECK macros. Since xlog also contains equivalent CHECK macros, let's just rely on them instead. This is mostly codemodded + arc lint + various fixes to get it compile. Reviewed By: chadaustin Differential Revision: D24871174 fbshipit-source-id: 4d2a691df235d6dbd0fbd8f7c19d5a956e86b31c
108 lines
3.5 KiB
C++
108 lines
3.5 KiB
C++
/*
|
|
* Copyright (c) Facebook, Inc. and its affiliates.
|
|
*
|
|
* This software may be used and distributed according to the terms of the
|
|
* GNU General Public License version 2.
|
|
*/
|
|
|
|
#include "eden/fs/store/StatsFetchContext.h"
|
|
#include <folly/logging/xlog.h>
|
|
|
|
namespace facebook {
|
|
namespace eden {
|
|
|
|
StatsFetchContext::StatsFetchContext(
|
|
std::optional<pid_t> pid,
|
|
Cause cause,
|
|
folly::StringPiece causeDetail)
|
|
: clientPid_{pid}, cause_{cause}, causeDetail_{std::move(causeDetail)} {}
|
|
|
|
StatsFetchContext::StatsFetchContext(const StatsFetchContext& other) {
|
|
for (size_t y = 0; y < ObjectFetchContext::kObjectTypeEnumMax; ++y) {
|
|
for (size_t x = 0; x < ObjectFetchContext::kOriginEnumMax; ++x) {
|
|
// This could almost certainly use a more relaxed memory ordering.
|
|
counts_[y][x] = other.counts_[y][x].load();
|
|
}
|
|
}
|
|
}
|
|
|
|
void StatsFetchContext::didFetch(ObjectType type, const Hash&, Origin origin) {
|
|
XCHECK(type < ObjectFetchContext::kObjectTypeEnumMax)
|
|
<< "type is out of range: " << type;
|
|
XCHECK(origin < ObjectFetchContext::kOriginEnumMax)
|
|
<< "origin is out of range: " << type;
|
|
counts_[type][origin].fetch_add(1, std::memory_order_acq_rel);
|
|
}
|
|
|
|
uint64_t StatsFetchContext::countFetchesOfType(ObjectType type) const {
|
|
XCHECK(type < ObjectFetchContext::kObjectTypeEnumMax)
|
|
<< "type is out of range: " << type;
|
|
uint64_t result = 0;
|
|
for (unsigned origin = 0; origin < ObjectFetchContext::kOriginEnumMax;
|
|
++origin) {
|
|
result += counts_[type][origin].load(std::memory_order_acquire);
|
|
}
|
|
return result;
|
|
}
|
|
|
|
void StatsFetchContext::merge(const StatsFetchContext& other) {
|
|
for (unsigned type = 0; type < ObjectFetchContext::kObjectTypeEnumMax;
|
|
++type) {
|
|
for (unsigned origin = 0; origin < ObjectFetchContext::kOriginEnumMax;
|
|
++origin) {
|
|
counts_[type][origin] += other.counts_[type][origin];
|
|
}
|
|
}
|
|
}
|
|
|
|
uint64_t StatsFetchContext::countFetchesOfTypeAndOrigin(
|
|
ObjectType type,
|
|
Origin origin) const {
|
|
XCHECK(type < ObjectFetchContext::kObjectTypeEnumMax)
|
|
<< "type is out of range: " << type;
|
|
XCHECK(origin < ObjectFetchContext::kOriginEnumMax)
|
|
<< "origin is out of range: " << type;
|
|
return counts_[type][origin].load(std::memory_order_acquire);
|
|
}
|
|
|
|
FetchStatistics StatsFetchContext::computeStatistics() const {
|
|
auto computePercent = [&](uint64_t n, uint64_t d) -> unsigned short {
|
|
XDCHECK_LE(n, d) << n << " > " << d;
|
|
if (d == 0) {
|
|
return 0;
|
|
}
|
|
return (1000 * n / d + 5) / 10;
|
|
};
|
|
|
|
auto computeAccessStats = [&](ObjectFetchContext::ObjectType type) {
|
|
uint64_t fromMemory = counts_[type][ObjectFetchContext::FromMemoryCache];
|
|
uint64_t fromDisk = counts_[type][ObjectFetchContext::FromDiskCache];
|
|
uint64_t fromBackingStore =
|
|
counts_[type][ObjectFetchContext::FromBackingStore];
|
|
uint64_t total = fromMemory + fromDisk + fromBackingStore;
|
|
return FetchStatistics::Access{
|
|
total, fromBackingStore, computePercent(fromMemory + fromDisk, total)};
|
|
};
|
|
|
|
auto result = FetchStatistics{};
|
|
result.tree = computeAccessStats(ObjectFetchContext::Tree);
|
|
result.blob = computeAccessStats(ObjectFetchContext::Blob);
|
|
result.metadata = computeAccessStats(ObjectFetchContext::BlobMetadata);
|
|
return result;
|
|
}
|
|
|
|
std::optional<pid_t> StatsFetchContext::getClientPid() const {
|
|
return clientPid_;
|
|
}
|
|
|
|
ObjectFetchContext::Cause StatsFetchContext::getCause() const {
|
|
return cause_;
|
|
}
|
|
|
|
std::optional<folly::StringPiece> StatsFetchContext::getCauseDetail() const {
|
|
return causeDetail_;
|
|
}
|
|
|
|
} // namespace eden
|
|
} // namespace facebook
|