diff --git a/worker/src/DepLibUring.cpp b/worker/src/DepLibUring.cpp index d2a9ef533d..808391d83e 100644 --- a/worker/src/DepLibUring.cpp +++ b/worker/src/DepLibUring.cpp @@ -186,7 +186,6 @@ void DepLibUring::StartPollingCQEs() MS_ASSERT(DepLibUring::enabled, "DepLibUring::liburing not supported"); - DepLibUring::liburing->StartPollingCQEs(); } diff --git a/worker/src/Worker.cpp b/worker/src/Worker.cpp index a3372dfdfd..01c4d90429 100644 --- a/worker/src/Worker.cpp +++ b/worker/src/Worker.cpp @@ -156,7 +156,7 @@ flatbuffers::Offset Worker::FillBuffer( channelMessageHandlers #ifdef MS_LIBURING_SUPPORTED , - DepLibUring::FillBuffer(builder) + DepLibUring::IsEnabled() ? DepLibUring::FillBuffer(builder) : nullptr #endif ); }