diff options
Diffstat (limited to 'src/core/lib/transport/byte_stream.cc')
-rw-r--r-- | src/core/lib/transport/byte_stream.cc | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/core/lib/transport/byte_stream.cc b/src/core/lib/transport/byte_stream.cc index afb55b2f20..b96598c393 100644 --- a/src/core/lib/transport/byte_stream.cc +++ b/src/core/lib/transport/byte_stream.cc @@ -51,7 +51,7 @@ static bool slice_buffer_stream_next(grpc_byte_stream* byte_stream, grpc_closure* on_complete) { grpc_slice_buffer_stream* stream = reinterpret_cast<grpc_slice_buffer_stream*>(byte_stream); - GPR_ASSERT(stream->cursor < stream->backing_buffer->count); + GPR_ASSERT(stream->cursor < stream->backing_buffer.count); return true; } @@ -62,9 +62,9 @@ static grpc_error* slice_buffer_stream_pull(grpc_byte_stream* byte_stream, if (stream->shutdown_error != GRPC_ERROR_NONE) { return GRPC_ERROR_REF(stream->shutdown_error); } - GPR_ASSERT(stream->cursor < stream->backing_buffer->count); + GPR_ASSERT(stream->cursor < stream->backing_buffer.count); *slice = - grpc_slice_ref_internal(stream->backing_buffer->slices[stream->cursor]); + grpc_slice_ref_internal(stream->backing_buffer.slices[stream->cursor]); stream->cursor++; return GRPC_ERROR_NONE; } @@ -80,7 +80,7 @@ static void slice_buffer_stream_shutdown(grpc_byte_stream* byte_stream, static void slice_buffer_stream_destroy(grpc_byte_stream* byte_stream) { grpc_slice_buffer_stream* stream = reinterpret_cast<grpc_slice_buffer_stream*>(byte_stream); - grpc_slice_buffer_reset_and_unref_internal(stream->backing_buffer); + grpc_slice_buffer_destroy(&stream->backing_buffer); GRPC_ERROR_UNREF(stream->shutdown_error); } @@ -95,7 +95,8 @@ void grpc_slice_buffer_stream_init(grpc_slice_buffer_stream* stream, stream->base.length = static_cast<uint32_t>(slice_buffer->length); stream->base.flags = flags; stream->base.vtable = &slice_buffer_stream_vtable; - stream->backing_buffer = slice_buffer; + grpc_slice_buffer_init(&stream->backing_buffer); + grpc_slice_buffer_swap(slice_buffer, &stream->backing_buffer); stream->cursor = 0; stream->shutdown_error = GRPC_ERROR_NONE; } |