diff options
author | Sree Kuchibhotla <sreek@google.com> | 2016-01-28 17:32:48 -0800 |
---|---|---|
committer | Sree Kuchibhotla <sreek@google.com> | 2016-01-28 17:32:48 -0800 |
commit | 7fa9d6f4c83766f9efc7a187527ee3ac242ea842 (patch) | |
tree | 2e91babeac98b454d0159c23a33f34f87e3ab895 /src/cpp/server/server_context.cc | |
parent | 7fbc0acf4ae9d0e719ea4917fbcbeca1d0b06b52 (diff) |
TryCancel() on ServerContext()
Diffstat (limited to 'src/cpp/server/server_context.cc')
-rw-r--r-- | src/cpp/server/server_context.cc | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/src/cpp/server/server_context.cc b/src/cpp/server/server_context.cc index 3732c1f090..4a5ac5af92 100644 --- a/src/cpp/server/server_context.cc +++ b/src/cpp/server/server_context.cc @@ -33,14 +33,14 @@ #include <grpc++/server_context.h> -#include <grpc/compression.h> -#include <grpc/grpc.h> -#include <grpc/support/alloc.h> -#include <grpc/support/log.h> #include <grpc++/completion_queue.h> #include <grpc++/impl/call.h> #include <grpc++/impl/sync.h> #include <grpc++/support/time.h> +#include <grpc/compression.h> +#include <grpc/grpc.h> +#include <grpc/support/alloc.h> +#include <grpc/support/log.h> #include "src/core/channel/compress_filter.h" #include "src/cpp/common/create_auth_context.h" @@ -173,6 +173,14 @@ void ServerContext::AddTrailingMetadata(const grpc::string& key, trailing_metadata_.insert(std::make_pair(key, value)); } +void ServerContext::TryCancel() const { + grpc_call_error err = grpc_call_cancel_with_status( + call_, GRPC_STATUS_CANCELLED, "Cancelled on the server side", NULL); + if (err != GRPC_CALL_OK) { + gpr_log(GPR_INFO, "TryCancel failed with: %d", err); + } +} + bool ServerContext::IsCancelled() const { return completion_op_ && completion_op_->CheckCancelled(cq_); } |