-
Show log
Commit
-
Hash : c0386ad4
Author :
Date : 2024-04-05T11:56:17
AsyncWorkerPool releases shared_ptr<Closure> before notifying Parallel compile (MainLinkLoadTask, Program::LinkingState) is dependent on destructor getting called before the event is notified Repro: https://crrev.com/c/5425924 More details on the parallel compile case, provided by syoussefi@: """ A race condition caused the worker pool to sometimes be destroyed from a worker thread instead of the main thread. The race condition triggered in the following scenario: - The MainLinkLoadTask holds on to the worker pool - This is necessary for the main task to spawn further tasks asynchronously - The reference to the worker pool in MainLinkLoadTask is released by its destructor - The worker thread dequeues a task (i.e. MainLinkLoadTask) to execute and holds a reference to it. - Once the task is run by the worker thread, the worker thread signals its completion - (1) At this point, the scope holding the reference to the task closes and the task is released. However, this is done after signaling the task's completion. - On program destruction, the program ensures that all its tasks are complete - This uses the signal coming from the worker thread - (2) On display destruction, the worker pool is destroyed (by dereferencing it through the shared_ptr) - The destructor of the worker pool waits for the worker thread, with the expectation that this wait is done in the main thread. The race condition led to the assert firing when (2) was done before (1). Because the task is already signaled complete, the main thread considers it done and goes ahead with the destruction of the display. However, until the scope of the worker thread closes, the task itself is still not destroyed. Since the task is holding a reference to the worker pool, that prevents the worker pool from getting destroyed too. Once the display is destroyed, the worker thread closes its scope, causing the task to be destroyed. In turn, this leads to the worker pool itself to be destroyed. On destruction, the worker pool would wait for the worker thread to end which is a deadlock. Fortunately, this was caught earlier with an ASSERT that wanted to ensure destruction happens on the main thread. In this change, the worker thread ensures it releases the task before signalling it complete, avoiding this issue. Other possible solutions would have been: - Release the worker pool from MainLinkLoadTask as soon as the subtasks are scheduled - Explicitly call a "destroy" method on the pool, instead of relying on the destructor to clean up. """ Bug: angleproject:8661 Change-Id: I37c9bc8e8f05bce4062d794df449cc3d2c80a093 Reviewed-on: https://chromium-review.googlesource.com/c/angle/angle/+/5428806 Reviewed-by: Shahbaz Youssefi <syoussefi@chromium.org> Commit-Queue: Roman Lavrov <romanl@google.com>
-
Files
- BinaryStream.h
- BinaryStream_unittest.cpp
- CircularBuffer.h
- CircularBuffer_unittest.cpp
- Color.h
- Color.inc
- CompiledShaderState.cpp
- CompiledShaderState.h
- FastVector.h
- FastVector_unittest.cpp
- FixedQueue.h
- FixedQueue_unittest.cpp
- FixedVector.h
- FixedVector_unittest.cpp
- Float16ToFloat32.cpp
- Float16ToFloat32.py
- MemoryBuffer.cpp
- MemoryBuffer.h
- Optional.h
- Optional_unittest.cpp
- PackedCLEnums_autogen.cpp
- PackedCLEnums_autogen.h
- PackedEGLEnums_autogen.cpp
- PackedEGLEnums_autogen.h
- PackedEnums.cpp
- PackedEnums.h
- PackedGLEnums_autogen.cpp
- PackedGLEnums_autogen.h
- PoolAlloc.cpp
- PoolAlloc.h
- PoolAlloc_unittest.cpp
- RingBufferAllocator.cpp
- RingBufferAllocator.h
- Spinlock.h
- SynchronizedValue.h
- WorkerThread.cpp
- WorkerThread.h
- WorkerThread_unittest.cpp
- aligned_memory.cpp
- aligned_memory.h
- aligned_memory_unittest.cpp
- android_util.cpp
- android_util.h
- angle_version.h
- angle_version_info.cpp
- angle_version_info.h
- angleutils.cpp
- angleutils.h
- angleutils_unittest.cpp
- apple/
- apple_platform_utils.h
- apple_platform_utils.mm
- backtrace_utils.h
- backtrace_utils_android.cpp
- backtrace_utils_noop.cpp
- base/
- bitset_utils.h
- bitset_utils_unittest.cpp
- debug.cpp
- debug.h
- entry_points_enum_autogen.cpp
- entry_points_enum_autogen.h
- event_tracer.cpp
- event_tracer.h
- frame_capture_utils.cpp
- frame_capture_utils.h
- frame_capture_utils_autogen.cpp
- frame_capture_utils_autogen.h
- fuchsia_egl/
- gen_packed_gl_enums.py
- gen_uniform_type_table.py
- gl/
- gl_enum_utils.cpp
- gl_enum_utils.h
- gl_enum_utils_autogen.cpp
- gl_enum_utils_autogen.h
- hash_utils.h
- hash_utils_unittest.cpp
- linux/
- mathutil.cpp
- mathutil.h
- mathutil_unittest.cpp
- matrix_utils.cpp
- matrix_utils.h
- matrix_utils_unittest.cpp
- packed_cl_enums.json
- packed_egl_enums.json
- packed_gl_enums.json
- platform.h
- platform_helpers.cpp
- platform_helpers.h
- serializer/
- spirv/
- string_utils.cpp
- string_utils.h
- string_utils_unittest.cpp
- system_utils.cpp
- system_utils.h
- system_utils_apple.cpp
- system_utils_ios.cpp
- system_utils_ios.mm
- system_utils_linux.cpp
- system_utils_mac.cpp
- system_utils_posix.cpp
- system_utils_unittest.cpp
- system_utils_win.cpp
- system_utils_win32.cpp
- system_utils_winuwp.cpp
- third_party/
- tls.cpp
- tls.h
- uniform_type_info_autogen.cpp
- utilities.cpp
- utilities.h
- utilities_unittest.cpp
- vector_utils.h
- vector_utils_unittest.cpp
- vulkan/
