|
|
|
@ -63,7 +63,7 @@ static void test_read_one_slice(void) { |
|
|
|
|
"Couldn't init byte buffer reader"); |
|
|
|
|
first_code = grpc_byte_buffer_reader_next(&reader, &first_slice); |
|
|
|
|
GPR_ASSERT(first_code != 0); |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR(first_slice), "test", 4) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(first_slice), "test", 4) == 0); |
|
|
|
|
grpc_slice_unref(first_slice); |
|
|
|
|
second_code = grpc_byte_buffer_reader_next(&reader, &second_slice); |
|
|
|
|
GPR_ASSERT(second_code == 0); |
|
|
|
@ -79,14 +79,14 @@ static void test_read_one_slice_malloc(void) { |
|
|
|
|
|
|
|
|
|
LOG_TEST("test_read_one_slice_malloc"); |
|
|
|
|
slice = grpc_slice_malloc(4); |
|
|
|
|
memcpy(GPR_SLICE_START_PTR(slice), "test", 4); |
|
|
|
|
memcpy(GRPC_SLICE_START_PTR(slice), "test", 4); |
|
|
|
|
buffer = grpc_raw_byte_buffer_create(&slice, 1); |
|
|
|
|
grpc_slice_unref(slice); |
|
|
|
|
GPR_ASSERT(grpc_byte_buffer_reader_init(&reader, buffer) && |
|
|
|
|
"Couldn't init byte buffer reader"); |
|
|
|
|
first_code = grpc_byte_buffer_reader_next(&reader, &first_slice); |
|
|
|
|
GPR_ASSERT(first_code != 0); |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR(first_slice), "test", 4) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(first_slice), "test", 4) == 0); |
|
|
|
|
grpc_slice_unref(first_slice); |
|
|
|
|
second_code = grpc_byte_buffer_reader_next(&reader, &second_slice); |
|
|
|
|
GPR_ASSERT(second_code == 0); |
|
|
|
@ -108,7 +108,7 @@ static void test_read_none_compressed_slice(void) { |
|
|
|
|
"Couldn't init byte buffer reader"); |
|
|
|
|
first_code = grpc_byte_buffer_reader_next(&reader, &first_slice); |
|
|
|
|
GPR_ASSERT(first_code != 0); |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR(first_slice), "test", 4) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(first_slice), "test", 4) == 0); |
|
|
|
|
grpc_slice_unref(first_slice); |
|
|
|
|
second_code = grpc_byte_buffer_reader_next(&reader, &second_slice); |
|
|
|
|
GPR_ASSERT(second_code == 0); |
|
|
|
@ -143,7 +143,7 @@ static void read_compressed_slice(grpc_compression_algorithm algorithm, |
|
|
|
|
grpc_slice_buffer_init(&sliceb_out); |
|
|
|
|
|
|
|
|
|
input_slice = grpc_slice_malloc(input_size); |
|
|
|
|
memset(GPR_SLICE_START_PTR(input_slice), 'a', input_size); |
|
|
|
|
memset(GRPC_SLICE_START_PTR(input_slice), 'a', input_size); |
|
|
|
|
grpc_slice_buffer_add(&sliceb_in, input_slice); /* takes ownership */ |
|
|
|
|
GPR_ASSERT(grpc_msg_compress(algorithm, &sliceb_in, &sliceb_out)); |
|
|
|
|
|
|
|
|
@ -153,10 +153,10 @@ static void read_compressed_slice(grpc_compression_algorithm algorithm, |
|
|
|
|
"Couldn't init byte buffer reader"); |
|
|
|
|
|
|
|
|
|
while (grpc_byte_buffer_reader_next(&reader, &read_slice)) { |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR(read_slice), |
|
|
|
|
GPR_SLICE_START_PTR(input_slice) + read_count, |
|
|
|
|
GPR_SLICE_LENGTH(read_slice)) == 0); |
|
|
|
|
read_count += GPR_SLICE_LENGTH(read_slice); |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(read_slice), |
|
|
|
|
GRPC_SLICE_START_PTR(input_slice) + read_count, |
|
|
|
|
GRPC_SLICE_LENGTH(read_slice)) == 0); |
|
|
|
|
read_count += GRPC_SLICE_LENGTH(read_slice); |
|
|
|
|
grpc_slice_unref(read_slice); |
|
|
|
|
} |
|
|
|
|
GPR_ASSERT(read_count == input_size); |
|
|
|
@ -185,7 +185,7 @@ static void test_byte_buffer_from_reader(void) { |
|
|
|
|
|
|
|
|
|
LOG_TEST("test_byte_buffer_from_reader"); |
|
|
|
|
slice = grpc_slice_malloc(4); |
|
|
|
|
memcpy(GPR_SLICE_START_PTR(slice), "test", 4); |
|
|
|
|
memcpy(GRPC_SLICE_START_PTR(slice), "test", 4); |
|
|
|
|
buffer = grpc_raw_byte_buffer_create(&slice, 1); |
|
|
|
|
grpc_slice_unref(slice); |
|
|
|
|
GPR_ASSERT(grpc_byte_buffer_reader_init(&reader, buffer) && |
|
|
|
@ -195,7 +195,7 @@ static void test_byte_buffer_from_reader(void) { |
|
|
|
|
GPR_ASSERT(buffer->type == buffer_from_reader->type); |
|
|
|
|
GPR_ASSERT(buffer_from_reader->data.raw.compression == GRPC_COMPRESS_NONE); |
|
|
|
|
GPR_ASSERT(buffer_from_reader->data.raw.slice_buffer.count == 1); |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR( |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR( |
|
|
|
|
buffer_from_reader->data.raw.slice_buffer.slices[0]), |
|
|
|
|
"test", 4) == 0); |
|
|
|
|
|
|
|
|
@ -217,9 +217,9 @@ static void test_readall(void) { |
|
|
|
|
memset(lotsa_bs, 'b', 1024); |
|
|
|
|
/* use slices large enough to overflow inlining */ |
|
|
|
|
slices[0] = grpc_slice_malloc(512); |
|
|
|
|
memcpy(GPR_SLICE_START_PTR(slices[0]), lotsa_as, 512); |
|
|
|
|
memcpy(GRPC_SLICE_START_PTR(slices[0]), lotsa_as, 512); |
|
|
|
|
slices[1] = grpc_slice_malloc(1024); |
|
|
|
|
memcpy(GPR_SLICE_START_PTR(slices[1]), lotsa_bs, 1024); |
|
|
|
|
memcpy(GRPC_SLICE_START_PTR(slices[1]), lotsa_bs, 1024); |
|
|
|
|
|
|
|
|
|
buffer = grpc_raw_byte_buffer_create(slices, 2); |
|
|
|
|
grpc_slice_unref(slices[0]); |
|
|
|
@ -229,9 +229,9 @@ static void test_readall(void) { |
|
|
|
|
"Couldn't init byte buffer reader"); |
|
|
|
|
slice_out = grpc_byte_buffer_reader_readall(&reader); |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(GPR_SLICE_LENGTH(slice_out) == 512 + 1024); |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR(slice_out), lotsa_as, 512) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(&(GPR_SLICE_START_PTR(slice_out)[512]), lotsa_bs, 1024) == |
|
|
|
|
GPR_ASSERT(GRPC_SLICE_LENGTH(slice_out) == 512 + 1024); |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(slice_out), lotsa_as, 512) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(&(GRPC_SLICE_START_PTR(slice_out)[512]), lotsa_bs, 1024) == |
|
|
|
|
0); |
|
|
|
|
grpc_slice_unref(slice_out); |
|
|
|
|
grpc_byte_buffer_destroy(buffer); |
|
|
|
@ -252,9 +252,9 @@ static void test_byte_buffer_copy(void) { |
|
|
|
|
memset(lotsa_bs, 'b', 1024); |
|
|
|
|
/* use slices large enough to overflow inlining */ |
|
|
|
|
slices[0] = grpc_slice_malloc(512); |
|
|
|
|
memcpy(GPR_SLICE_START_PTR(slices[0]), lotsa_as, 512); |
|
|
|
|
memcpy(GRPC_SLICE_START_PTR(slices[0]), lotsa_as, 512); |
|
|
|
|
slices[1] = grpc_slice_malloc(1024); |
|
|
|
|
memcpy(GPR_SLICE_START_PTR(slices[1]), lotsa_bs, 1024); |
|
|
|
|
memcpy(GRPC_SLICE_START_PTR(slices[1]), lotsa_bs, 1024); |
|
|
|
|
|
|
|
|
|
buffer = grpc_raw_byte_buffer_create(slices, 2); |
|
|
|
|
grpc_slice_unref(slices[0]); |
|
|
|
@ -265,9 +265,9 @@ static void test_byte_buffer_copy(void) { |
|
|
|
|
"Couldn't init byte buffer reader"); |
|
|
|
|
slice_out = grpc_byte_buffer_reader_readall(&reader); |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(GPR_SLICE_LENGTH(slice_out) == 512 + 1024); |
|
|
|
|
GPR_ASSERT(memcmp(GPR_SLICE_START_PTR(slice_out), lotsa_as, 512) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(&(GPR_SLICE_START_PTR(slice_out)[512]), lotsa_bs, 1024) == |
|
|
|
|
GPR_ASSERT(GRPC_SLICE_LENGTH(slice_out) == 512 + 1024); |
|
|
|
|
GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(slice_out), lotsa_as, 512) == 0); |
|
|
|
|
GPR_ASSERT(memcmp(&(GRPC_SLICE_START_PTR(slice_out)[512]), lotsa_bs, 1024) == |
|
|
|
|
0); |
|
|
|
|
grpc_slice_unref(slice_out); |
|
|
|
|
grpc_byte_buffer_destroy(buffer); |
|
|
|
|