|
|
|
@ -253,8 +253,9 @@ GPR_EXPORT intptr_t GPR_CALLTYPE grpcsharp_batch_context_recv_message_length( |
|
|
|
|
if (!ctx->recv_message) { |
|
|
|
|
return -1; |
|
|
|
|
} |
|
|
|
|
/* TODO(issue:#7206): check return value of grpc_byte_buffer_reader_init. */ |
|
|
|
|
grpc_byte_buffer_reader_init(&reader, ctx->recv_message); |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(grpc_byte_buffer_reader_init(&reader, ctx->recv_message)); |
|
|
|
|
|
|
|
|
|
return (intptr_t)grpc_byte_buffer_length(reader.buffer_out); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -268,8 +269,7 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_batch_context_recv_message_to_buffer( |
|
|
|
|
gpr_slice slice; |
|
|
|
|
size_t offset = 0; |
|
|
|
|
|
|
|
|
|
/* TODO(issue:#7206): check return value of grpc_byte_buffer_reader_init. */ |
|
|
|
|
grpc_byte_buffer_reader_init(&reader, ctx->recv_message); |
|
|
|
|
GPR_ASSERT(grpc_byte_buffer_reader_init(&reader, ctx->recv_message)); |
|
|
|
|
|
|
|
|
|
while (grpc_byte_buffer_reader_next(&reader, &slice)) { |
|
|
|
|
size_t len = GPR_SLICE_LENGTH(slice); |
|
|
|
|