Searched refs:rpc_info_ (Results 1 – 6 of 6) sorted by relevance
/third_party/grpc/src/cpp/server/ |
D | server_context.cc | 255 if (rpc_info_) { in ~ServerContextBase() 256 rpc_info_->Unref(); in ~ServerContextBase() 275 if (rpc_info_) { in BeginCompletionOp() 276 rpc_info_->Ref(); in BeginCompletionOp() 309 if (rpc_info_) { in TryCancel() 310 for (size_t i = 0; i < rpc_info_->interceptors_.size(); i++) { in TryCancel() 311 rpc_info_->RunInterceptor(&cancel_methods, i); in TryCancel()
|
/third_party/grpc/include/grpcpp/impl/codegen/ |
D | client_context_impl.h | 464 rpc_info_ = grpc::experimental::ClientRpcInfo(this, type, method, channel); in set_client_rpc_info() 465 rpc_info_.RegisterInterceptors(creators, interceptor_pos); in set_client_rpc_info() 466 return &rpc_info_; in set_client_rpc_info() 513 grpc::experimental::ClientRpcInfo rpc_info_; variable
|
D | client_context.h | 472 rpc_info_ = grpc::experimental::ClientRpcInfo(this, type, method, channel); in set_client_rpc_info() 473 rpc_info_.RegisterInterceptors(creators, interceptor_pos); in set_client_rpc_info() 474 return &rpc_info_; in set_client_rpc_info() 521 grpc::experimental::ClientRpcInfo rpc_info_; variable
|
D | server_context_impl.h | 411 rpc_info_ = new ::grpc::experimental::ServerRpcInfo(this, method, type); in set_server_rpc_info() 412 rpc_info_->RegisterInterceptors(creators); in set_server_rpc_info() 414 return rpc_info_; in set_server_rpc_info() 445 ::grpc::experimental::ServerRpcInfo* rpc_info_;
|
D | server_context.h | 426 rpc_info_ = new ::grpc::experimental::ServerRpcInfo(this, method, type); in set_server_rpc_info() 427 rpc_info_->RegisterInterceptors(creators); in set_server_rpc_info() 429 return rpc_info_; in set_server_rpc_info() 471 ::grpc::experimental::ServerRpcInfo* rpc_info_ = nullptr;
|
/third_party/grpc/src/cpp/client/ |
D | client_context.cc | 158 for (size_t i = 0; i < rpc_info_.interceptors_.size(); i++) { in SendCancelToInterceptors() 159 rpc_info_.RunInterceptor(&cancel_methods, i); in SendCancelToInterceptors()
|