|
|
|
@ -13,6 +13,7 @@ |
|
|
|
|
// limitations under the License.
|
|
|
|
|
|
|
|
|
|
#include <functional> |
|
|
|
|
#include <memory> |
|
|
|
|
#include <string> |
|
|
|
|
#include <utility> |
|
|
|
|
|
|
|
|
@ -32,6 +33,7 @@ |
|
|
|
|
#include "src/core/lib/channel/channel_stack.h" |
|
|
|
|
#include "src/core/lib/channel/context.h" |
|
|
|
|
#include "src/core/lib/channel/promise_based_filter.h" |
|
|
|
|
#include "src/core/lib/channel/tcp_tracer.h" |
|
|
|
|
#include "src/core/lib/config/core_configuration.h" |
|
|
|
|
#include "src/core/lib/gprpp/sync.h" |
|
|
|
|
#include "src/core/lib/gprpp/time.h" |
|
|
|
@ -80,6 +82,9 @@ class FakeCallTracer : public ClientCallTracer { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void RecordCancel(grpc_error_handle /*cancel_error*/) override {} |
|
|
|
|
std::shared_ptr<TcpTracerInterface> StartNewTcpTrace() override { |
|
|
|
|
return nullptr; |
|
|
|
|
} |
|
|
|
|
void RecordEnd(const gpr_timespec& /*latency*/) override { delete this; } |
|
|
|
|
void RecordAnnotation(absl::string_view /*annotation*/) override {} |
|
|
|
|
void RecordAnnotation(const Annotation& /*annotation*/) override {} |
|
|
|
@ -155,6 +160,9 @@ class FakeServerCallTracer : public ServerCallTracer { |
|
|
|
|
void RecordReceivedDecompressedMessage( |
|
|
|
|
const SliceBuffer& /*recv_decompressed_message*/) override {} |
|
|
|
|
void RecordCancel(grpc_error_handle /*cancel_error*/) override {} |
|
|
|
|
std::shared_ptr<TcpTracerInterface> StartNewTcpTrace() override { |
|
|
|
|
return nullptr; |
|
|
|
|
} |
|
|
|
|
void RecordReceivedTrailingMetadata( |
|
|
|
|
grpc_metadata_batch* /*recv_trailing_metadata*/) override {} |
|
|
|
|
|
|
|
|
|