diff options
author | Yang Gao <yangg@google.com> | 2015-03-06 16:11:16 -0800 |
---|---|---|
committer | Yang Gao <yangg@google.com> | 2015-03-06 16:11:16 -0800 |
commit | 5f4539f4e8be43c477bad8fba84c6ce6c125a120 (patch) | |
tree | 397c321e5bc0b944c2e684f89916624ea1fbf3bb /src/cpp/server/server.cc | |
parent | df6e45c52a40aca45485cc087f11134d4714954e (diff) |
Service side should be done, it builds and existing tests pass
Diffstat (limited to 'src/cpp/server/server.cc')
-rw-r--r-- | src/cpp/server/server.cc | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/cpp/server/server.cc b/src/cpp/server/server.cc index 4de1ad290e..6e66cd476c 100644 --- a/src/cpp/server/server.cc +++ b/src/cpp/server/server.cc @@ -371,6 +371,12 @@ class Server::AsyncRequest GRPC_FINAL : public CompletionQueueTag { array_.metadata[i].value, array_.metadata[i].value + array_.metadata[i].value_length))); } + if (anonymous_ctx_) { + anonymous_ctx_->method_.assign(call_details_.method, + call_details_.method_capacity); + anonymous_ctx_->host_.assign(call_details_.host, + call_details_.host_capacity); + } } ctx->call_ = call_; Call call(call_, server_, cq_); @@ -403,6 +409,7 @@ void Server::RequestAsyncCall(void* registered_method, ServerContext* context, CompletionQueue* cq, void* tag) { new AsyncRequest(this, registered_method, context, request, stream, cq, tag); } + void Server::RequestAsyncAnonymousCall(AnonymousServerContext* context, ServerAsyncStreamingInterface* stream, CompletionQueue* cq, void* tag) { |