From cb5ec3db66106ea535ed74a913f47e576d15461d Mon Sep 17 00:00:00 2001 From: Rei Shimizu Date: Wed, 17 Mar 2021 23:30:08 +0900 Subject: [PATCH] reporter endpoint backward compat (#70) --- cpp2sky/internal/async_client.h | 2 ++ example/BUILD | 4 ++-- source/grpc_async_client_impl.cc | 3 +-- source/propagation_impl.cc | 4 ++-- source/tracing_context_impl.h | 6 ------ source/utils/circular_buffer.h | 2 -- test/grpc_async_client_test.cc | 2 -- 7 files changed, 7 insertions(+), 16 deletions(-) diff --git a/cpp2sky/internal/async_client.h b/cpp2sky/internal/async_client.h index 92f4074..0c2cc52 100644 --- a/cpp2sky/internal/async_client.h +++ b/cpp2sky/internal/async_client.h @@ -126,6 +126,8 @@ struct StreamCallbackTag { case StreamState::ReadDone: callback_->onReadDone(); break; + default: + break; } } diff --git a/example/BUILD b/example/BUILD index 151a59d..a3731f6 100644 --- a/example/BUILD +++ b/example/BUILD @@ -1,7 +1,7 @@ load("@rules_cc//cc:defs.bzl", "cc_binary") cc_binary( - name = "tracer_example", + name = "sample", srcs = ["sample.cc"], deps = [ "//cpp2sky:cpp2sky_interface", @@ -11,7 +11,7 @@ cc_binary( ) cc_binary( - name = "tracer_client_example", + name = "sample_client", srcs = ["sample_client.cc"], deps = [ "//cpp2sky:cpp2sky_interface", diff --git a/source/grpc_async_client_impl.cc b/source/grpc_async_client_impl.cc index 629d294..93a1acd 100644 --- a/source/grpc_async_client_impl.cc +++ b/source/grpc_async_client_impl.cc @@ -117,8 +117,7 @@ GrpcAsyncSegmentReporterStream::GrpcAsyncSegmentReporterStream( ctx_.set_wait_for_ready(true); request_writer_ = client_.stub().PrepareCall( - &ctx_, "/skywalking.v3.TraceSegmentReportService/collect", - &client_.completionQueue()); + &ctx_, "/TraceSegmentReportService/collect", &client_.completionQueue()); request_writer_->StartCall(reinterpret_cast(&ready_)); } diff --git a/source/propagation_impl.cc b/source/propagation_impl.cc index 809d6d0..4f4ed8e 100644 --- a/source/propagation_impl.cc +++ b/source/propagation_impl.cc @@ -36,7 +36,7 @@ SpanContextImpl::SpanContextImpl(std::string_view header_value) { size_t current_field_idx = 0; std::string value; - for (auto i = 0; i < header_value.size(); ++i) { + for (size_t i = 0; i < header_value.size(); ++i) { if (current_field_idx >= EXPECTED_FIELD_COUNT) { throw TracerException( "Invalid span context format. It must have 8 fields."); @@ -78,7 +78,7 @@ SpanContextExtensionImpl::SpanContextExtensionImpl( size_t current_field_idx = 0; std::string value; - for (auto i = 0; i < header_value.size(); ++i) { + for (size_t i = 0; i < header_value.size(); ++i) { if (current_field_idx >= EXPECTED_EXTENSION_FIELD_COUNT) { throw TracerException( "Invalid span context format. It must have 1 fields."); diff --git a/source/tracing_context_impl.h b/source/tracing_context_impl.h index 1eb6f07..8fb375a 100644 --- a/source/tracing_context_impl.h +++ b/source/tracing_context_impl.h @@ -27,7 +27,6 @@ class TracingSpanImpl : public TracingSpan { skywalking::v3::SpanObject createSpanObject() override; -#pragma region Getters int32_t spanId() const override { return span_id_; } int32_t parentSpanId() const override { return parent_span_id_; } int64_t startTime() const override { return start_time_; } @@ -47,9 +46,7 @@ class TracingSpanImpl : public TracingSpan { } bool finished() const override { return finished_; } std::string operationName() const override { return operation_name_; } -#pragma endregion -#pragma region Setters void setParentSpanId(int32_t span_id) override { assert(!finished_); parent_span_id_ = span_id; @@ -86,7 +83,6 @@ class TracingSpanImpl : public TracingSpan { void addLog(std::string key, std::string value, TimePoint current_time) override; void setComponentId(int32_t component_id) override; -#pragma endregion private: // Based on @@ -127,7 +123,6 @@ class TracingContextImpl : public TracingContext { SpanContextExtensionPtr parent_ext_span_context, RandomGenerator& random); -#pragma region Getters const std::string& traceId() const override { return trace_id_; } const std::string& traceSegmentId() const override { return trace_segment_id_; @@ -143,7 +138,6 @@ class TracingContextImpl : public TracingContext { SpanContextExtensionPtr parentSpanContextExtension() const override { return parent_ext_span_context_; } -#pragma endregion TracingSpanPtr createExitSpan(TracingSpanPtr parent_span) override; diff --git a/source/utils/circular_buffer.h b/source/utils/circular_buffer.h index b5f5399..7addc7e 100644 --- a/source/utils/circular_buffer.h +++ b/source/utils/circular_buffer.h @@ -86,10 +86,8 @@ class CircularBuffer { size_t size() const { return item_count_; } // Used for test -#pragma region test size_t frontIdx() { return front_; } size_t backIdx() { return back_; } -#pragma endregion private: void popInternal() { diff --git a/test/grpc_async_client_test.cc b/test/grpc_async_client_test.cc index d9d2c9f..c15c8be 100644 --- a/test/grpc_async_client_test.cc +++ b/test/grpc_async_client_test.cc @@ -21,8 +21,6 @@ #include "source/grpc_async_client_impl.h" #include "test/mocks.h" -#define TEST - namespace cpp2sky { using testing::_;