Function CopyFile

cpp/src/arrow/filesystem/azurefs.cc:3253–3290

  }

  Status CopyFile(const AzureLocation& src, const AzureLocation& dest) {
    RETURN_NOT_OK(ValidateFileLocation(src));
    RETURN_NOT_OK(ValidateFileLocation(dest));
    if (src == dest) {
      return Status::OK();
    }
    auto src_url = GetBlobClient(src.container, src.path).GetUrl();
    auto dest_blob_client = GetBlobClient(dest.container, dest.path);
    if (!dest.path.empty()) {
      auto dest_parent = dest.parent();
      if (!dest_parent.path.empty()) {
        auto dest_container_client = GetBlobContainerClient(dest_parent.container);
        ARROW_ASSIGN_OR_RAISE(auto info, GetFileInfo(dest_container_client, dest_parent));
        if (info.type() == FileType::File) {
          return NotADir(dest_parent);
        }
      }
    }
    try {
      // We use StartCopyFromUri instead of CopyFromUri because it supports blobs larger
      // than 256 MiB and it doesn't require generating a SAS token to authenticate
      // reading a source blob in the same storage account.
      auto copy_operation = dest_blob_client.StartCopyFromUri(src_url);
      // For large blobs, the copy operation may be slow so we need to poll until it
      // completes. We use a polling interval of 1 second.
      copy_operation.PollUntilDone(std::chrono::milliseconds(1000));
    } catch (const Storage::StorageException& exception) {
      // StartCopyFromUri failed or a GetProperties call inside PollUntilDone failed.
      return ExceptionToStatus(
          exception, "Failed to start blob copy or poll status of ongoing copy. (",
          src_url, " -> ", dest_blob_client.GetUrl(), ")");
    } catch (const Azure::Core::RequestFailedException& exception) {
      // A GetProperties call inside PollUntilDone returned a failed CopyStatus.
      return ExceptionToStatus(exception, "Failed to copy blob. (", src_url, " -> ",
                               dest_blob_client.GetUrl(), ")");
    }
    return Status::OK();
  }
};

std::atomic<LeaseGuard::SteadyClock::time_point> LeaseGuard::latest_known_expiry_time_ =