Method sync

Src/Base/AMReX_GpuDevice.cpp:159–194

}

void
StreamManager::sync () {
    decltype(m_free_wait_list) new_empty_wait_list{};

    {
        // lock mutex before accessing and modifying member variables
        std::lock_guard<std::mutex> lock(m_mutex);
        m_free_wait_list.swap(new_empty_wait_list);
    }
    // unlock mutex before stream sync and memory free
    // to avoid deadlocks from the CArena mutex

    // actual stream sync
#ifdef AMREX_USE_SYCL
    try {
        m_stream.queue->wait_and_throw();
    } catch (sycl::exception const& ex) {
        for (auto [arena, mem] : new_empty_wait_list) {
            arena->free(mem);
        }
        new_empty_wait_list.clear();
        amrex::Abort(std::string("streamSynchronize: ")+ex.what()+"!!!!!");
    }
#else
    AMREX_HIP_OR_CUDA( AMREX_HIP_SAFE_CALL(hipStreamSynchronize(m_stream));,
                       AMREX_CUDA_SAFE_CALL(cudaStreamSynchronize(m_stream)); )
#endif

    // synconizing the stream may have taken a long time and
    // there may be new kernels launched already, so we free memory
    // according to the state from before the stream was synced

    for (auto [arena, mem] : new_empty_wait_list) {
        arena->free(mem);
    }
}

void
StreamManager::free_async (Arena* arena, void* mem) {