aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/transport/byte_stream.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/lib/transport/byte_stream.cc')
-rw-r--r--src/core/lib/transport/byte_stream.cc11
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;
}