aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/ext/transport/inproc/inproc_transport.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2017-07-21 16:06:48 -0700
committerGravatar Craig Tiller <ctiller@google.com>2017-07-21 16:06:48 -0700
commit39af3361ae8e34eecc4899b114eeeb7df13ad879 (patch)
tree5b0437eb08321dad3798c165616d02df34c7e0d2 /src/core/ext/transport/inproc/inproc_transport.c
parent00b1df590909906606c5be6e6f12b3410c352cab (diff)
parent781fd6f6ea03645a520cd5c675da67ab61f87e4b (diff)
Merge github.com:grpc/grpc into stats
Diffstat (limited to 'src/core/ext/transport/inproc/inproc_transport.c')
-rw-r--r--src/core/ext/transport/inproc/inproc_transport.c7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/core/ext/transport/inproc/inproc_transport.c b/src/core/ext/transport/inproc/inproc_transport.c
index 4df64d81e2..14498021eb 100644
--- a/src/core/ext/transport/inproc/inproc_transport.c
+++ b/src/core/ext/transport/inproc/inproc_transport.c
@@ -190,8 +190,11 @@ typedef struct inproc_stream {
static bool inproc_slice_byte_stream_next(grpc_exec_ctx *exec_ctx,
grpc_byte_stream *bs, size_t max,
grpc_closure *on_complete) {
- inproc_slice_byte_stream *stream = (inproc_slice_byte_stream *)bs;
- return (stream->le->sb.count != 0);
+ // Because inproc transport always provides the entire message atomically,
+ // the byte stream always has data available when this function is called.
+ // Thus, this function always returns true (unlike other transports) and
+ // there is never any need to schedule a closure
+ return true;
}
static grpc_error *inproc_slice_byte_stream_pull(grpc_exec_ctx *exec_ctx,