mirror of
https://github.com/facebook/sapling.git
synced 2024-10-07 23:38:50 +03:00
761d5d2c8e
Summary: Some threads update FUSE counters, some threads update HgBackingStore counters, and some threads update HgImporter counters. No thread updates all of FUSE counters, HgBackingStore counters, and HgImporter counters. FUSE threads and HgImporter threads allocate the full set of counters (EdenThreadStats), even though many of the allocated counters can never be used during the thread's lifetime. Reduce redundant allocation (and overhead during counter aggregation): split EdenThreadStats into three classes (FuseThreadStats, HgBackingStoreThreadStats, and HgImporterThreadStats) so different threads can allocate different sets of counters. This diff should not change observable behavior. Reviewed By: simpkins Differential Revision: D14822273 fbshipit-source-id: cfd238187d20a0b8d3959673401ecad894e2095b
123 lines
3.3 KiB
C++
123 lines
3.3 KiB
C++
/*
|
|
* Copyright (c) 2016-present, Facebook, Inc.
|
|
* All rights reserved.
|
|
*
|
|
* This source code is licensed under the BSD-style license found in the
|
|
* LICENSE file in the root directory of this source tree. An additional grant
|
|
* of patent rights can be found in the PATENTS file in the same directory.
|
|
*
|
|
*/
|
|
#include "eden/fs/fuse/RequestData.h"
|
|
|
|
#include <folly/logging/xlog.h>
|
|
|
|
#include "eden/fs/fuse/Dispatcher.h"
|
|
#include "eden/fs/utils/SystemError.h"
|
|
|
|
using namespace folly;
|
|
using namespace std::chrono;
|
|
|
|
namespace facebook {
|
|
namespace eden {
|
|
|
|
const std::string RequestData::kKey("fuse");
|
|
|
|
RequestData::RequestData(
|
|
FuseChannel* channel,
|
|
const fuse_in_header& fuseHeader,
|
|
Dispatcher* dispatcher)
|
|
: channel_(channel), fuseHeader_(fuseHeader), dispatcher_(dispatcher) {}
|
|
|
|
bool RequestData::isFuseRequest() {
|
|
return folly::RequestContext::get()->getContextData(kKey) != nullptr;
|
|
}
|
|
|
|
RequestData& RequestData::get() {
|
|
const auto data = folly::RequestContext::get()->getContextData(kKey);
|
|
if (UNLIKELY(!data)) {
|
|
XLOG(FATAL) << "boom for missing RequestData";
|
|
throw std::runtime_error("no fuse request data set in this context!");
|
|
}
|
|
return *dynamic_cast<RequestData*>(data);
|
|
}
|
|
|
|
RequestData& RequestData::create(
|
|
FuseChannel* channel,
|
|
const fuse_in_header& fuseHeader,
|
|
Dispatcher* dispatcher) {
|
|
folly::RequestContext::get()->setContextData(
|
|
RequestData::kKey,
|
|
std::make_unique<RequestData>(channel, fuseHeader, dispatcher));
|
|
return get();
|
|
}
|
|
|
|
void RequestData::startRequest(
|
|
EdenStats* stats,
|
|
FuseThreadStats::HistogramPtr histogram) {
|
|
startTime_ = steady_clock::now();
|
|
DCHECK(latencyHistogram_ == nullptr);
|
|
latencyHistogram_ = histogram;
|
|
stats_ = stats;
|
|
}
|
|
|
|
void RequestData::finishRequest() {
|
|
const auto now = steady_clock::now();
|
|
const auto now_since_epoch = duration_cast<seconds>(now.time_since_epoch());
|
|
const auto diff = duration_cast<microseconds>(now - startTime_);
|
|
stats_->getFuseStatsForCurrentThread().recordLatency(
|
|
latencyHistogram_, diff, now_since_epoch);
|
|
latencyHistogram_ = nullptr;
|
|
stats_ = nullptr;
|
|
}
|
|
|
|
fuse_in_header RequestData::stealReq() {
|
|
if (fuseHeader_.opcode == 0) {
|
|
throw std::runtime_error("req_ has been released");
|
|
}
|
|
fuse_in_header res = fuseHeader_;
|
|
fuseHeader_.opcode = 0;
|
|
return res;
|
|
}
|
|
|
|
const fuse_in_header& RequestData::getReq() const {
|
|
if (fuseHeader_.opcode == 0) {
|
|
throw std::runtime_error("req_ has been released");
|
|
}
|
|
return fuseHeader_;
|
|
}
|
|
|
|
const fuse_in_header& RequestData::examineReq() const {
|
|
// Will just return the fuseHeader_ and not throw(unlike getReq)
|
|
// The caller is responsible to check the opcode and ignore if zero
|
|
return fuseHeader_;
|
|
}
|
|
|
|
Dispatcher* RequestData::getDispatcher() const {
|
|
return dispatcher_;
|
|
}
|
|
|
|
void RequestData::replyError(int err) {
|
|
channel_->replyError(stealReq(), err);
|
|
}
|
|
|
|
void RequestData::replyNone() {
|
|
stealReq();
|
|
}
|
|
|
|
void RequestData::systemErrorHandler(const std::system_error& err) {
|
|
int errnum = EIO;
|
|
if (isErrnoError(err)) {
|
|
errnum = err.code().value();
|
|
}
|
|
XLOG(DBG5) << folly::exceptionStr(err);
|
|
RequestData::get().replyError(errnum);
|
|
}
|
|
|
|
void RequestData::genericErrorHandler(const std::exception& err) {
|
|
XLOG(DBG5) << folly::exceptionStr(err);
|
|
RequestData::get().replyError(EIO);
|
|
}
|
|
|
|
} // namespace eden
|
|
} // namespace facebook
|