liburing: Fix/allow configurable disable (#39695)

Signed-off-by: Ryan Northey <ryan@synca.io>

Author: phlax

bazel/BUILD

@@ -1058,3 +1058,18 @@ cc_library(
         "//conditions:default": ["//bazel/foreign_cc:gperftools"],
     }),
 )
+
+bool_flag(
+    name = "enable_liburing",
+    build_setting_default = True,
+)
+
+config_setting(
+    name = "liburing_enabled",
+    constraint_values = [
+        "@platforms//os:linux",
+    ],
+    flag_values = {
+        ":enable_liburing": "True",
+    },
+)

source/common/io/BUILD

@@ -11,27 +11,33 @@ envoy_package()
 envoy_cc_library(
     name = "io_uring_impl_lib",
     srcs = select({
-        "//bazel:linux": ["io_uring_impl.cc"],
+        "//bazel:liburing_enabled": ["io_uring_impl.cc"],
+        "//conditions:default": [],
+    }),
+    hdrs = select({
+        "//bazel:liburing_enabled": ["io_uring_impl.h"],
         "//conditions:default": [],
     }),
-    hdrs = [
-        "io_uring_impl.h",
-    ],
     tags = ["nocompdb"],
     deps = [
-        "//bazel/foreign_cc:liburing_linux",
         "//envoy/common/io:io_uring_interface",
         "//envoy/thread_local:thread_local_interface",
-    ],
+    ] + select({
+        "//bazel:liburing_enabled": ["//bazel/foreign_cc:liburing_linux"],
+        "//conditions:default": [],
+    }),
 )
 
 envoy_cc_library(
     name = "io_uring_worker_lib",
     srcs = select({
-        "//bazel:linux": ["io_uring_worker_impl.cc"],
+        "//bazel:liburing_enabled": ["io_uring_worker_impl.cc"],
+        "//conditions:default": [],
+    }),
+    hdrs = select({
+        "//bazel:liburing_enabled": ["io_uring_worker_impl.h"],
         "//conditions:default": [],
     }),
-    hdrs = ["io_uring_worker_impl.h"],
     deps = [
         ":io_uring_impl_lib",
         "//envoy/common/io:io_uring_interface",
@@ -43,8 +49,14 @@ envoy_cc_library(
 
 envoy_cc_library(
     name = "io_uring_worker_factory_impl_lib",
-    srcs = ["io_uring_worker_factory_impl.cc"],
-    hdrs = ["io_uring_worker_factory_impl.h"],
+    srcs = select({
+        "//bazel:liburing_enabled": ["io_uring_worker_factory_impl.cc"],
+        "//conditions:default": [],
+    }),
+    hdrs = select({
+        "//bazel:liburing_enabled": ["io_uring_worker_factory_impl.h"],
+        "//conditions:default": [],
+    }),
     deps = [
         ":io_uring_worker_lib",
         "//envoy/common/io:io_uring_interface",

source/common/network/BUILD

@@ -249,7 +249,7 @@ envoy_cc_library(
         "win32_socket_handle_impl.cc",
     ] + select({
         "//bazel:android": [],
-        "//bazel:linux": [
+        "//bazel:liburing_enabled": [
             "io_uring_socket_handle_impl.cc",
         ],
         "//conditions:default": [],
@@ -261,11 +261,15 @@ envoy_cc_library(
         "win32_socket_handle_impl.h",
     ] + select({
         "//bazel:android": [],
-        "//bazel:linux": [
+        "//bazel:liburing_enabled": [
             "io_uring_socket_handle_impl.h",
         ],
         "//conditions:default": [],
     }),
+    defines = select({
+        "//bazel:liburing_enabled": ["ENVOY_ENABLE_IO_URING=1"],
+        "//conditions:default": [],
+    }),
     deps = [
         ":address_lib",
         ":io_socket_error_lib",
@@ -281,7 +285,7 @@ envoy_cc_library(
         "@envoy_api//envoy/extensions/network/socket_interface/v3:pkg_cc_proto",
     ] + select({
         "//bazel:android": [],
-        "//bazel:linux": [
+        "//bazel:liburing_enabled": [
             "//source/common/io:io_uring_impl_lib",
             "//source/common/io:io_uring_worker_factory_impl_lib",
             "//source/common/io:io_uring_worker_lib",

source/common/network/socket_interface_impl.cc

@@ -11,7 +11,7 @@
 #include "source/common/network/io_socket_handle_impl.h"
 #include "source/common/network/win32_socket_handle_impl.h"
 
-#if defined(__linux__) && !defined(__ANDROID_API__)
+#if defined(__linux__) && !defined(__ANDROID_API__) && defined(ENVOY_ENABLE_IO_URING)
 #include "source/common/io/io_uring_worker_factory_impl.h"
 #include "source/common/io/io_uring_impl.h"
 #include "source/common/network/io_uring_socket_handle_impl.h"
@@ -40,7 +40,7 @@ IoHandlePtr SocketInterfaceImpl::makePlatformSpecificSocket(
   if constexpr (Event::PlatformDefaultTriggerType == Event::FileTriggerType::EmulatedEdge) {
     return std::make_unique<Win32SocketHandleImpl>(socket_fd, socket_v6only, domain);
   }
-#if defined(__linux__) && !defined(__ANDROID_API__)
+#if defined(__linux__) && !defined(__ANDROID_API__) && defined(ENVOY_ENABLE_IO_URING)
   // Only create IoUringSocketHandleImpl when the IoUringWorkerFactory has been created and it has
   // been registered in the TLS, initialized. There are cases that test may create threads before
   // IoUringWorkerFactory has been added to the TLS and got initialized.
@@ -167,7 +167,7 @@ bool SocketInterfaceImpl::ipFamilySupported(int domain) {
 Server::BootstrapExtensionPtr SocketInterfaceImpl::createBootstrapExtension(
     [[maybe_unused]] const Protobuf::Message& config,
     [[maybe_unused]] Server::Configuration::ServerFactoryContext& context) {
-#if defined(__linux__) && !defined(__ANDROID_API__)
+#if defined(__linux__) && !defined(__ANDROID_API__) && defined(ENVOY_ENABLE_IO_URING)
   const auto& message = MessageUtil::downcastAndValidate<
       const envoy::extensions::network::socket_interface::v3::DefaultSocketInterface&>(
       config, context.messageValidationVisitor());