Method ReloadMonitor

be/src/util/openssl-util.cc:350–396

}

void AuthenticationHashFromFile::ReloadMonitor(int fd, int wd) {
  LOG(INFO) << "Started reload thread for authentication key at " << path_;
  char buf[sizeof(struct inotify_event) + PATH_MAX + 1]
      __attribute__((aligned(__alignof__(struct inotify_event))));
  while (true) {
    fd_set readfds;
    FD_ZERO(&readfds);
    FD_SET(fd, &readfds);
    FD_SET(stop_pipe_read_fd_, &readfds);
    int maxfd = std::max(fd, stop_pipe_read_fd_) + 1;
    int ret = select(maxfd, &readfds, nullptr, nullptr, nullptr);
    if (ret < 0) {
      if (errno == EINTR) continue;
      LOG(FATAL) << "select() failed in reload thread for authentication key at "
                 << path_ << ": " << strerror(errno);
    }
    if (FD_ISSET(stop_pipe_read_fd_, &readfds)) {
      // Stop signal received.
      LOG(INFO) << "Stopping reload thread for authentication key at " << path_;
      break;
    }

    if (FD_ISSET(fd, &readfds)) {
      ssize_t len = read(fd, buf, sizeof(buf));
      if (len > 0) {
        // Reload key on any event.
        int64_t start = MonotonicSeconds();
        Status stat;
        while (!(stat = LoadKey()).ok()) {
          if (FLAGS_hash_reload_grace_period_s >= 0 &&
              MonotonicSeconds() >= start + FLAGS_hash_reload_grace_period_s) {
            LOG(FATAL) << "Authentication key reload failed for more than "
                       << FLAGS_hash_reload_grace_period_s
                       << " seconds; terminating Impala. Last error: " << stat;
          }
          LOG(ERROR) << stat;
          SleepForMs(1000);
        }
      } else if (len < 0 && errno != EAGAIN) {
        LOG(FATAL) << "Failed to read inotify event: " << strerror(errno);
      }
    }
  }
  inotify_rm_watch(fd, wd);
  close(stop_pipe_read_fd_);
  close(fd);
}

int GetKeyLenForMode(AES_CIPHER_MODE m) {
  switch (m) {