apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-06-02 19:25:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Refactor profiler into cpu and heap profilers

Browse Source
This commit is contained in:
Jingyu Zhou 2019-04-03 20:54:30 -07:00
parent 433060ef95
commit eaaf58ee34
1 changed files with 20 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
fdbserver/worker.actor.cpp
View File

@ -433,22 +433,17 @@ void updateCpuProfiler(ProfilerRequest req) {
}
break;
case ProfilerRequest::Type::GPROF_HEAP:
#if defined(__linux__) && defined(USE_GPERFTOOLS) && !defined(VALGRIND)
HeapProfilerDump("User triggered heap dump");
#endif
break;
}
}
ACTOR Future<Void> runProfiler(ProfilerRequest req) {
ACTOR Future<Void> runCpuProfiler(ProfilerRequest req) {
if (req.action == ProfilerRequest::Action::RUN) {
req.action = ProfilerRequest::Action::ENABLE;
updateCpuProfiler(req);
if (req.type != ProfilerRequest::Type::GPROF_HEAP) {
wait(delay(req.duration));
req.action = ProfilerRequest::Action::DISABLE;
updateCpuProfiler(req);
}
wait(delay(req.duration));
req.action = ProfilerRequest::Action::DISABLE;
updateCpuProfiler(req);
return Void();
} else {
updateCpuProfiler(req);
@ -456,6 +451,22 @@ ACTOR Future<Void> runProfiler(ProfilerRequest req) {
}
}
void runHeapProfiler() {
#if defined(__linux__) && defined(USE_GPERFTOOLS) && !defined(VALGRIND)
HeapProfilerDump("User triggered heap dump");
#endif
}
ACTOR Future<Void> runProfiler(ProfilerRequest req) {
if (req.type == ProfilerRequest::Type::GPROF_HEAP) {
runHeapProfiler();
return Void();
}
Future<Void> f = runCpuProfiler(req);
wait(f);
return Void();
}
ACTOR Future<Void> storageServerRollbackRebooter( Future<Void> prevStorageServer, KeyValueStoreType storeType, std::string filename, UID id, LocalityData locality, Reference<AsyncVar<ServerDBInfo>> db, std::string folder, ActorCollection* filesClosed, int64_t memoryLimit, IKeyValueStore* store ) {
loop {
ErrorOr<Void> e = wait( errorOr( prevStorageServer) );