end2end tests: fix test service impl to apply test slowdown factor (#30750)

* end2end tests: fix test service impl to apply test slowdown factor

* fix build

test/cpp/end2end/BUILD

@@ -32,6 +32,7 @@ grpc_cc_library(
     ],
     deps = [
         "//src/proto/grpc/testing:echo_proto",
+        "//test/core/util:grpc_test_util",
         "//test/cpp/util:test_util",
     ],
 )

test/cpp/end2end/test_service_impl.cc

@@ -163,7 +163,8 @@ ServerUnaryReactor* CallbackTestServiceImpl::Echo(
         // Set an alarm for that much time
         alarm_.Set(
             gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC),
-                         gpr_time_from_micros(req_->param().server_sleep_us(),
+                         gpr_time_from_micros(req_->param().server_sleep_us() *
+                                                  grpc_test_slowdown_factor(),
                                               GPR_TIMESPAN)),
             [this](bool ok) { NonDelayed(ok); });
         return;
@@ -250,7 +251,8 @@ ServerUnaryReactor* CallbackTestServiceImpl::Echo(
       } else if (req_->has_param() && req_->param().server_cancel_after_us()) {
         alarm_.Set(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME),
                                 gpr_time_from_micros(
-                                    req_->param().server_cancel_after_us(),
+                                    req_->param().server_cancel_after_us() *
+                                        grpc_test_slowdown_factor(),
                                     GPR_TIMESPAN)),
                    [this](bool) { Finish(Status::CANCELLED); });
         return;

test/cpp/end2end/test_service_impl.h

@@ -34,6 +34,7 @@
 #include <grpcpp/server_context.h>
 
 #include "src/proto/grpc/testing/echo.grpc.pb.h"
+#include "test/core/util/test_config.h"
 #include "test/cpp/util/string_ref_helper.h"
 
 namespace grpc {
@@ -131,9 +132,10 @@ class TestMultipleServiceImpl : public RpcService {
 
     // A bit of sleep to make sure that short deadline tests fail
     if (request->has_param() && request->param().server_sleep_us() > 0) {
-      gpr_sleep_until(
+      gpr_sleep_until(gpr_time_add(
-          gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC),
+          gpr_now(GPR_CLOCK_MONOTONIC),
-                       gpr_time_from_micros(request->param().server_sleep_us(),
+          gpr_time_from_micros(
+              request->param().server_sleep_us() * grpc_test_slowdown_factor(),
               GPR_TIMESPAN)));
     }
 
@@ -176,7 +178,8 @@ class TestMultipleServiceImpl : public RpcService {
       while (!context->IsCancelled()) {
         gpr_sleep_until(gpr_time_add(
             gpr_now(GPR_CLOCK_REALTIME),
-            gpr_time_from_micros(request->param().client_cancel_after_us(),
+            gpr_time_from_micros(request->param().client_cancel_after_us() *
+                                     grpc_test_slowdown_factor(),
                                  GPR_TIMESPAN)));
       }
       {
@@ -188,7 +191,8 @@ class TestMultipleServiceImpl : public RpcService {
                request->param().server_cancel_after_us()) {
       gpr_sleep_until(gpr_time_add(
           gpr_now(GPR_CLOCK_REALTIME),
-          gpr_time_from_micros(request->param().server_cancel_after_us(),
+          gpr_time_from_micros(request->param().server_cancel_after_us() *
+                                   grpc_test_slowdown_factor(),
                                GPR_TIMESPAN)));
       return Status::CANCELLED;
     } else if (!request->has_param() ||