mirror of
https://github.com/php-win-ext/grpc.git
synced 2026-04-29 03:53:17 +02:00
Tanvi Jagtap
986428d252
[grpc][Gpr_To_Absl_Logging] Migrating from gpr to absl logging - gpr_log In this CL we are migrating from gRPCs own gpr logging mechanism to absl logging mechanism. The intention is to deprecate gpr_log in the future. We have the following mapping 1. gpr_log(GPR_INFO,...) -> LOG(INFO) 2. gpr_log(GPR_ERROR,...) -> LOG(ERROR) 3. gpr_log(GPR_DEBUG,...) -> VLOG(2) Reviewers need to check : 1. If the above mapping is correct. 2. The content of the log is as before. gpr_log format strings did not use string_view or std::string . absl LOG accepts these. So there will be some elimination of string_view and std::string related conversions. This is expected. Closes #36636 COPYBARA_INTEGRATE_REVIEW=https://github.com/grpc/grpc/pull/36636 from tanvi-jagtap:regex_test_cpp f2cac9c5a49f8d6025989160b9d9d6954dc8cc2d PiperOrigin-RevId: 634954173
113 lines
4.1 KiB
C++
113 lines
4.1 KiB
C++
//
|
|
//
|
|
// Copyright 2015 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 <memory>
|
|
#include <sstream>
|
|
|
|
#include "absl/flags/flag.h"
|
|
#include "absl/log/check.h"
|
|
#include "absl/log/log.h"
|
|
|
|
#include <grpc/grpc.h>
|
|
#include <grpcpp/channel.h>
|
|
#include <grpcpp/client_context.h>
|
|
#include <grpcpp/support/channel_arguments.h>
|
|
|
|
#include "src/core/lib/gprpp/crash.h"
|
|
#include "src/proto/grpc/testing/empty.pb.h"
|
|
#include "src/proto/grpc/testing/messages.pb.h"
|
|
#include "src/proto/grpc/testing/test.grpc.pb.h"
|
|
#include "test/cpp/util/create_test_channel.h"
|
|
#include "test/cpp/util/test_config.h"
|
|
|
|
ABSL_FLAG(int32_t, server_control_port, 0, "Server port for control rpcs.");
|
|
ABSL_FLAG(int32_t, server_retry_port, 0,
|
|
"Server port for testing reconnection.");
|
|
ABSL_FLAG(std::string, server_host, "localhost", "Server host to connect to");
|
|
// TODO(Capstan): Consider using absl::Duration
|
|
ABSL_FLAG(int32_t, max_reconnect_backoff_ms, 0,
|
|
"Maximum backoff time, or 0 for default.");
|
|
|
|
using grpc::CallCredentials;
|
|
using grpc::Channel;
|
|
using grpc::ChannelArguments;
|
|
using grpc::ClientContext;
|
|
using grpc::CreateTestChannel;
|
|
using grpc::Status;
|
|
using grpc::testing::Empty;
|
|
using grpc::testing::INSECURE;
|
|
using grpc::testing::ReconnectInfo;
|
|
using grpc::testing::ReconnectParams;
|
|
using grpc::testing::ReconnectService;
|
|
using grpc::testing::TLS;
|
|
|
|
int main(int argc, char** argv) {
|
|
grpc::testing::InitTest(&argc, &argv, true);
|
|
CHECK(absl::GetFlag(FLAGS_server_control_port));
|
|
CHECK(absl::GetFlag(FLAGS_server_retry_port));
|
|
|
|
std::ostringstream server_address;
|
|
server_address << absl::GetFlag(FLAGS_server_host) << ':'
|
|
<< absl::GetFlag(FLAGS_server_control_port);
|
|
std::unique_ptr<ReconnectService::Stub> control_stub(
|
|
ReconnectService::NewStub(
|
|
CreateTestChannel(server_address.str(), INSECURE)));
|
|
ClientContext start_context;
|
|
ReconnectParams reconnect_params;
|
|
reconnect_params.set_max_reconnect_backoff_ms(
|
|
absl::GetFlag(FLAGS_max_reconnect_backoff_ms));
|
|
Empty empty_response;
|
|
Status start_status =
|
|
control_stub->Start(&start_context, reconnect_params, &empty_response);
|
|
CHECK(start_status.ok());
|
|
|
|
LOG(INFO) << "Starting connections with retries.";
|
|
server_address.str("");
|
|
server_address << absl::GetFlag(FLAGS_server_host) << ':'
|
|
<< absl::GetFlag(FLAGS_server_retry_port);
|
|
ChannelArguments channel_args;
|
|
if (absl::GetFlag(FLAGS_max_reconnect_backoff_ms) > 0) {
|
|
channel_args.SetInt(GRPC_ARG_MAX_RECONNECT_BACKOFF_MS,
|
|
absl::GetFlag(FLAGS_max_reconnect_backoff_ms));
|
|
}
|
|
std::shared_ptr<Channel> retry_channel =
|
|
CreateTestChannel(server_address.str(), "foo.test.google.fr", TLS, false,
|
|
std::shared_ptr<CallCredentials>(), channel_args);
|
|
|
|
// About 13 retries.
|
|
const int kDeadlineSeconds = 540;
|
|
// Use any rpc to test retry.
|
|
std::unique_ptr<ReconnectService::Stub> retry_stub(
|
|
ReconnectService::NewStub(retry_channel));
|
|
ClientContext retry_context;
|
|
retry_context.set_deadline(std::chrono::system_clock::now() +
|
|
std::chrono::seconds(kDeadlineSeconds));
|
|
Status retry_status =
|
|
retry_stub->Start(&retry_context, reconnect_params, &empty_response);
|
|
CHECK(retry_status.error_code() == grpc::StatusCode::DEADLINE_EXCEEDED);
|
|
LOG(INFO) << "Done retrying, getting final data from server";
|
|
|
|
ClientContext stop_context;
|
|
ReconnectInfo response;
|
|
Status stop_status = control_stub->Stop(&stop_context, Empty(), &response);
|
|
CHECK(stop_status.ok());
|
|
CHECK(response.passed() == true);
|
|
LOG(INFO) << "Passed";
|
|
return 0;
|
|
}
|