Method stop

3rdparty/libprocess/src/memory_profiler.cpp:730–784

TODO(bevers): Add a way to dump an intermediate profile without stopping the data collection.

// TODO(bevers): Add a way to dump an intermediate profile without
// stopping the data collection.
Future<http::Response> MemoryProfiler::stop(
    const http::Request& request,
    const Option<http::authentication::Principal>&)
{
  if (!detectJemalloc()) {
    return http::BadRequest(string(JEMALLOC_NOT_DETECTED_MESSAGE) + ".\n");
  }

  Try<bool> active = jemalloc::profilingActive();
  if (active.isError()) {
    return http::BadRequest(
        "Error interfacing with jemalloc: " + active.error() + ".\n");
  }

  if (!currentRun.isSome() && active.get()) {
    // TODO(bevers): Allow stopping even in this case.
    return http::BadRequest(
        "Profiling is active, but was not started by libprocess. Accessing the"
        " raw profile through libprocess is currently not supported.\n");
  }

  // If stop is successful or a no-op, `jemallocRawProfile` will be `Some`.
  stopAndGenerateRawProfile();

  if (rawProfile.isError()) {
    return http::BadRequest(rawProfile.error() + ".\n");
  }

  Try<bool> stillActive = jemalloc::profilingActive();
  CHECK(stillActive.isError() || !stillActive.get());

  const string message =
    "Successfully stopped memory profiling run."
    " Use one of the provided URLs to download results."
    " Note that in order to generate graphs or symbolized profiles,"
    " jeprof must be installed on the host machine and generation of"
    " these files can take several minutes.";

  const string id = stringify(rawProfile->getId());

  JSON::Object result;
  result.values["id"] = id;
  result.values["message"] = message;

  result.values["url_raw_profile"] =
    "/" + this->self().id + "/download/raw?id=" + id;

  result.values["url_graph_profile"] =
    "/" + this->self().id + "/download/graph?id=" + id;

  result.values["url_symbolized_profile"] =
    "/" + this->self().id + "/download/text?id=" + id;

  return http::OK(result);
}


Future<http::Response> MemoryProfiler::downloadRawProfile(