diff options
| author |  Yang Gao <yangg@google.com> | 2017-02-17 09:17:34 -0800 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-02-17 09:17:34 -0800 |
| commit | 13e185419cd177b7fb552601665e43820321a96b (patch) | |
| tree | 117d5f5d3c110fd9b09a3a3bf9fae813d4bfdbad /src/cpp/server/server_cc.cc | |
| parent | 46ca4f7d4eca6cb69a6d80ce35f58f2325cf945d (diff) | |
| parent | f07ed45439110033c8460295a71e4a5b4c42a0a1 (diff) | |
Merge pull request #9759 from yang-g/max_recv_msg_size
Restore the NextMessageSize for streamed calls
Diffstat (limited to 'src/cpp/server/server_cc.cc')
| -rw-r--r-- | src/cpp/server/server_cc.cc | 4 |
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); } |