Method OpenHdfsFileWithTimeout

be/src/runtime/io/hdfs-monitored-ops.cc:83–96

}

Status HdfsMonitor::OpenHdfsFileWithTimeout(const hdfsFS& fs, const std::string* fname,
  int flags, uint64_t blocksize, hdfsFile* fid_out) {
  std::shared_ptr<OpenHdfsFileOp> op(new OpenHdfsFileOp(fs, fname, flags, blocksize));

  // Submit the operation to the synchronous thread pool. If this times out, it returns
  // an error status.
  Status status = hdfs_worker_pool_->SynchronousOffer(op,
      FLAGS_hdfs_operation_timeout_sec * MILLIS_PER_SEC);
  RETURN_IF_ERROR(status);

  // The operation didn't time out, and there wasn't an error. Get the handle.
  *fid_out = op->GetFileHandle();
  return Status::OK();
}

}