Sha256: 2c8d1b707e2dc2987ce0784913a14137df73797069b080a6753c29211a182472
Contents?: true
Size: 1.66 KB
Versions: 13
Compression:
Stored size: 1.66 KB
Contents
/* * * Copyright 2016 gRPC authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * */ #include <grpc/support/port_platform.h> #include "src/core/lib/channel/handshaker_registry.h" namespace grpc_core { void HandshakerRegistry::Builder::RegisterHandshakerFactory( bool at_start, HandshakerType handshaker_type, std::unique_ptr<HandshakerFactory> factory) { auto& vec = factories_[handshaker_type]; auto where = at_start ? vec.begin() : vec.end(); vec.insert(where, std::move(factory)); } HandshakerRegistry HandshakerRegistry::Builder::Build() { HandshakerRegistry out; for (size_t i = 0; i < NUM_HANDSHAKER_TYPES; i++) { out.factories_[i] = std::move(factories_[i]); } return out; } void HandshakerRegistry::AddHandshakers(HandshakerType handshaker_type, const grpc_channel_args* args, grpc_pollset_set* interested_parties, HandshakeManager* handshake_mgr) const { for (const auto& factory : factories_[handshaker_type]) { factory->AddHandshakers(args, interested_parties, handshake_mgr); } } } // namespace grpc_core
Version data entries
13 entries across 13 versions & 2 rubygems