bug fix

3 files changed, 18 insertions, 12 deletions

diff --git a/test/core/end2end/tests/stream_compressed_payload.c b/test/core/end2end/tests/stream_compressed_payload.c
index e994ba836d..a686a566d7 100644
--- a/test/core/end2end/tests/stream_compressed_payload.c
+++ b/test/core/end2end/tests/stream_compressed_payload.c
@@ -560,7 +560,7 @@ static void test_invoke_request_with_compressed_payload(
       GRPC_STREAM_COMPRESS_GZIP, GRPC_STREAM_COMPRESS_GZIP,
       GRPC_STREAM_COMPRESS_GZIP, GRPC_STREAM_COMPRESS_GZIP, NULL,
       false, /* ignored */
-      GRPC_COMPRESS_LEVEL_NONE, false, false, GRPC_COMPRESS_NONE);
+      GRPC_STREAM_COMPRESS_LEVEL_NONE, false, false, GRPC_COMPRESS_NONE);
 }
 
 static void test_invoke_request_with_send_message_before_initial_metadata(
@@ -570,7 +570,7 @@ static void test_invoke_request_with_send_message_before_initial_metadata(
       0, GRPC_STREAM_COMPRESS_GZIP, GRPC_STREAM_COMPRESS_GZIP,
       GRPC_STREAM_COMPRESS_GZIP, GRPC_STREAM_COMPRESS_GZIP, NULL,
       false, /* ignored */
-      GRPC_COMPRESS_LEVEL_NONE, true, false, GRPC_COMPRESS_NONE);
+      GRPC_STREAM_COMPRESS_LEVEL_NONE, true, false, GRPC_COMPRESS_NONE);
 }
 
 static void test_invoke_request_with_server_level(
@@ -607,7 +607,8 @@ static void test_invoke_request_with_compressed_payload_md_override(
       GRPC_STREAM_COMPRESS_NONE, GRPC_STREAM_COMPRESS_NONE,
       GRPC_STREAM_COMPRESS_GZIP, GRPC_STREAM_COMPRESS_NONE,
       &gzip_compression_override, false,
-      /*ignored*/ GRPC_COMPRESS_LEVEL_NONE, false, false, GRPC_COMPRESS_NONE);
+      /*ignored*/ GRPC_STREAM_COMPRESS_LEVEL_NONE, false, false,
+      GRPC_COMPRESS_NONE);
 
   /* Channel default stream GZIP, call override to NONE (aka IDENTITY) */
   request_with_payload_template(
@@ -615,7 +616,8 @@ static void test_invoke_request_with_compressed_payload_md_override(
       GRPC_STREAM_COMPRESS_GZIP, GRPC_STREAM_COMPRESS_NONE,
       GRPC_STREAM_COMPRESS_NONE, GRPC_STREAM_COMPRESS_NONE,
       &identity_compression_override, false,
-      /*ignored*/ GRPC_COMPRESS_LEVEL_NONE, false, false, GRPC_COMPRESS_NONE);
+      /*ignored*/ GRPC_STREAM_COMPRESS_LEVEL_NONE, false, false,
+      GRPC_COMPRESS_NONE);
 }
 
 static void test_invoke_request_with_disabled_algorithm(
diff --git a/test/core/end2end/tests/stream_payload.c b/test/core/end2end/tests/stream_payload.c
index 3119f88a08..ceaad02b66 100644
--- a/test/core/end2end/tests/stream_payload.c
+++ b/test/core/end2end/tests/stream_payload.c
@@ -265,10 +265,12 @@ static void request_response_with_payload(grpc_end2end_test_config config,
    payload and status. */
 static void test_invoke_request_response_with_payload(
     grpc_end2end_test_config config) {
-  grpc_channel_args *client_args = grpc_channel_args_set_compression_algorithm(
-      NULL, GRPC_STREAM_COMPRESS_GZIP);
-  grpc_channel_args *server_args = grpc_channel_args_set_compression_algorithm(
-      NULL, GRPC_STREAM_COMPRESS_GZIP);
+  grpc_channel_args *client_args =
+      grpc_channel_args_set_stream_compression_algorithm(
+          NULL, GRPC_STREAM_COMPRESS_GZIP);
+  grpc_channel_args *server_args =
+      grpc_channel_args_set_stream_compression_algorithm(
+          NULL, GRPC_STREAM_COMPRESS_GZIP);
   grpc_end2end_test_fixture f =
       begin_test(config, "test_invoke_request_response_with_payload",
                  client_args, server_args);
diff --git a/test/core/end2end/tests/stream_ping_pong_streaming.c b/test/core/end2end/tests/stream_ping_pong_streaming.c
index a3321f151b..9990091e4b 100644
--- a/test/core/end2end/tests/stream_ping_pong_streaming.c
+++ b/test/core/end2end/tests/stream_ping_pong_streaming.c
@@ -90,10 +90,12 @@ static void end_test(grpc_end2end_test_fixture *f) {
 /* Client pings and server pongs. Repeat messages rounds before finishing. */
 static void test_pingpong_streaming(grpc_end2end_test_config config,
                                     int messages) {
-  grpc_channel_args *client_args = grpc_channel_args_set_compression_algorithm(
-      NULL, GRPC_STREAM_COMPRESS_GZIP);
-  grpc_channel_args *server_args = grpc_channel_args_set_compression_algorithm(
-      NULL, GRPC_STREAM_COMPRESS_GZIP);
+  grpc_channel_args *client_args =
+      grpc_channel_args_set_stream_compression_algorithm(
+          NULL, GRPC_STREAM_COMPRESS_GZIP);
+  grpc_channel_args *server_args =
+      grpc_channel_args_set_stream_compression_algorithm(
+          NULL, GRPC_STREAM_COMPRESS_GZIP);
   grpc_end2end_test_fixture f =
       begin_test(config, "test_pingpong_streaming", client_args, server_args);
   grpc_call *c;