Searched refs:interceptors_ (Results 1 – 10 of 10) sorted by relevance
138 GPR_CODEGEN_ASSERT(pos < interceptors_.size()); in RunInterceptor()139 interceptors_[pos]->Intercept(interceptor_methods); in RunInterceptor()156 interceptors_.push_back( in RegisterInterceptors()161 interceptors_.push_back(std::unique_ptr<experimental::Interceptor>( in RegisterInterceptors()173 std::vector<std::unique_ptr<experimental::Interceptor>> interceptors_; variable
226 return client_rpc_info->interceptors_.empty(); in InterceptorsListEmpty()230 return server_rpc_info == nullptr || server_rpc_info->interceptors_.empty(); in InterceptorsListEmpty()242 if (client_rpc_info->interceptors_.empty()) { in RunInterceptors()251 if (server_rpc_info == nullptr || server_rpc_info->interceptors_.empty()) { in RunInterceptors()267 if (server_rpc_info == nullptr || server_rpc_info->interceptors_.empty()) { in RunInterceptors()284 current_interceptor_index_ = rpc_info->interceptors_.size() - 1; in RunClientInterceptors()295 current_interceptor_index_ = rpc_info->interceptors_.size() - 1; in RunServerInterceptors()315 if (current_interceptor_index_ < rpc_info->interceptors_.size()) { in ProceedClient()344 if (current_interceptor_index_ < rpc_info->interceptors_.size()) { in ProceedServer()
102 GPR_CODEGEN_ASSERT(pos < interceptors_.size()); in RunInterceptor()103 interceptors_[pos]->Intercept(interceptor_methods); in RunInterceptor()113 interceptors_.push_back( in RegisterInterceptors()130 std::vector<std::unique_ptr<experimental::Interceptor>> interceptors_; variable
159 for (size_t i = 0; i < rpc_info_.interceptors_.size(); i++) { in SendCancelToInterceptors()
1158 for (const auto& interceptor : interceptors_) { in RegisterInterceptor()1176 interceptors_.emplace_back(); in RegisterInterceptor()1177 RegisteredInterceptor& interceptor = interceptors_.back(); in RegisterInterceptor()1371 for (size_t j = 0; j < interceptors_.size(); j++) { in SetupDataSourceImpl()1373 interceptors_[j].descriptor.name()) { in SetupDataSourceImpl()1379 internal_state->interceptor = interceptors_[j].factory(); in SetupDataSourceImpl()2257 auto& interceptor = interceptors_[data_source->interceptor_id - 1]; in CreateTraceWriter()2664 muxer->interceptors_.clear(); in ResetForTesting()
535 std::vector<RegisteredInterceptor> interceptors_; variable
315 for (size_t i = 0; i < rpc_info_->interceptors_.size(); i++) { in TryCancel()