|  | // Copyright 2015 The Bazel Authors. All rights reserved. | 
|  | // | 
|  | // 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 <errno.h>  // errno, ENAMETOOLONG | 
|  | #include <limits.h> | 
|  | #include <pwd.h> | 
|  | #include <signal.h> | 
|  | #include <spawn.h> | 
|  | #include <string.h>  // strerror | 
|  | #include <sys/mount.h> | 
|  | #include <sys/param.h> | 
|  | #include <sys/queue.h> | 
|  | #include <sys/socket.h> | 
|  | #include <sys/sysctl.h> | 
|  | #include <sys/types.h> | 
|  | #include <sys/un.h> | 
|  | #include <unistd.h> | 
|  | #include <libprocstat.h>  // must be included after <sys/...> headers | 
|  |  | 
|  | #include "src/main/cpp/blaze_util.h" | 
|  | #include "src/main/cpp/blaze_util_platform.h" | 
|  | #include "src/main/cpp/util/errors.h" | 
|  | #include "src/main/cpp/util/exit_code.h" | 
|  | #include "src/main/cpp/util/file.h" | 
|  | #include "src/main/cpp/util/logging.h" | 
|  | #include "src/main/cpp/util/path.h" | 
|  | #include "src/main/cpp/util/port.h" | 
|  | #include "src/main/cpp/util/strings.h" | 
|  |  | 
|  | namespace blaze { | 
|  |  | 
|  | using blaze_util::GetLastErrorString; | 
|  | using std::string; | 
|  |  | 
|  | string GetOutputRoot() { | 
|  | char buf[2048]; | 
|  | struct passwd pwbuf; | 
|  | struct passwd *pw = NULL; | 
|  | int uid = getuid(); | 
|  | int r = getpwuid_r(uid, &pwbuf, buf, 2048, &pw); | 
|  | if (r != -1 && pw != NULL) { | 
|  | return blaze_util::JoinPath(pw->pw_dir, ".cache/bazel"); | 
|  | } else { | 
|  | return "/tmp"; | 
|  | } | 
|  | } | 
|  |  | 
|  | void WarnFilesystemType(const string &output_base) { | 
|  | struct statfs buf = {}; | 
|  | if (statfs(output_base.c_str(), &buf) < 0) { | 
|  | BAZEL_LOG(WARNING) << "couldn't get file system type information for '" | 
|  | << output_base << "': " << strerror(errno); | 
|  | return; | 
|  | } | 
|  |  | 
|  | if (strcmp(buf.f_fstypename, "nfs") == 0) { | 
|  | BAZEL_LOG(WARNING) << "Output base '" << output_base | 
|  | << "' is on NFS. This may lead to surprising failures " | 
|  | "and undetermined behavior."; | 
|  | } | 
|  | } | 
|  |  | 
|  | string GetSelfPath() { | 
|  | char buffer[PATH_MAX] = {}; | 
|  | auto pid = getpid(); | 
|  | if (kill(pid, 0) < 0) return ""; | 
|  | auto procstat = procstat_open_sysctl(); | 
|  | unsigned int n; | 
|  | auto p = procstat_getprocs(procstat, KERN_PROC_PID, pid, &n); | 
|  | if (p) { | 
|  | if (n != 1) { | 
|  | BAZEL_DIE(blaze_exit_code::INTERNAL_ERROR) | 
|  | << "expected exactly one process from procstat_getprocs, got " << n | 
|  | << ": " << GetLastErrorString(); | 
|  | } | 
|  | auto r = procstat_getpathname(procstat, p, buffer, PATH_MAX); | 
|  | if (r != 0) { | 
|  | BAZEL_DIE(blaze_exit_code::INTERNAL_ERROR) | 
|  | << "procstat_getpathname failed: " << GetLastErrorString(); | 
|  | } | 
|  | procstat_freeprocs(procstat, p); | 
|  | } | 
|  | procstat_close(procstat); | 
|  | return string(buffer); | 
|  | } | 
|  |  | 
|  | uint64_t GetMillisecondsMonotonic() { | 
|  | struct timespec ts = {}; | 
|  | clock_gettime(CLOCK_MONOTONIC, &ts); | 
|  | return ts.tv_sec * 1000LL + (ts.tv_nsec / 1000000LL); | 
|  | } | 
|  |  | 
|  | void SetScheduling(bool batch_cpu_scheduling, int io_nice_level) { | 
|  | // Stubbed out so we can compile for FreeBSD. | 
|  | } | 
|  |  | 
|  | string GetProcessCWD(int pid) { | 
|  | if (kill(pid, 0) < 0) return ""; | 
|  | auto procstat = procstat_open_sysctl(); | 
|  | unsigned int n; | 
|  | auto p = procstat_getprocs(procstat, KERN_PROC_PID, pid, &n); | 
|  | string cwd; | 
|  | if (p) { | 
|  | if (n != 1) { | 
|  | BAZEL_DIE(blaze_exit_code::INTERNAL_ERROR) | 
|  | << "expected exactly one process from procstat_getprocs, got " << n | 
|  | << ": " << GetLastErrorString(); | 
|  | } | 
|  | auto files = procstat_getfiles(procstat, p, false); | 
|  | filestat *entry; | 
|  | STAILQ_FOREACH(entry, files, next) { | 
|  | if (entry->fs_uflags & PS_FST_UFLAG_CDIR) { | 
|  | if (entry->fs_path) { | 
|  | cwd = entry->fs_path; | 
|  | } else { | 
|  | cwd = ""; | 
|  | } | 
|  | } | 
|  | } | 
|  | procstat_freefiles(procstat, files); | 
|  | procstat_freeprocs(procstat, p); | 
|  | } | 
|  | procstat_close(procstat); | 
|  | return cwd; | 
|  | } | 
|  |  | 
|  | bool IsSharedLibrary(const string &filename) { | 
|  | return blaze_util::ends_with(filename, ".so"); | 
|  | } | 
|  |  | 
|  | string GetSystemJavabase() { | 
|  | // if JAVA_HOME is defined, then use it as default. | 
|  | string javahome = GetPathEnv("JAVA_HOME"); | 
|  |  | 
|  | if (!javahome.empty()) { | 
|  | string javac = blaze_util::JoinPath(javahome, "bin/javac"); | 
|  | if (access(javac.c_str(), X_OK) == 0) { | 
|  | return javahome; | 
|  | } | 
|  | BAZEL_LOG(WARNING) | 
|  | << "Ignoring JAVA_HOME, because it must point to a JDK, not a JRE."; | 
|  | } | 
|  |  | 
|  | return "/usr/local/openjdk8"; | 
|  | } | 
|  |  | 
|  | int ConfigureDaemonProcess(posix_spawnattr_t *attrp, | 
|  | const StartupOptions *options) { | 
|  | // No interesting platform-specific details to configure on this platform. | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | void WriteSystemSpecificProcessIdentifier( | 
|  | const string& server_dir, pid_t server_pid) { | 
|  | } | 
|  |  | 
|  | bool VerifyServerProcess(int pid, const string &output_base) { | 
|  | // TODO(lberki): This only checks for the process's existence, not whether | 
|  | // its start time matches. Therefore this might accidentally kill an | 
|  | // unrelated process if the server died and the PID got reused. | 
|  | return killpg(pid, 0) == 0; | 
|  | } | 
|  |  | 
|  | // Not supported. | 
|  | void ExcludePathFromBackup(const string &path) { | 
|  | } | 
|  |  | 
|  | int32_t GetExplicitSystemLimit(const int resource) { | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | }  // namespace blaze |