aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/cpp/server
diff options
context:
space:
mode:
authorGravatar yang-g <yangg@google.com>2017-02-16 23:01:28 -0800
committerGravatar yang-g <yangg@google.com>2017-02-16 23:01:28 -0800
commitf07ed45439110033c8460295a71e4a5b4c42a0a1 (patch)
tree47adf788bb8294b30c763cb6f66aabba4a69d2c7 /src/cpp/server
parent2ad3d73f9557da88b5c8898b991ffb4a4d8d1e3e (diff)
Restore the NextMessageSize for streamed calls
Diffstat (limited to 'src/cpp/server')
-rw-r--r--src/cpp/server/server_cc.cc4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc
index 29898a4209..5ed9f41d4f 100644
--- a/src/cpp/server/server_cc.cc
+++ b/src/cpp/server/server_cc.cc
@@ -186,7 +186,7 @@ class Server::SyncRequest final : public CompletionQueueTag {
public:
explicit CallData(Server* server, SyncRequest* mrd)
: cq_(mrd->cq_),
- call_(mrd->call_, server, &cq_),
+ call_(mrd->call_, server, &cq_, server->max_receive_message_size()),
ctx_(mrd->deadline_, mrd->request_metadata_.metadata,
mrd->request_metadata_.count),
has_request_payload_(mrd->has_request_payload_),
@@ -590,7 +590,7 @@ bool ServerInterface::BaseAsyncRequest::FinalizeResult(void** tag,
}
context_->set_call(call_);
context_->cq_ = call_cq_;
- Call call(call_, server_, call_cq_);
+ Call call(call_, server_, call_cq_, server_->max_receive_message_size());
if (*status && call_) {
context_->BeginCompletionOp(&call);
}