YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// Licensed to the Apache Software Foundation (ASF) under one

// or more contributor license agreements.  See the NOTICE file

// distributed with this work for additional information

// regarding copyright ownership.  The ASF licenses this file

// to you under the Apache License, Version 2.0 (the

// "License"); you may not use this file except in compliance

// with the License.  You may obtain a copy of the License at

//

//   http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing,

// software distributed under the License is distributed on an

// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

// KIND, either express or implied.  See the License for the

// specific language governing permissions and limitations

// under the License.

//

// The following only applies to changes made to this file as part of YugaByte development.

//

// Portions Copyright (c) YugaByte, Inc.

//

// Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except

// in compliance with the License.  You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing, software distributed under the License

// is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express

// or implied.  See the License for the specific language governing permissions and limitations

// under the License.

//

#include "yb/util/pstack_watcher.h"

#include <stdio.h>

#include <sys/types.h>

#include <functional>

#include <memory>

#include <string>

#include <vector>

#include "yb/util/env.h"

#include "yb/util/errno.h"

#include "yb/util/status.h"

#include "yb/util/status_log.h"

#include "yb/util/subprocess.h"

#include "yb/util/thread.h"

namespace yb {

using std::shared_ptr;

using std::string;

using std::vector;

using strings::Substitute;

PstackWatcher::PstackWatcher(MonoDelta timeout)

    : timeout_(std::move(timeout)), running_(true), cond_(&lock_) {

  CHECK_OK(Thread::Create(

      "pstack_watcher", "pstack_watcher", std::bind(&PstackWatcher::Run, this), &thread_));

}

PstackWatcher::~PstackWatcher() {

  Shutdown();

}

void PstackWatcher::Shutdown() {

  {

    MutexLock guard(lock_);

    running_ = false;

    cond_.Broadcast();

  }

  if (thread_) {

    CHECK_OK(ThreadJoiner(thread_.get()).Join());

    thread_.reset();

  }

}

bool PstackWatcher::IsRunning() const {

  MutexLock guard(lock_);

  return running_;

}

void PstackWatcher::Wait() const {

  MutexLock lock(lock_);

  while (running_) {

    cond_.Wait();

  }

}

void PstackWatcher::Run() {

  MutexLock guard(lock_);

  if (!running_) 
return1
;

  cond_.TimedWait(timeout_);

  if (!running_) 
return1
;

  WARN_NOT_OK(DumpStacks(DUMP_FULL), "Unable to print pstack from watcher");

  running_ = false;

  cond_.Broadcast();

}

Status PstackWatcher::HasProgram(const char* progname) {

  string which("which");

  vector<string> argv;

  argv.push_back(which);

  argv.push_back(progname);

  Subprocess proc(which, argv);

  proc.DisableStderr();

  proc.DisableStdout();

  RETURN_NOT_OK_PREPEND(proc.Start(),

      Substitute("HasProgram($0): error running 'which'", progname));

  int wait_status = 0;

  RETURN_NOT_OK(proc.Wait(&wait_status));

  if ((WIFEXITED(wait_status)) && (0 == WEXITSTATUS(wait_status))) {

    return Status::OK();

  }

  return STATUS(NotFound, Substitute("can't find $0: exited?=$1, status=$2",

                                     progname,

                                     static_cast<bool>(WIFEXITED(wait_status)),

                                     WEXITSTATUS(wait_status)));

}

Status PstackWatcher::DumpStacks(int flags) {

  return DumpPidStacks(getpid(), flags);

}

Status PstackWatcher::DumpPidStacks(pid_t pid, int flags) {

  // Prefer GDB if available; it gives us line numbers and thread names.

  if (HasProgram("gdb").ok()) {

    return RunGdbStackDump(pid, flags);

  }

  // Otherwise, try to use pstack or gstack.

  const char *progname = nullptr;

  if (HasProgram("pstack").ok()) {

    progname = "pstack";

  } else if (HasProgram("gstack").ok()) {

    progname = "gstack";

  }

  if (!progname) {

    return STATUS(ServiceUnavailable, "Neither gdb, pstack, nor gstack appears to be installed.");

  }

  return RunPstack(progname, pid);

}

Status PstackWatcher::RunGdbStackDump(pid_t pid, int flags) {

  // Command:

  // gdb -quiet -batch -nx -ex "set print pretty on" -ex "info threads" -ex "thread apply all bt"

  //     <executable_path> <pid>>

  string prog("gdb");

  vector<string> argv;

  argv.push_back(prog);

  argv.push_back("-quiet");

  argv.push_back("-batch");

  argv.push_back("-nx");

  argv.push_back("-ex");

  argv.push_back("set print pretty on");

  argv.push_back("-ex");

  argv.push_back("info threads");

  argv.push_back("-ex");

  argv.push_back("thread apply all bt");

  if (flags & DUMP_FULL) {

    argv.push_back("-ex");

    argv.push_back("thread apply all bt full");

  }

  string executable;

  Env* env = Env::Default();

  RETURN_NOT_OK(env->GetExecutablePath(&executable));

  argv.push_back(executable);

  argv.push_back(Substitute("$0", pid));

  return RunStackDump(prog, argv);

}

Status PstackWatcher::RunPstack(const std::string& progname, pid_t pid) {

  string prog(progname);

  string pid_string(Substitute("$0", pid));

  vector<string> argv;

  argv.push_back(prog);

  argv.push_back(pid_string);

  return RunStackDump(prog, argv);

}

Status PstackWatcher::RunStackDump(const string& prog, const vector<string>& argv) {

  printf("************************ BEGIN STACKS **************************\n");

  if (fflush(stdout) == EOF) {

    return STATUS(IOError, "Unable to flush stdout", Errno(errno));

  }

  Subprocess pstack_proc(prog, argv);

  RETURN_NOT_OK_PREPEND(pstack_proc.Start(), "RunStackDump proc.Start() failed");

  if (::close(pstack_proc.ReleaseChildStdinFd()) == -1) {

    return STATUS(IOError, "Unable to close child stdin", Errno(errno));

  }

  int ret;

  RETURN_NOT_OK_PREPEND(pstack_proc.Wait(&ret), "RunStackDump proc.Wait() failed");

  if (ret == -1) {

    return STATUS(RuntimeError, "RunStackDump proc.Wait() error", Errno(errno));

  }

  printf("************************* END STACKS ***************************\n");

  if (fflush(stdout) == EOF) {

    return STATUS(IOError, "Unable to flush stdout", Errno(errno));

  }

  return Status::OK();

}

} // namespace yb