Method Flush

cpp/src/arrow/filesystem/azurefs.cc:1183–1201

  }

  Status Flush() override {
    RETURN_NOT_OK(CheckClosed("flush"));
    if (!initialised_) {
      // If the stream has not been successfully initialized then there is nothing to
      // flush. This also avoids some unhandled errors when flushing in the destructor.
      return Status::OK();
    }

    Future<> pending_blocks_completed;
    {
      std::unique_lock<std::mutex> lock(upload_state_->mutex);
      pending_blocks_completed = upload_state_->pending_blocks_completed;
    }

    RETURN_NOT_OK(pending_blocks_completed.status());
    std::unique_lock<std::mutex> lock(upload_state_->mutex);
    return CommitBlockList(block_blob_client_, upload_state_->block_ids,
                           commit_block_list_options_);
  }

  Future<> FlushAsync() {
    RETURN_NOT_OK(CheckClosed("flush async"));