Method CompleteStoreTask

be/src/runtime/io/data-cache.cc:1477–1482

}

void DataCache::CompleteStoreTask(const StoreTask& task) {
  current_buffer_size_.Add(-task.buffer_len());
  DCHECK_GE(current_buffer_size_.Load(), 0);
  ImpaladMetrics::IO_MGR_REMOTE_DATA_CACHE_ASYNC_WRITES_OUTSTANDING_BYTES->SetValue(
      current_buffer_size_.Load());
}

void DataCache::HandleStoreTask(uint32_t thread_id, const StoreTaskHandle& task) {
    StoreInternal(task->key(), task->buffer(), task->buffer_len());