mirror of
https://github.com/php-win-ext/grpc.git
synced 2026-03-25 01:22:07 +01:00
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
114 lines
3.1 KiB
C++
114 lines
3.1 KiB
C++
//
|
|
//
|
|
// Copyright 2019 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 "test/cpp/microbenchmarks/callback_test_service.h"
|
|
|
|
#include "absl/log/check.h"
|
|
#include "absl/log/log.h"
|
|
|
|
namespace grpc {
|
|
namespace testing {
|
|
namespace {
|
|
|
|
std::string ToString(const grpc::string_ref& r) {
|
|
return std::string(r.data(), r.size());
|
|
}
|
|
|
|
int GetIntValueFromMetadataHelper(
|
|
const char* key,
|
|
const std::multimap<grpc::string_ref, grpc::string_ref>& metadata,
|
|
int default_value) {
|
|
if (metadata.find(key) != metadata.end()) {
|
|
std::istringstream iss(ToString(metadata.find(key)->second));
|
|
iss >> default_value;
|
|
}
|
|
|
|
return default_value;
|
|
}
|
|
|
|
int GetIntValueFromMetadata(
|
|
const char* key,
|
|
const std::multimap<grpc::string_ref, grpc::string_ref>& metadata,
|
|
int default_value) {
|
|
return GetIntValueFromMetadataHelper(key, metadata, default_value);
|
|
}
|
|
} // namespace
|
|
|
|
ServerUnaryReactor* CallbackStreamingTestService::Echo(
|
|
CallbackServerContext* context, const EchoRequest* /*request*/,
|
|
EchoResponse* response) {
|
|
int response_msgs_size = GetIntValueFromMetadata(
|
|
kServerMessageSize, context->client_metadata(), 0);
|
|
if (response_msgs_size > 0) {
|
|
response->set_message(std::string(response_msgs_size, 'a'));
|
|
} else {
|
|
response->set_message("");
|
|
}
|
|
auto* reactor = context->DefaultReactor();
|
|
reactor->Finish(grpc::Status::OK);
|
|
return reactor;
|
|
}
|
|
|
|
ServerBidiReactor<EchoRequest, EchoResponse>*
|
|
CallbackStreamingTestService::BidiStream(CallbackServerContext* context) {
|
|
class Reactor : public ServerBidiReactor<EchoRequest, EchoResponse> {
|
|
public:
|
|
explicit Reactor(CallbackServerContext* context) {
|
|
message_size_ = GetIntValueFromMetadata(kServerMessageSize,
|
|
context->client_metadata(), 0);
|
|
StartRead(&request_);
|
|
}
|
|
void OnDone() override {
|
|
CHECK(finished_);
|
|
delete this;
|
|
}
|
|
void OnCancel() override {}
|
|
void OnReadDone(bool ok) override {
|
|
if (!ok) {
|
|
// Stream is over
|
|
Finish(grpc::Status::OK);
|
|
finished_ = true;
|
|
return;
|
|
}
|
|
if (message_size_ > 0) {
|
|
response_.set_message(std::string(message_size_, 'a'));
|
|
} else {
|
|
response_.set_message("");
|
|
}
|
|
StartWrite(&response_);
|
|
}
|
|
void OnWriteDone(bool ok) override {
|
|
if (!ok) {
|
|
LOG(ERROR) << "Server write failed";
|
|
return;
|
|
}
|
|
StartRead(&request_);
|
|
}
|
|
|
|
private:
|
|
EchoRequest request_;
|
|
EchoResponse response_;
|
|
int message_size_;
|
|
bool finished_{false};
|
|
};
|
|
|
|
return new Reactor(context);
|
|
}
|
|
} // namespace testing
|
|
} // namespace grpc
|