Home
last modified time | relevance | path

Searched full:tracers (Results 1 – 25 of 223) sorted by relevance

123456789

/aosp_15_r20/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
H A DStatsTraceContext.java43 private final StreamTracer[] tracers; field in StatsTraceContext
50 ClientStreamTracer[] tracers, Attributes transportAtts, Metadata headers) { in newClientContext() argument
51 StatsTraceContext ctx = new StatsTraceContext(tracers); in newClientContext()
52 for (ClientStreamTracer tracer : tracers) { in newClientContext()
68 StreamTracer[] tracers = new StreamTracer[factories.size()]; in newServerContext() local
69 for (int i = 0; i < tracers.length; i++) { in newServerContext()
70 tracers[i] = factories.get(i).newServerStreamTracer(fullMethodName, headers); in newServerContext()
72 return new StatsTraceContext(tracers); in newServerContext()
76 StatsTraceContext(StreamTracer[] tracers) { in StatsTraceContext() argument
77 this.tracers = tracers; in StatsTraceContext()
[all …]
H A DDelayedClientTransport.java138 ClientStreamTracer[] tracers) { in newStream() argument
146 return new FailingClientStream(shutdownStatus, tracers); in newStream()
149 return createPendingStream(args, tracers); in newStream()
153 return createPendingStream(args, tracers); in newStream()
164 tracers); in newStream()
180 PickSubchannelArgs args, ClientStreamTracer[] tracers) { in createPendingStream() argument
181 PendingStream pendingStream = new PendingStream(args, tracers); in createPendingStream()
186 for (ClientStreamTracer streamTracer : tracers) { in createPendingStream()
250 new FailingClientStream(status, RpcProgress.REFUSED, stream.tracers)); in shutdownNow()
357 private final ClientStreamTracer[] tracers; field in DelayedClientTransport.PendingStream
[all …]
H A DFailingClientStream.java34 private final ClientStreamTracer[] tracers; field in FailingClientStream
39 public FailingClientStream(Status error, ClientStreamTracer[] tracers) { in FailingClientStream() argument
40 this(error, RpcProgress.PROCESSED, tracers); in FailingClientStream()
47 Status error, RpcProgress rpcProgress, ClientStreamTracer[] tracers) { in FailingClientStream() argument
51 this.tracers = tracers; in FailingClientStream()
58 for (ClientStreamTracer tracer : tracers) { in start()
H A DGrpcUtil.java738 ClientStreamTracer[] tracers) { in getTransportFromPickResult()
742 checkState(tracers[tracers.length - 1] == NOOP_TRACER, "lb tracer already assigned"); in getTransportFromPickResult()
743 tracers[tracers.length - 1] = streamTracer; in getTransportFromPickResult()
744 return transport.newStream(method, headers, callOptions, tracers); in getTransportFromPickResult()
776 /** Gets stream tracers based on CallOptions. */
780 ClientStreamTracer[] tracers = new ClientStreamTracer[factories.size() + 1];
787 tracers[i] = factories.get(i).newClientStreamTracer(streamInfo, headers);
791 tracers[tracers.length - 1] = NOOP_TRACER;
792 return tracers;
H A DMetadataApplierImpl.java40 private final ClientStreamTracer[] tracers; field in MetadataApplierImpl
56 CallOptions callOptions, MetadataApplierListener listener, ClientStreamTracer[] tracers) { in MetadataApplierImpl() argument
63 this.tracers = tracers; in MetadataApplierImpl()
74 realStream = transport.newStream(method, origHeaders, callOptions, tracers); in apply()
86 new FailingClientStream(GrpcUtil.replaceInappropriateControlPlaneStatus(status), tracers)); in fail()
H A DCallCredentialsApplyingTransportFactory.java110 ClientStreamTracer[] tracers) { in newStream() argument
119 delegate, method, headers, callOptions, applierListener, tracers); in newStream()
122 return new FailingClientStream(shutdownStatus, tracers); in newStream()
176 return new FailingClientStream(shutdownStatus, tracers); in newStream()
178 return delegate.newStream(method, headers, callOptions, tracers); in newStream()
/aosp_15_r20/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
H A DCallCredentialsApplyingTest.java93 private static final ClientStreamTracer[] tracers = new ClientStreamTracer[] { field in CallCredentialsApplyingTest
145 transport.newStream(method, origHeaders, callOptions, tracers); in parameterPropagation_base()
170 tracers); in parameterPropagation_overrideByCallOptions()
190 transport.newStream(method, origHeaders, callOptions, tracers); in parameterPropagation_transportSetSecurityLevel()
214 tracers); in parameterPropagation_callOptionsSetAuthority()
236 method, origHeaders, callOptions, tracers); in credentialThrows()
245 assertTrue(transport.newStream(method, origHeaders, callOptions, tracers) in credentialThrows()
256 method, origHeaders, callOptions, tracers); in applyMetadata_inline()
258 verify(mockTransport).newStream(method, origHeaders, callOptions, tracers); in applyMetadata_inline()
263 assertTrue(transport.newStream(method, origHeaders, callOptions, tracers) in applyMetadata_inline()
[all …]
H A DDelayedClientTransportTest.java94 private static final ClientStreamTracer[] tracers = new ClientStreamTracer[] { field in DelayedClientTransportTest
148 method, headers, callOptions, tracers); in streamStartThenAssignTransport()
169 ClientStream stream = delayedTransport.newStream(method, headers, callOptions, tracers); in newStreamThenAssignTransportThenShutdown()
199 method, headers, callOptions, tracers); in assignTransportThenShutdownThenNewStream()
213 method, headers, callOptions, tracers); in assignTransportThenShutdownNowThenNewStream()
223 method, new Metadata(), CallOptions.DEFAULT, tracers); in startThenCancelStreamWithoutSetTransport()
236 method, headers, callOptions, tracers); in newStreamThenShutdownTransportThenAssignTransport()
249 method, headers, callOptions, tracers); in newStreamThenShutdownTransportThenAssignTransport()
258 method, new Metadata(), CallOptions.DEFAULT, tracers); in newStreamThenShutdownTransportThenAssignTransport()
273 method, new Metadata(), CallOptions.DEFAULT, tracers); in newStreamThenShutdownTransportThenCancelStream()
[all …]
H A DGrpcUtilTest.java56 private static final ClientStreamTracer[] tracers = new ClientStreamTracer[] { field in GrpcUtilTest
267 tracers); in getTransportFromPickResult_errorPickResult_failFast()
294 tracers); in getTransportFromPickResult_errorPickResult_noInappropriateControlPlaneStatus()
329 tracers); in getTransportFromPickResult_errorPickResult_appropriateControlPlaneStatus()
347 tracers); in getTransportFromPickResult_dropPickResult_waitForReady()
364 tracers); in getTransportFromPickResult_dropPickResult_failFast()
/aosp_15_r20/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
H A DOkHttpClientTransportTest.java153 private static final ClientStreamTracer[] tracers = new ClientStreamTracer[] { field in OkHttpClientTransportTest
282 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in testClientHandlerFrameLogger()
370 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in maxMessageSizeShouldBeEnforced()
422 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in nextFrameThrowIoException()
426 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in nextFrameThrowIoException()
456 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in nextFrameThrowsError()
477 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in nextFrameReturnFalse()
495 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in readMessages()
545 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in invalidInboundHeadersCancelStream()
569 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT, tracers); in invalidInboundTrailersPropagateToMetadata()
[all …]
/aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/extensions/tracers/opentelemetry/resource_detectors/v3/
H A Ddynatrace_resource_detector_pb2.py3 # source: envoy/extensions/tracers/opentelemetry/resource_detectors/v3/dynatrace_resource_detector.…
17tracers/opentelemetry/resource_detectors/v3/dynatrace_resource_detector.proto\x12<envoy.extensions…
21 _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'envoy.extensions.tracers.opentelemetry.resourc…
24 …s.tracers.opentelemetry.resource_detectors.v3B\036DynatraceResourceDetectorProtoP\001Zxgithub.com/…
H A Denvironment_resource_detector_pb2.py3 # source: envoy/extensions/tracers/opentelemetry/resource_detectors/v3/environment_resource_detecto…
17tracers/opentelemetry/resource_detectors/v3/environment_resource_detector.proto\x12<envoy.extensio…
21 _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'envoy.extensions.tracers.opentelemetry.resourc…
24 …ns.tracers.opentelemetry.resource_detectors.v3B EnvironmentResourceDetectorProtoP\001Zxgithub.com/…
/aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/extensions/tracers/opentelemetry/samplers/v3/
H A Dalways_on_sampler_pb2.py3 # source: envoy/extensions/tracers/opentelemetry/samplers/v3/always_on_sampler.proto
17tracers/opentelemetry/samplers/v3/always_on_sampler.proto\x12\x32\x65nvoy.extensions.tracers.opent…
21 _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'envoy.extensions.tracers.opentelemetry.sampler…
24 ….extensions.tracers.opentelemetry.samplers.v3B\024AlwaysOnSamplerProtoP\001Zdgithub.com/envoyproxy…
/aosp_15_r20/external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/
H A DAbstractTransportTest.java190 private final ClientStreamTracer[] tracers = new ClientStreamTracer[] { field in AbstractTransportTest
202 final ArrayDeque<TestServerStreamTracer> tracers =
207 TestServerStreamTracer tracer = tracers.poll();
444 methodDescriptor, new Metadata(), callOptions, tracers); in openStreamPreventsTermination()
497 methodDescriptor, new Metadata(), callOptions, tracers); in shutdownNowKillsClientStream()
536 methodDescriptor, new Metadata(), callOptions, tracers); in shutdownNowKillsServerStream()
592 methodDescriptor, new Metadata(), callOptions, tracers); in ping_duringShutdown()
643 methodDescriptor, new Metadata(), callOptions, tracers); in newStream_duringShutdown()
679 methodDescriptor, new Metadata(), callOptions, tracers); in newStream_afterTermination()
816 methodDescriptor, clientHeaders, callOptions, tracers); in basicStream()
[all …]
/aosp_15_r20/external/grpc-grpc-java/xds/third_party/envoy/src/main/proto/envoy/config/trace/v2/
H A Dhttp_tracer.proto22 // Envoy may support other tracers in the future, but right now the HTTP tracer is the only one
40 // - *envoy.tracers.lightstep*
41 // - *envoy.tracers.zipkin*
42 // - *envoy.tracers.dynamic_ot*
43 // - *envoy.tracers.datadog*
44 // - *envoy.tracers.opencensus*
45 // - *envoy.tracers.xray*
/aosp_15_r20/external/python/cpython3/Lib/idlelib/
Dconfigdialog.py89 tracers.attach()
248 # # Define tk vars and register var and callback with tracers.
334 self.font_name = tracers.add(StringVar(self), self.var_changed_font)
335 self.font_size = tracers.add(StringVar(self), self.var_changed_font)
336 self.font_bold = tracers.add(BooleanVar(self), self.var_changed_font)
603 self.builtin_name = tracers.add(
605 self.custom_name = tracers.add(
608 self.color = tracers.add(
610 self.theme_source = tracers.add(
612 self.highlight_target = tracers.add(
[all …]
/aosp_15_r20/external/python/cpython3/Lib/idlelib/idle_test/
Dtest_configdialog.py13 from idlelib.configdialog import idleConf, changes, tracers
45 tracers.detach()
46 tracers.clear()
129 tracers.detach()
140 tracers.attach()
299 tracers.detach()
337 tracers.attach()
804 tracers.detach()
843 tracers.attach()
1482 cls.tracers = configdialog.VarTrace()
[all …]
/aosp_15_r20/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/internal/
H A DBinderClientTransportTest.java69 private static final ClientStreamTracer[] tracers = new ClientStreamTracer[] { field in BinderClientTransportTest
172 methodDesc, new Metadata(), CallOptions.DEFAULT, tracers); in testShutdownBeforeStreamStart_b153326034()
184 transport.newStream(streamingMethodDesc, new Metadata(), CallOptions.DEFAULT, tracers); in testRequestWhileStreamIsWaitingOnCall_b154088869()
204 transport.newStream(streamingMethodDesc, new Metadata(), CallOptions.DEFAULT, tracers); in testTransactionForDiscardedCall_b155244043()
224 transport.newStream(streamingMethodDesc, new Metadata(), CallOptions.DEFAULT, tracers); in testBadTransactionStreamThroughput_b163053382()
245 transport.newStream(methodDesc, new Metadata(), CallOptions.DEFAULT, tracers); in testMessageProducerClosedAfterStream_b169313545()
269 transport.newStream(streamingMethodDesc, new Metadata(), CallOptions.DEFAULT, tracers); in testNewStreamBeforeTransportReadyFails()
/aosp_15_r20/external/cronet/base/debug/
H A Dstack_trace_perftest.cc62 std::vector<std::unique_ptr<StackTracer>> tracers; in MultiObjTest() local
64 tracers.push_back(std::make_unique<StackTracer>(trace_count)); in MultiObjTest()
66 std::vector<std::unique_ptr<StackTracer>>::iterator it = tracers.begin(); in MultiObjTest()
70 if (++it == tracers.end()) in MultiObjTest()
71 it = tracers.begin(); in MultiObjTest()
/aosp_15_r20/external/libtracefs/Documentation/
H A Dlibtracefs-tracer.txt26 custom kernels that contain tracers that are not yet identified by the
51 Tracers the latency of interrupts disabled.
54 Tracers the latency of preemption disabled (the time in the kernel that
84 Note that the above tracers may not be available in the kernel and
102 *ENOENT* Tracers are not supported on the running kernel.
/aosp_15_r20/external/grpc-grpc/doc/
H A Denvironment_variables.md44 A comma separated list of tracers that provide additional insight into how
45 gRPC C core is processing requests via debug logs. Available tracers include:
107 The following tracers will only run in binaries built in DEBUG mode. This is
134 'refcount' will turn on all of the tracers for refcount debugging.
136 if 'list_tracers' is present, then all of the available tracers will be
/aosp_15_r20/external/trace-cmd/utest/
H A Dtracefs-utest.c391 char **tracers; in test_tracers() local
399 tracers = tracefs_tracers(tdir); in test_tracers()
400 CU_TEST(tracers != NULL); in test_tracers()
406 exclude_string(tracers, tracer); in test_tracers()
410 for (i = 0; tracers[i]; i++) in test_tracers()
411 CU_TEST(tracers[i][0] == '/'); in test_tracers()
413 tracefs_list_free(tracers); in test_tracers()
/aosp_15_r20/external/trace-cmd/Documentation/trace-cmd/
H A Dtrace-cmd-set.1.txt22 Specify a tracer. Tracers usually do more than just trace an event.
23 Common tracers are: *function*, *function_graph*, *preemptirqsoff*,
25 running kernel. To see a list of available tracers, see trace-cmd-list(1).
110 This will limit the 'function' and 'function_graph' tracers to only trace
129 latency tracers. This option prevents the function tracer from being
140 outside of ftrace tracers (stack_tracer, perf, etc).
/aosp_15_r20/external/grpc-grpc/src/core/lib/channel/
H A Dcall_tracer.h85 // `DelegatingServerCallTracer` are the only delegating call tracers.
214 // Convenience functions to add call tracers to a call context. Allows setting
215 // multiple call tracers to a single call. It is only valid to add client call
216 // tracers before the client_channel filter sees the send_initial_metadata op.
220 // TODO(yashykt): We want server call tracers to be registered through the
/aosp_15_r20/external/libtracefs/src/
H A Dtracefs-utils.c608 char **tracers = NULL; in tracefs_tracer_available() local
611 tracers = tracefs_tracers(tracing_dir); in tracefs_tracer_available()
612 if (!tracers) in tracefs_tracer_available()
615 for (i = 0; tracers[i]; i++) { in tracefs_tracer_available()
616 if (strcmp(tracer, tracers[i]) == 0) { in tracefs_tracer_available()
622 tracefs_list_free(tracers); in tracefs_tracer_available()

123456789