apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-22 14:55:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

More cleanup

Browse Source
This commit is contained in:
Lukas Joswiak 2021-06-15 15:08:17 -07:00
parent eb3fb811d4
commit f938ed6a7e
2 changed files with 4 additions and 10 deletions

12
fdbclient/ActorLineageProfiler.cpp

@ -249,15 +249,9 @@ std::vector<std::shared_ptr<Sample>> SampleCollection_t::get(double from /*= 0.0
return res; return res;
} }
// void sample(const Reference<ActorLineage>& lineage) { void sample(Reference<ActorLineage>* p) {
void sample(Reference<ActorLineage>* ptr) { if (!p->isValid()) { return; }
// boost::asio::post(ActorLineageProfiler::instance().context(), [lineage]() { boost::asio::post(ActorLineageProfiler::instance().context(), [lineage = Reference<ActorLineage>::addRef(p->getPtr())]() {
// SampleCollection::instance().collect(lineage);
// });
if (!ptr->isValid()) {
return;
}
boost::asio::post(ActorLineageProfiler::instance().context(), [lineage = Reference<ActorLineage>::addRef(ptr->getPtr())]() {
SampleCollection::instance().collect(lineage); SampleCollection::instance().collect(lineage);
}); });
} }

2
flow/flow.cpp

@ -48,7 +48,7 @@ Reference<ActorLineage> getCurrentLineage() {
return *currentLineage; return *currentLineage;
} }
void sample(Reference<ActorLineage>* ptr); void sample(Reference<ActorLineage>* p);
void replaceLineage(LineageReference* lineage) { void replaceLineage(LineageReference* lineage) {
if (!startSampling) { if (!startSampling) {