x

bazel/experiments.bzl

@@ -83,6 +83,10 @@ EXPERIMENTS = {
             "core_end2end_test": [
                 "event_engine_client",
                 "event_engine_listener",
+                "work_serializer_dispatch",
+            ],
+            "cpp_end2end_test": [
+                "work_serializer_dispatch",
             ],
             "cpp_lb_end2end_test": [
                 "pick_first_new",
@@ -95,12 +99,14 @@ EXPERIMENTS = {
             ],
             "lb_unit_test": [
                 "pick_first_new",
+                "work_serializer_dispatch",
             ],
             "resolver_component_tests_runner_invoker": [
                 "event_engine_dns",
             ],
             "xds_end2end_test": [
                 "pick_first_new",
+                "work_serializer_dispatch",
             ],
         },
     },
@@ -128,14 +134,22 @@ EXPERIMENTS = {
             ],
         },
         "on": {
+            "core_end2end_test": [
+                "work_serializer_dispatch",
+            ],
+            "cpp_end2end_test": [
+                "work_serializer_dispatch",
+            ],
             "cpp_lb_end2end_test": [
                 "pick_first_new",
             ],
             "lb_unit_test": [
                 "pick_first_new",
+                "work_serializer_dispatch",
             ],
             "xds_end2end_test": [
                 "pick_first_new",
+                "work_serializer_dispatch",
             ],
         },
     },

src/core/lib/experiments/experiments.cc

@@ -188,7 +188,7 @@ const ExperimentMetadata g_experiment_metadata[] = {
      additional_constraints_unconstrained_max_quota_buffer_size, nullptr, 0,
      false, true},
     {"work_serializer_dispatch", description_work_serializer_dispatch,
-     additional_constraints_work_serializer_dispatch, nullptr, 0, false, true},
+     additional_constraints_work_serializer_dispatch, nullptr, 0, true, true},
 };
 
 }  // namespace grpc_core
@@ -360,7 +360,7 @@ const ExperimentMetadata g_experiment_metadata[] = {
      additional_constraints_unconstrained_max_quota_buffer_size, nullptr, 0,
      false, true},
     {"work_serializer_dispatch", description_work_serializer_dispatch,
-     additional_constraints_work_serializer_dispatch, nullptr, 0, false, true},
+     additional_constraints_work_serializer_dispatch, nullptr, 0, true, true},
 };
 
 }  // namespace grpc_core

src/core/lib/experiments/experiments.h

@@ -89,7 +89,8 @@ inline bool IsTimeCachingInPartyEnabled() { return true; }
 #define GRPC_EXPERIMENT_IS_INCLUDED_TRACE_RECORD_CALLOPS
 inline bool IsTraceRecordCallopsEnabled() { return true; }
 inline bool IsUnconstrainedMaxQuotaBufferSizeEnabled() { return false; }
-inline bool IsWorkSerializerDispatchEnabled() { return false; }
+#define GRPC_EXPERIMENT_IS_INCLUDED_WORK_SERIALIZER_DISPATCH
+inline bool IsWorkSerializerDispatchEnabled() { return true; }
 
 #elif defined(GPR_WINDOWS)
 #define GRPC_EXPERIMENT_IS_INCLUDED_CALL_TRACER_IN_TRANSPORT
@@ -127,7 +128,8 @@ inline bool IsTimeCachingInPartyEnabled() { return true; }
 #define GRPC_EXPERIMENT_IS_INCLUDED_TRACE_RECORD_CALLOPS
 inline bool IsTraceRecordCallopsEnabled() { return true; }
 inline bool IsUnconstrainedMaxQuotaBufferSizeEnabled() { return false; }
-inline bool IsWorkSerializerDispatchEnabled() { return false; }
+#define GRPC_EXPERIMENT_IS_INCLUDED_WORK_SERIALIZER_DISPATCH
+inline bool IsWorkSerializerDispatchEnabled() { return true; }
 
 #else
 #define GRPC_EXPERIMENT_IS_INCLUDED_CALL_TRACER_IN_TRANSPORT

src/core/lib/experiments/rollouts.yaml

@@ -111,9 +111,4 @@
 - name: work_serializer_clears_time_cache
   default: true
 - name: work_serializer_dispatch
-  default:
-    # TODO(ysseung): Not fully tested.
-    ios: broken
-    posix: true
-    # TODO(ysseung): Test flakes not fully resolved.
-    windows: broken
+  default: true