diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-01-26 23:16:00 -0800 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-01-26 23:16:00 -0800 |
| commit | eb30fd1df5a474d63d4a4f9262cd8fe87fd19868 (patch) | |
| tree | 5122e971407526ba5d8139a6666dbfa314f51957 /src | |
| parent | de78a21579dabf84a7710fce2ff4fa2bfdb7e04c (diff) | |
| parent | 4edd56751f8309f55922518f2598c35f3c007b1e (diff) | |
Merge pull request #9404 from ctiller/maxmsgsz
Remove double-checking of max-message-size in C++ layers
Diffstat (limited to 'src')
| -rw-r--r-- | src/cpp/server/server_cc.cc | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc index 817d85a81c..7785a1f124 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_, server->max_receive_message_size_), + call_(mrd->call_, server, &cq_), ctx_(mrd->deadline_, mrd->request_metadata_.metadata, mrd->request_metadata_.count), has_request_payload_(mrd->has_request_payload_), @@ -208,8 +208,8 @@ class Server::SyncRequest final : public CompletionQueueTag { void Run(std::shared_ptr<GlobalCallbacks> global_callbacks) { ctx_.BeginCompletionOp(&call_); global_callbacks->PreSynchronousRequest(&ctx_); - method_->handler()->RunHandler(MethodHandler::HandlerParameter( - &call_, &ctx_, request_payload_, call_.max_receive_message_size())); + method_->handler()->RunHandler( + MethodHandler::HandlerParameter(&call_, &ctx_, request_payload_)); global_callbacks->PostSynchronousRequest(&ctx_); request_payload_ = nullptr; void* ignored_tag; @@ -598,7 +598,7 @@ bool ServerInterface::BaseAsyncRequest::FinalizeResult(void** tag, grpc_metadata_array_destroy(&initial_metadata_array_); context_->set_call(call_); context_->cq_ = call_cq_; - Call call(call_, server_, call_cq_, server_->max_receive_message_size()); + Call call(call_, server_, call_cq_); if (*status && call_) { context_->BeginCompletionOp(&call); } |