aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/compression/message_compress_test.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-10-31 07:25:01 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-10-31 07:25:01 -0700
commita59c16c184244383900107d56e10b548e26cc7c2 (patch)
treeda1e68553dc249a8f2bf4b12593c350e1d5c0855 /test/core/compression/message_compress_test.c
parentc650fb3810ae6b9ee12526cc55d69ba12c0632d7 (diff)
Progress towards making grpc_slice_unref_internal take an exec_ctx
Diffstat (limited to 'test/core/compression/message_compress_test.c')
-rw-r--r--test/core/compression/message_compress_test.c34
1 files changed, 17 insertions, 17 deletions
diff --git a/test/core/compression/message_compress_test.c b/test/core/compression/message_compress_test.c
index fc53cd9d36..ee4f0dbe40 100644
--- a/test/core/compression/message_compress_test.c
+++ b/test/core/compression/message_compress_test.c
@@ -105,10 +105,10 @@ static void assert_passthrough(grpc_slice value,
final = grpc_slice_merge(output.slices, output.count);
GPR_ASSERT(0 == grpc_slice_cmp(value, final));
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&compressed);
- grpc_slice_buffer_destroy(&compressed_raw);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &compressed);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &compressed_raw);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
grpc_slice_unref(final);
}
@@ -164,8 +164,8 @@ static void test_tiny_data_compress(void) {
GPR_ASSERT(1 == output.count);
}
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
}
static void test_bad_decompression_data_crc(void) {
@@ -191,9 +191,9 @@ static void test_bad_decompression_data_crc(void) {
/* try (and fail) to decompress the corrupted compresed buffer */
GPR_ASSERT(0 == grpc_msg_decompress(GRPC_COMPRESS_GZIP, &corrupted, &output));
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&corrupted);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &corrupted);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
}
static void test_bad_decompression_data_trailing_garbage(void) {
@@ -210,8 +210,8 @@ static void test_bad_decompression_data_trailing_garbage(void) {
/* try (and fail) to decompress the invalid compresed buffer */
GPR_ASSERT(0 == grpc_msg_decompress(GRPC_COMPRESS_DEFLATE, &input, &output));
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
}
static void test_bad_decompression_data_stream(void) {
@@ -226,8 +226,8 @@ static void test_bad_decompression_data_stream(void) {
/* try (and fail) to decompress the invalid compresed buffer */
GPR_ASSERT(0 == grpc_msg_decompress(GRPC_COMPRESS_DEFLATE, &input, &output));
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
}
static void test_bad_compression_algorithm(void) {
@@ -247,8 +247,8 @@ static void test_bad_compression_algorithm(void) {
grpc_msg_compress(GRPC_COMPRESS_ALGORITHMS_COUNT + 123, &input, &output);
GPR_ASSERT(0 == was_compressed);
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
}
static void test_bad_decompression_algorithm(void) {
@@ -269,8 +269,8 @@ static void test_bad_decompression_algorithm(void) {
&input, &output);
GPR_ASSERT(0 == was_decompressed);
- grpc_slice_buffer_destroy(&input);
- grpc_slice_buffer_destroy(&output);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &input);
+ grpc_slice_buffer_destroy_internal(exec_ctx, &output);
}
int main(int argc, char **argv) {