Sha256: e1c099294d60cd113a11a72a4a1f392cea7cd3676d1ccf7de37a670287a31eba
Contents?: true
Size: 1.85 KB
Versions: 3
Compression:
Stored size: 1.85 KB
Contents
// Copyright 2017 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/ext/transport/inproc/inproc_transport.h" #include <grpc/support/log.h> #include "src/core/ext/transport/inproc/legacy_inproc_transport.h" #include "src/core/lib/experiments/experiments.h" #include "src/core/lib/gprpp/crash.h" namespace grpc_core { namespace { bool UsePromiseBasedTransport() { if (!IsPromiseBasedInprocTransportEnabled()) return false; if (!IsPromiseBasedClientCallEnabled()) { gpr_log(GPR_ERROR, "Promise based inproc transport requested but promise based client " "calls are disabled: using legacy implementation."); return false; } if (!IsPromiseBasedServerCallEnabled()) { gpr_log(GPR_ERROR, "Promise based inproc transport requested but promise based server " "calls are disabled: using legacy implementation."); return false; } return true; } } // namespace } // namespace grpc_core grpc_channel* grpc_inproc_channel_create(grpc_server* server, const grpc_channel_args* args, void* reserved) { if (!grpc_core::UsePromiseBasedTransport()) { return grpc_legacy_inproc_channel_create(server, args, reserved); } grpc_core::Crash("unimplemented"); }
Version data entries
3 entries across 3 versions & 1 rubygems