28 instantiations of Activity
Microsoft.AspNetCore.Diagnostics (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
70activity = new Activity(activityName);
Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
70activity = new Activity(activityName);
Microsoft.AspNetCore.Hosting (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
70activity = new Activity(activityName);
Microsoft.AspNetCore.Http.Connections.Tests (1)
HttpConnectionDispatcherTests.cs (1)
3123var activityFeature = new TestActivityFeature(new Activity("name"));
Microsoft.AspNetCore.Mvc.Core.TestCommon (1)
ActivityReplacer.cs (1)
14_activity = new Activity("Test");
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1113activity = new Activity(ActivityName);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (3)
HubConnectionTests.Tracing.cs (3)
77clientParentActivity1 = new Activity("ClientActivity1"); 99clientParentActivity2 = new Activity("ClientActivity2"); 260clientParentActivity = new Activity("ClientActivity");
Microsoft.AspNetCore.SignalR.Core (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
70activity = new Activity(activityName);
Microsoft.AspNetCore.SignalR.Tests (8)
HubConnectionHandlerTests.Activity.cs (8)
44var mockHttpRequestActivity = new Activity("HttpRequest"); 119var mockHttpRequestActivity = new Activity("HttpRequest"); 188var mockHttpRequestActivity = new Activity("HttpRequest"); 247var mockHttpRequestActivity = new Activity("HttpRequest"); 320var mockHttpRequestActivity = new Activity("HttpRequest"); 367var mockHttpRequestActivity = new Activity("HttpRequest"); 419var mockHttpRequestActivity = new Activity("HttpRequest"); 470var mockHttpRequestActivity = new Activity("HttpRequest");
Microsoft.Extensions.Telemetry.Tests (9)
Logging\ExtendedLoggerFactoryTests.cs (7)
206using Activity activity = new Activity("ScopeActivity"); 216using Activity b = new Activity("ScopeActivity"); 256using Activity activity = new Activity("ScopeActivity"); 289using Activity activity = new Activity("ScopeActivity"); 318using Activity activity = new Activity("ScopeActivity"); 346using Activity activity = new Activity("ScopeActivity"); 420using Activity activity = new Activity("ScopeActivity");
Sampling\TraceBasedSamplerTests.cs (2)
42using var activity = new Activity("my activity"); 63using var activity = new Activity("my activity");
System.Diagnostics.DiagnosticSource (1)
System\Diagnostics\Activity.cs (1)
1179Activity activity = new Activity(name);
632 references to Activity
aspire (49)
Backchannel\AppHostBackchannel.cs (10)
35using var activity = telemetry.ActivitySource.StartActivity(); 54using var activity = telemetry.ActivitySource.StartActivity(); 67using var activity = telemetry.ActivitySource.StartActivity(); 82using var activity = telemetry.ActivitySource.StartActivity(); 102using var activity = telemetry.ActivitySource.StartActivity(); 124using var activity = telemetry.ActivitySource.StartActivity(); 168using var activity = telemetry.ActivitySource.StartActivity(); 188using var activity = telemetry.ActivitySource.StartActivity(); 203using var activity = telemetry.ActivitySource.StartActivity(); 216using var activity = telemetry.ActivitySource.StartActivity();
Backchannel\ExtensionBackchannel.cs (17)
58using var activity = _activitySource.StartActivity(); 146using var activity = _activitySource.StartActivity(); 239using var activity = _activitySource.StartActivity(); 255using var activity = _activitySource.StartActivity(); 271using var activity = _activitySource.StartActivity(); 287using var activity = _activitySource.StartActivity(); 303using var activity = _activitySource.StartActivity(); 319using var activity = _activitySource.StartActivity(); 336using var activity = _activitySource.StartActivity(); 352using var activity = _activitySource.StartActivity(); 368using var activity = _activitySource.StartActivity(); 390using var activity = _activitySource.StartActivity(); 411using var activity = _activitySource.StartActivity(); 432using var activity = _activitySource.StartActivity(); 452using var activity = _activitySource.StartActivity(); 470using var activity = _activitySource.StartActivity(); 491using var activity = _activitySource.StartActivity();
Certificates\CertificateService.cs (1)
23using var activity = telemetry.ActivitySource.StartActivity(nameof(EnsureCertificatesTrustedAsync), ActivityKind.Client);
Commands\AddCommand.cs (1)
64using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\ExecCommand.cs (1)
80using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\NewCommand.cs (1)
101using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\PublishCommandBase.cs (1)
86using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\RunCommand.cs (1)
79using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
DotNetCliRunner.cs (12)
54using var activity = telemetry.ActivitySource.StartActivity(); 137using var activity = telemetry.ActivitySource.StartActivity(); 191using var activity = telemetry.ActivitySource.StartActivity(); 228using var activity = telemetry.ActivitySource.StartActivity(); 242using var activity = telemetry.ActivitySource.StartActivity(); 256using var activity = telemetry.ActivitySource.StartActivity(nameof(InstallTemplateAsync), ActivityKind.Client); 367using var activity = telemetry.ActivitySource.StartActivity(); 396using var activity = telemetry.ActivitySource.StartActivity(); 515using var activity = telemetry.ActivitySource.StartActivity(); 589using var activity = telemetry.ActivitySource.StartActivity(); 609using var activity = telemetry.ActivitySource.StartActivity(); 653using var activity = telemetry.ActivitySource.StartActivity();
NuGet\NuGetPackageCache.cs (1)
60using var activity = telemetry.ActivitySource.StartActivity();
Program.cs (1)
180using var activity = telemetry.ActivitySource.StartActivity();
Projects\ProjectLocator.cs (1)
25using var activity = telemetry.ActivitySource.StartActivity();
Utils\AppHostHelper.cs (1)
54using var activity = telemetry.ActivitySource.StartActivity(nameof(GetAppHostInformationAsync), ActivityKind.Client);
Aspire.Components.Common.TestUtilities (11)
ActivityNotifier.cs (9)
14public sealed class ActivityNotifier : BaseProcessor<Activity> 16private readonly Channel<Activity> _activityChannel = Channel.CreateUnbounded<Activity>(); 18public async Task<List<Activity>> TakeAsync(int count, TimeSpan timeout) 20var activityList = new List<Activity>(); 22await foreach (var activity in WaitAsync(cts.Token)) 34public override void OnEnd(Activity data) 39private async IAsyncEnumerable<Activity> WaitAsync([EnumeratorCancellation] CancellationToken cancellationToken) 41await foreach (var activity in _activityChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
ConformanceTests.cs (2)
73/// Do anything that is going to trigger the <see cref="Activity"/> and <see cref="ILogger"/> creation. Example: try to create a DB. 442List<Activity> exportedActivities = new();
Aspire.Confluent.Kafka (15)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (3)
327using Activity? activity = this.StartReceiveActivity(propagationContext, startTime, consumeResult.TopicPartitionOffset, consumeResult.Key); 350private Activity? StartReceiveActivity(PropagationContext propagationContext, DateTimeOffset start, TopicPartitionOffset? topicPartitionOffset, object? key) 360Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, startTime: start, parentContext: default);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (7)
46using Activity? activity = this.StartPublishActivity(start, topic, message); 93using Activity? activity = this.StartPublishActivity(start, topicPartition.Topic, message, topicPartition.Partition); 137using Activity? activity = this.StartPublishActivity(start, topic, message); 178using Activity? activity = this.StartPublishActivity(start, topicPartition.Topic, message, topicPartition.Partition); 325private Activity? StartPublishActivity(DateTimeOffset start, string topic, Message<TKey, TValue> message, int? partition = null) 333var activity = ConfluentKafkaCommon.ActivitySource.StartActivity(name: spanName, kind: ActivityKind.Producer, startTime: start); 360private void InjectActivity(Activity? activity, Message<TKey, TValue> message)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeAndProcessMessageHandler.cs (2)
12/// <param name="activity">The <see cref="Activity"/>.</param> 19Activity? activity,
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (3)
108Activity? processActivity = null; 148private static Activity? StartProcessActivity<TKey>(PropagationContext propagationContext, TopicPartitionOffset? topicPartitionOffset, TKey? key, string clientId, string groupId) 158Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, parentContext: default);
Aspire.Confluent.Kafka.Tests (1)
OtelTracesTests.cs (1)
34List<Activity> activities = new();
Aspire.Dashboard (1)
Components\Pages\Error.razor.cs (1)
24RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
Aspire.Microsoft.Data.SqlClient (9)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (2)
49var activity = Activity.Current;
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\DiagnosticSourceListener.cs (1)
35if (!this.handler.SupportsNullActivity && Activity.Current == null)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\ListenerHandler.cs (1)
28/// Gets a value indicating whether the <see cref="ListenerHandler"/> supports NULL <see cref="Activity"/>.
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\SqlClientTraceInstrumentationOptions.cs (5)
120/// Gets or sets an action to enrich an <see cref="Activity"/> with the 128/// <item>The <see cref="Activity"/> being enriched.</item> 133/// cref="Activity"/>.</item> 136public Action<Activity, string, object> Enrich { get; set; } 257internal void AddConnectionLevelDetailsToActivity(string dataSource, Activity sqlActivity)
Aspire.Microsoft.EntityFrameworkCore.SqlServer (9)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (2)
49var activity = Activity.Current;
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\DiagnosticSourceListener.cs (1)
35if (!this.handler.SupportsNullActivity && Activity.Current == null)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\ListenerHandler.cs (1)
28/// Gets a value indicating whether the <see cref="ListenerHandler"/> supports NULL <see cref="Activity"/>.
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\SqlClientTraceInstrumentationOptions.cs (5)
120/// Gets or sets an action to enrich an <see cref="Activity"/> with the 128/// <item>The <see cref="Activity"/> being enriched.</item> 133/// cref="Activity"/>.</item> 136public Action<Activity, string, object> Enrich { get; set; } 257internal void AddConnectionLevelDetailsToActivity(string dataSource, Activity sqlActivity)
Aspire.NATS.Net.Tests (1)
AspireNatsClientExtensionsTests.cs (1)
230var activity = activityList[0];
Aspire.Oracle.EntityFrameworkCore.Tests (1)
ConformanceTests.cs (1)
150List<Activity> exportedActivities = new();
Aspire.RabbitMQ.Client (4)
src\Components\Aspire.RabbitMQ.Client\AspireRabbitMQExtensions.cs (4)
193using var activity = s_activitySource.StartActivity("rabbitmq connect", ActivityKind.Client); 215using var connectAttemptActivity = s_activitySource.StartActivity("rabbitmq connect attempt", ActivityKind.Client); 231private static void AddRabbitMQTags(Activity? activity, Uri address, string? operation = null) 247private static void AddRabbitMQExceptionTags(Activity? connectAttemptActivity, Exception ex)
Aspire.StackExchange.Redis (11)
src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\Implementation\RedisProfilerEntryToActivityConverter.cs (4)
76public static Activity? ProfilerCommandToActivity(Activity? parentActivity, IProfiledCommand command, StackExchangeRedisInstrumentationOptions options) 84var activity = StackExchangeRedisConnectionInstrumentation.ActivitySource.StartActivity( 182public static void DrainSession(Activity? parentActivity, IEnumerable<IProfiledCommand> sessionCommands, StackExchangeRedisInstrumentationOptions options)
src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\StackExchangeRedisConnectionInstrumentation.cs (4)
30internal readonly ConcurrentDictionary<(ActivityTraceId TraceId, ActivitySpanId SpanId), (Activity Activity, ProfilingSession Session)> Cache 77var parent = Activity.Current; 114var parent = entry.Value.Activity;
src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\StackExchangeRedisInstrumentationOptions.cs (3)
16/// Gets or sets the maximum time that should elapse between flushing the internal buffer of Redis profiling sessions and creating <see cref="Activity"/> objects. Default value: 00:00:10. 29/// <para><see cref="Activity"/>: the activity being enriched.</para> 32public Action<Activity, IProfiledCommand>? Enrich { get; set; }
Aspire.StackExchange.Redis.Tests (1)
AspireRedisExtensionsTests.cs (1)
294var activity = activityList[0];
CatalogDb (1)
CatalogDbInitializer.cs (1)
18using var activity = _activitySource.StartActivity("Initializing catalog database", ActivityKind.Client);
ClaimsTransformation (1)
Controllers\HomeController.cs (1)
26return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
Cookies (1)
Controllers\HomeController.cs (1)
26return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
DatabaseMigration.MigrationService (1)
ApiDbInitializer.cs (1)
22using var activity = s_activitySource.StartActivity("Migrating database", ActivityKind.Client);
DynamicSchemes (1)
Pages\Error.cshtml.cs (1)
21RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
HostedBlazorWebassemblyApp.Server (1)
Pages\Error.cshtml.cs (1)
32RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
Identity.DefaultUI.WebSite (1)
Pages\Error.cshtml.cs (1)
19RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
Identity.ExternalClaims (1)
Pages\Error.cshtml.cs (1)
21RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
Microsoft.AspNetCore.Components (14)
ComponentsActivitySource.cs (13)
28var activity = ActivitySource.CreateActivity(OnRouteName, ActivityKind.Internal, parentId: null, null, null); 31var httpActivity = Activity.Current; 33Activity.Current = null; // do not inherit the parent activity 64var activity = ActivitySource.CreateActivity(OnEventName, ActivityKind.Internal, parentId: null, null, null); 68var previousActivity = Activity.Current; 70Activity.Current = null; // do not inherit the parent activity 114var activity = activityHandle.Activity; 128if (Activity.Current == null && activityHandle.Previous != null && !activityHandle.Previous.IsStopped) 130Activity.Current = activityHandle.Previous; 141public Activity? Previous; 142public Activity? Activity;
src\Shared\Components\ComponentsActivityLinkStore.cs (1)
44public void AddActivityContexts(string exceptCategory, Activity targetActivity)
Microsoft.AspNetCore.Components.Endpoints (1)
src\Shared\Components\ComponentsActivityLinkStore.cs (1)
44public void AddActivityContexts(string exceptCategory, Activity targetActivity)
Microsoft.AspNetCore.Components.Server (10)
Circuits\CircuitActivitySource.cs (9)
25var activity = ActivitySource.CreateActivity(OnCircuitName, ActivityKind.Internal, parentId: null, null, null); 28var signalRActivity = Activity.Current; 30Activity.Current = null; // do not inherit the parent activity 61var activity = activityHandle.Activity; 75if (Activity.Current == null && activityHandle.Previous != null && !activityHandle.Previous.IsStopped) 77Activity.Current = activityHandle.Previous; 88public Activity? Previous; 89public Activity? Activity;
src\Shared\Components\ComponentsActivityLinkStore.cs (1)
44public void AddActivityContexts(string exceptCategory, Activity targetActivity)
Microsoft.AspNetCore.Components.Server.Tests (5)
Circuits\CircuitActivitySourceTest.cs (5)
21private readonly List<Activity> _activities; 25_activities = new List<Activity>(); 48var activity = activityHandle.Activity; 75var activity = activityHandle.Activity; 97var activity = activityHandle.Activity;
Microsoft.AspNetCore.Components.Tests (9)
ComponentsActivitySourceTest.cs (9)
12private readonly List<Activity> _activities; 16_activities = new List<Activity>(); 54var activity = activityHandle.Activity; 90var activity = activityHandle.Activity; 117var activity = activityHandle.Activity; 137var activity = activityHandle.Activity; 156var activity = activityHandle.Activity; 179var activity = activityHandle.Activity; 196var activity = activityHandle.Activity;
Microsoft.AspNetCore.Diagnostics (2)
src\Shared\Diagnostics\ActivityCreator.cs (2)
13public static Activity? CreateFromRemote( 24Activity? activity = null;
Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore (2)
src\Shared\Diagnostics\ActivityCreator.cs (2)
13public static Activity? CreateFromRemote( 24Activity? activity = null;
Microsoft.AspNetCore.Hosting (12)
Internal\HostingApplication.cs (1)
125public Activity? Activity
Internal\HostingApplicationDiagnostics.cs (7)
213var activity = context.Activity; 388private Activity? StartActivity(HttpContext httpContext, bool loggingEnabled, bool diagnosticListenerActivityCreationEnabled, out bool hasDiagnosticListener) 393var activity = ActivityCreator.CreateFromRemote( 429private void StopActivity(HttpContext httpContext, Activity activity, bool hasDiagnosticListener) 457private Activity StartActivity(Activity activity, HttpContext httpContext) 471private void StopActivity(Activity activity, HttpContext httpContext)
Internal\HttpActivityFeature.cs (2)
14internal HttpActivityFeature(Activity activity) 20public Activity Activity { get; set; }
src\Shared\Diagnostics\ActivityCreator.cs (2)
13public static Activity? CreateFromRemote( 24Activity? activity = null;
Microsoft.AspNetCore.Hosting.Tests (54)
HostingApplicationDiagnosticsTests.cs (47)
176Activity measurementActivity = null; 205measurementActivity = Activity.Current; 491Assert.Null(Activity.Current); 531Assert.Null(Activity.Current); 562Assert.Null(Activity.Current); 599Assert.NotNull(Activity.Current); 619Assert.NotNull(Activity.Current); 620Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 626Assert.NotNull(Activity.Current); 643Assert.NotNull(Activity.Current); 644Assert.True(Activity.Current.Duration > TimeSpan.Zero); 645Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 667Assert.NotNull(Activity.Current); 668Assert.True(Activity.Current.Duration > TimeSpan.Zero); 669Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 691Assert.NotNull(Activity.Current); 692Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 719Assert.NotNull(Activity.Current); 720Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 748Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 749Assert.Null(Activity.Current.ParentId); 750Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 751Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 778Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 779Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 780Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 808Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 809Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 810Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 839Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 840Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value3"); 841Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value4"); 869Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 878Assert.Equal(expectedBaggage, Activity.Current.Baggage.ToArray()); 906Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 907Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1/1"); 936Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 937Assert.Equal(ActivityIdFormat.W3C, Activity.Current.IdFormat); 938Assert.Equal("0123456789abcdef0123456789abcdef", Activity.Current.TraceId.ToHexString()); 939Assert.Equal("0123456789abcdef", Activity.Current.ParentSpanId.ToHexString()); 940Assert.Equal("tracestate=1", Activity.Current.TraceStateString); 942Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 943Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 1003Assert.Null(Activity.Current); 1014Assert.NotNull(Activity.Current); 1015Assert.True(Activity.Current.Recorded); 1030parentSpanId = Activity.Current.ParentSpanId.ToHexString();
HostingApplicationTests.cs (7)
113var initialActivity = Activity.Current; 116using var dummyActivity = dummySource.StartActivity("DummyActivity"); 118Assert.Equal(Activity.Current, dummyActivity); 122Assert.Equal(activityFeature.Activity.Id, Activity.Current.ParentId); 123Assert.NotEqual(Activity.Current, activityFeature.Activity); 131public Activity Activity { get; set; }
Microsoft.AspNetCore.Http (1)
Features\IHttpActivityFeature.cs (1)
16Activity Activity { get; set; }
Microsoft.AspNetCore.Http.Connections.Tests (3)
HttpConnectionDispatcherTests.cs (3)
3095public TestActivityFeature(Activity activity) 3100public Activity Activity { get; set; } 3129Assert.Equal("true", Activity.Current.GetTagItem("http.long_running"));
Microsoft.AspNetCore.Http.Extensions (1)
DefaultProblemDetailsWriter.cs (1)
58var traceId = Activity.Current?.Id ?? httpContext.TraceIdentifier;
Microsoft.AspNetCore.Http.Extensions.Tests (15)
ProblemDetailsDefaultWriterTest.cs (15)
29var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 66var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 98var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 132var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 174var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 214var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 251var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 294var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 337var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 380var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 423var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 464var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 511var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 552var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier; 718var expectedTraceId = Activity.Current?.Id ?? context.TraceIdentifier;
Microsoft.AspNetCore.Identity.UI (2)
Areas\Identity\Pages\V4\Error.cshtml.cs (1)
37RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
Areas\Identity\Pages\V5\Error.cshtml.cs (1)
37RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
Microsoft.AspNetCore.Mvc.Core (1)
Infrastructure\DefaultProblemDetailsFactory.cs (1)
105var traceId = Activity.Current?.Id ?? httpContext?.TraceIdentifier;
Microsoft.AspNetCore.Mvc.Core.Test (2)
DependencyInjection\ApiBehaviorOptionsSetupTest.cs (1)
110Assert.Equal(Activity.Current.Id, problemDetails.Extensions["traceId"]);
Infrastructure\ProblemDetalsClientErrorFactoryTest.cs (1)
91Assert.Equal(Activity.Current.Id, problemDetails.Extensions["traceId"]);
Microsoft.AspNetCore.Mvc.Core.TestCommon (2)
ActivityReplacer.cs (2)
10private readonly Activity _activity; 20Debug.Assert(Activity.Current == _activity);
Microsoft.AspNetCore.Mvc.FunctionalTests (1)
XmlSerializerFormattersWrappingTest.cs (1)
211$"<traceId>{Activity.Current.Id}</traceId>" +
Microsoft.AspNetCore.SignalR.Client.Core (13)
HubConnection.cs (7)
1021private async Task<(ConnectionState, Activity?)> WaitForActiveConnectionWithActivityAsync(string sendingMethodName, string invokedMethodName, CancellationToken token) 1025var activity = CreateActivity(invokedMethodName); 1069static void SetServerTags(Activity? activity, Uri? uri) 1108private Activity? CreateActivity(string methodName) 1110var activity = _activitySource.CreateActivity(ActivityName, ActivityKind.Client); 1111if (activity is null && Activity.Current is not null && _logger.IsEnabled(LogLevel.Critical)) 1195private static void InjectHeaders(Activity currentActivity, HubInvocationMessage invocationMessage)
Internal\InvocationRequest.cs (6)
26public Activity? Activity { get; } 28protected InvocationRequest(CancellationToken cancellationToken, Type resultType, string invocationId, ILogger logger, HubConnection hubConnection, Activity? activity) 48public static InvocationRequest Invoke(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out Task<object?> result) 56ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out ChannelReader<object?> result) 83public Streaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity) 171public NonStreaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity)
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (26)
HubConnectionTests.Tracing.cs (26)
35var serverChannel = Channel.CreateUnbounded<Activity>(); 36var clientChannel = Channel.CreateUnbounded<Activity>(); 66Activity clientParentActivity1 = null; 67Activity clientActivity1 = null; 68Activity clientParentActivity2 = null; 69Activity clientActivity2 = null; 86Assert.Equal(clientParentActivity1, Activity.Current); 108Assert.Equal(clientParentActivity2, Activity.Current); 229var serverChannel = Channel.CreateUnbounded<Activity>(); 230var clientActivityTcs = new TaskCompletionSource<Activity>(); 231Activity clientActivity = null; 255Activity clientParentActivity = null; 280Assert.Equal(clientParentActivity, Activity.Current); 374var serverChannel = Channel.CreateUnbounded<Activity>(); 375var clientActivityTcs = new TaskCompletionSource<Activity>(); 440var clientActivity = await clientActivityTcs.Task.DefaultTimeout(); 477var serverChannel = Channel.CreateUnbounded<Activity>(); 478var clientActivityTcs = new TaskCompletionSource<Activity>(); 537var clientActivity = await clientActivityTcs.Task.DefaultTimeout(); 573var serverChannel = Channel.CreateUnbounded<Activity>(); 574var clientActivityTcs = new TaskCompletionSource<Activity>(); 632var clientActivity = await clientActivityTcs.Task.DefaultTimeout(); 663var serverChannel = Channel.CreateUnbounded<Activity>(); 664var clientActivityTcs = new TaskCompletionSource<Activity>(); 704Assert.Null(Activity.Current); 731var clientActivity = await clientActivityTcs.Task.DefaultTimeout();
Microsoft.AspNetCore.SignalR.Client.Tests (6)
HubConnectionTests.Tracing.cs (6)
25Activity clientActivity = null; 62Activity clientActivity = null; 100Activity clientActivity = null; 134Activity clientActivity = null; 172var clientActivityTcs = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); ; 196var clientActivity = await clientActivityTcs.Task.DefaultTimeout();
Microsoft.AspNetCore.SignalR.Core (22)
HubConnectionContext.cs (1)
62internal Activity? OriginalActivity { get; set; }
HubConnectionHandler.cs (1)
136OriginalActivity = Activity.Current,
Internal\DefaultHubDispatcher.cs (18)
89Activity? activity = null; 125Activity? activity = null; 399var previousActivity = Activity.Current; 402Activity.Current = null; 407var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger); 428if (Activity.Current != previousActivity) 430Activity.Current = previousActivity; 519var previousActivity = Activity.Current; 522Activity.Current = null; 525var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger); 592if (Activity.Current != previousActivity) 594Activity.Current = previousActivity; 832private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger) 857Activity? activity; 892private static void SetActivityError(Activity? activity, Exception ex)
src\Shared\Diagnostics\ActivityCreator.cs (2)
13public static Activity? CreateFromRemote( 24Activity? activity = null;
Microsoft.AspNetCore.SignalR.Tests (48)
HubConnectionHandlerTests.Activity.cs (47)
22var serverChannel = Channel.CreateUnbounded<Activity>(); 44var mockHttpRequestActivity = new Activity("HttpRequest"); 46Activity.Current = mockHttpRequestActivity; 54var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 63var invocation1Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 69var invocation2Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 75var invocation3Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 78var userCodeActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 87var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 97var serverChannel = Channel.CreateUnbounded<Activity>(); 119var mockHttpRequestActivity = new Activity("HttpRequest"); 121Activity.Current = mockHttpRequestActivity; 129var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 145var invocationActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 159var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 169var serverChannel = Channel.CreateUnbounded<Activity>(); 188var mockHttpRequestActivity = new Activity("HttpRequest"); 190Activity.Current = mockHttpRequestActivity; 200var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 205var invocation1Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 210var invocation2Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 218var disconnectedActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 228var serverChannel = Channel.CreateUnbounded<Activity>(); 247var mockHttpRequestActivity = new Activity("HttpRequest"); 249Activity.Current = mockHttpRequestActivity; 259var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 271var invocationActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 285var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 301var serverChannel = Channel.CreateUnbounded<Activity>(); 320var mockHttpRequestActivity = new Activity("HttpRequest"); 322Activity.Current = mockHttpRequestActivity; 330var activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 348var serverChannel = Channel.CreateUnbounded<Activity>(); 367var mockHttpRequestActivity = new Activity("HttpRequest"); 369Activity.Current = mockHttpRequestActivity; 383var activity = activities[1]; 400var serverChannel = Channel.CreateUnbounded<Activity>(); 419var mockHttpRequestActivity = new Activity("HttpRequest"); 421Activity.Current = mockHttpRequestActivity; 433var activity = activities[1]; 451var serverChannel = Channel.CreateUnbounded<Activity>(); 470var mockHttpRequestActivity = new Activity("HttpRequest"); 472Activity.Current = mockHttpRequestActivity; 484var activity = activities[1]; 491private static void AssertHubMethodActivity<THub>(Activity activity, Activity parent, string methodName, Activity linkedActivity, Type exceptionType = null, string activityName = null)
HubConnectionHandlerTestUtils\Hubs.cs (1)
376var activity = testActivitySource.ActivitySource.StartActivity("inner", ActivityKind.Server);
Microsoft.Build.Framework (14)
Telemetry\ActivityExtensions.cs (9)
13/// Extension methods for <see cref="Activity"/>. usage in VS OpenTelemetry. 20public static Activity WithTags(this Activity activity, IActivityTelemetryDataHolder? dataHolder) 32public static Activity WithTags(this Activity activity, IList<TelemetryItem> tags) 43public static Activity WithTag(this Activity activity, TelemetryItem item) 53public static Activity WithStartTime(this Activity activity, DateTime? startTime)
Telemetry\IActivityTelemetryDataHolder.cs (1)
10/// Interface for classes that hold telemetry data that should be added as tags to an <see cref="Activity"/>.
Telemetry\MSBuildActivitySource.cs (4)
26public Activity? StartActivity(string name) 28var activity = Activity.Current?.HasRemoteParent == true 29? _source.StartActivity($"{TelemetryConstants.EventPrefix}{name}", ActivityKind.Internal, parentId: Activity.Current.ParentId)
Microsoft.Extensions.AI (16)
ChatCompletion\FunctionInvokingChatClient.cs (6)
225using Activity? activity = _activitySource?.StartActivity($"{nameof(FunctionInvokingChatClient)}.{nameof(GetResponseAsync)}"); 320using Activity? activity = _activitySource?.StartActivity($"{nameof(FunctionInvokingChatClient)}.{nameof(GetStreamingResponseAsync)}"); 365Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 413Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 428private static void AddUsageTags(Activity? activity, UsageDetails? usage) 806using Activity? activity = _activitySource?.StartActivity(
ChatCompletion\OpenTelemetryChatClient.cs (6)
138using Activity? activity = CreateAndConfigureActivity(options); 169using Activity? activity = CreateAndConfigureActivity(options); 211Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 223private Activity? CreateAndConfigureActivity(ChatOptions? options) 225Activity? activity = null; 333Activity? activity,
Embeddings\OpenTelemetryEmbeddingGenerator.cs (4)
113using Activity? activity = CreateAndConfigureActivity(options); 149private Activity? CreateAndConfigureActivity(EmbeddingGenerationOptions? options) 151Activity? activity = null; 203Activity? activity,
Microsoft.Extensions.AI.Integration.Tests (10)
ChatClientIntegrationTests.cs (8)
219var activities = new List<Activity>(); 286var activities = new List<Activity>(); 318var activities = new List<Activity>(); 350var activities = new List<Activity>(); 377private static void AssertUsageAgainstActivities(ChatResponse response, List<Activity> activities) 407var activities = new List<Activity>(); 931var activities = new List<Activity>(); 943var activity = Assert.Single(activities);
EmbeddingGeneratorIntegrationTests.cs (2)
111var activities = new List<Activity>(); 125var activity = activities.Single();
Microsoft.Extensions.AI.Tests (5)
ChatCompletion\FunctionInvokingChatClientTests.cs (1)
614var activities = new List<Activity>();
ChatCompletion\OpenTelemetryChatClientTests.cs (2)
27var activities = new List<Activity>(); 149var activity = Assert.Single(activities);
Embeddings\OpenTelemetryEmbeddingGeneratorTests.cs (2)
25var activities = new List<Activity>(); 75var activity = Assert.Single(activities);
Microsoft.Extensions.Logging (7)
LoggerFactoryScopeProvider.cs (7)
37Activity? activity = Activity.Current; 78private static ActivityBaggageLogScopeWrapper GetOrCreateActivityBaggageLogScopeWrapper(Activity activity, IEnumerable<KeyValuePair<string, string?>> items) 137public ActivityLogScope(Activity activity, ActivityTrackingOptions activityTrackingOption) 291public static string GetSpanId(this Activity activity) 301public static string GetTraceId(this Activity activity) 311public static string GetParentId(this Activity activity)
Microsoft.Extensions.Logging.EventSource (2)
EventSourceLogger.cs (2)
75Activity? activity = Activity.Current;
Microsoft.Extensions.ServiceDiscovery.Dns (1)
Resolver\DnsResolver.Telemetry.cs (1)
59private readonly Activity? _activity; // null if activity is not started
Microsoft.Extensions.Telemetry (9)
Logging\Import\LoggerFactoryScopeProvider.cs (7)
56Activity? activity = Activity.Current; 97private static ActivityBaggageLogScopeWrapper GetOrCreateActivityBaggageLogScopeWrapper(Activity activity, IEnumerable<KeyValuePair<string, string?>> items) 156public ActivityLogScope(Activity activity, ActivityTrackingOptions activityTrackingOption) 309public static string GetSpanId(this Activity activity) 319public static string GetTraceId(this Activity activity) 329public static string GetParentId(this Activity activity)
Sampling\SamplingLoggerBuilderExtensions.cs (1)
26/// <remarks>Sampling decisions for logs match exactly the sampling decisions for the underlying <see cref="System.Diagnostics.Activity"/>.
Sampling\TraceBasedSampler.cs (1)
13Activity.Current?.Recorded ?? true;
Microsoft.Extensions.Telemetry.Tests (14)
Logging\ExtendedLoggerFactoryTests.cs (12)
129Activity activity = Activity.Current!; 206using Activity activity = new Activity("ScopeActivity"); 216using Activity b = new Activity("ScopeActivity"); 256using Activity activity = new Activity("ScopeActivity"); 289using Activity activity = new Activity("ScopeActivity"); 318using Activity activity = new Activity("ScopeActivity"); 346using Activity activity = new Activity("ScopeActivity"); 420using Activity activity = new Activity("ScopeActivity"); 658public static string GetSpanId(this Activity activity) 670public static string GetTraceId(this Activity activity) 682public static string GetParentId(this Activity activity)
Sampling\TraceBasedSamplerTests.cs (2)
42using var activity = new Activity("my activity"); 63using var activity = new Activity("my activity");
MvcFormSample (1)
Controllers\HomeController.cs (1)
48return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
OrderProcessor (2)
OrderProcessingWorker.cs (2)
68Activity.Current?.AddTag("order-id", order.Id); 69Activity.Current?.AddTag("product-count", order.Items.Count);
PathSchemeSelection (1)
Controllers\HomeController.cs (1)
26return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
Seq.ApiService (1)
Program.cs (1)
23using var activity = source.StartActivity("Chose {Number}");
StaticFilesAuth (1)
Controllers\HomeController.cs (1)
24return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
Stress.ApiService (29)
ProducerConsumer.cs (5)
12public required Activity? Producer { get; init; } 28using var appActivity = s_activitySource.StartActivity("ConsumerApp", ActivityKind.Internal); 38using var activity = s_activitySource.StartActivity($"Consume {item.Id}", ActivityKind.Consumer, parentId: null, links: links); 44using var appActivity = s_activitySource.StartActivity("ProducerApp", ActivityKind.Internal); 51using (var activity = s_activitySource.StartActivity($"Produce {id}", ActivityKind.Producer))
Program.cs (13)
97var current = Activity.Current; 98Activity.Current = null; 112Activity.Current = current; 269var span1 = traceCreator.CreateActivity("Test 1", "0485b1947fe788bb"); 272var span2 = traceCreator.CreateActivity("Test 2", "0485b1947fe788bb"); 282var current = Activity.Current; 283Activity.Current = null; 290Activity.Current = current; 311using var activity = source.StartActivity("ValidateAndUpdateCacheService.ExecuteAsync"); 314using var innerActivity = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 333using var innerActivity2 = source.StartActivity("ValidateAndUpdateCacheService.activeUser",
TraceCreator.cs (11)
17private readonly List<Activity> _allActivities = new List<Activity>(); 19public Activity? CreateActivity(string name, string? spandId) 21var activity = s_activitySource.StartActivity(name, ActivityKind.Client); 27typeof(Activity).GetField("_spanId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, spandId); 28typeof(Activity).GetField("_traceId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, activity.TraceId.ToString()); 37var activityStack = new Stack<Activity>(); 47using var activity = s_activitySource.StartActivity(rootName ?? name, ActivityKind.Client); 75using var activity = s_activitySource.StartActivity(ActivityKind.Client, name: name, links: links.DistinctBy(l => l.Context.SpanId)); 93private static void AddEvents(Activity activity) 128var a = _allActivities[Random.Shared.Next(0, _allActivities.Count)];
System.Diagnostics.DiagnosticSource (146)
System\Diagnostics\Activity.cs (43)
18/// Carries the <see cref="Activity.Current"/> changed event data. 22internal ActivityChangedEventArgs(Activity? previous, Activity? current) 29/// Gets <see cref="Activity"/> object before the event. 31public Activity? Previous { get; init; } 34/// Gets <see cref="Activity"/> object after the event. 36public Activity? Current { get; init; } 65private static readonly AsyncLocal<Activity?> s_current = new AsyncLocal<Activity?>(); 79/// Event occur when the <see cref="Activity.Current"/> value changes. 117private Activity? _previousActiveActivity; 138public static Activity? Current 160public Activity SetStatus(ActivityStatusCode code, string? description = null) 203public Activity? Parent { get; private set; } 380for (Activity? activity = this; activity != null; activity = activity.Parent) 390static IEnumerable<KeyValuePair<string, string?>> Iterate(Activity? activity) 476public Activity AddTag(string key, string? value) => AddTag(key, (object?)value); 486public Activity AddTag(string key, object? value) 510public Activity SetTag(string key, object? value) 527public Activity AddEvent(ActivityEvent e) 552public Activity AddException(Exception exception, in TagList tags = default, DateTimeOffset timestamp = default) 612public Activity AddLink(ActivityLink link) 631public Activity AddBaggage(string key, string? value) 655public Activity SetBaggage(string key, string? value) 676public Activity SetParentId(string parentId) 706public Activity SetParentId(ActivityTraceId traceId, ActivitySpanId spanId, ActivityTraceFlags activityTraceFlags = ActivityTraceFlags.None) 736public Activity SetStartTime(DateTime startTimeUtc) 756public Activity SetEndTime(DateTime endTimeUtc) 785/// Use <see cref="DiagnosticSource.StartActivity(Activity, object)"/> to start activity and write start event. 787/// <seealso cref="DiagnosticSource.StartActivity(Activity, object)"/> 789public Activity Start() 841/// Use <see cref="DiagnosticSource.StopActivity(Activity, object)"/> to stop activity and write stop event. 843/// <seealso cref="DiagnosticSource.StopActivity(Activity, object)"/> 886for (Activity? activity = this; activity != null; activity = activity.Parent) 1046public Activity SetIdFormat(ActivityIdFormat format) 1175internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 1179Activity activity = new Activity(name); 1260private static void SetCurrent(Activity? activity) 1269Activity? previous = s_current.Value; 1409private static bool ValidateSetCurrent(Activity? activity) 1472/// Indicates whether this <see cref="Activity"/> object is stopped 1475/// When subscribing to <see cref="Activity"/> stop event using <see cref="ActivityListener.ActivityStopped"/>, the received <see cref="Activity"/> object in the event callback will have <see cref="IsStopped"/> as true.
System\Diagnostics\ActivityContext.cs (2)
78return Activity.TryConvertIdToContext(traceParent, traceState, isRemote, out context); 101if (!Activity.TryConvertIdToContext(traceParent, traceState, isRemote: false, out ActivityContext context))
System\Diagnostics\ActivityCreationOptions.cs (6)
38if (IdFormat == ActivityIdFormat.Unknown && Activity.ForceDefaultIdFormat) 40IdFormat = Activity.DefaultIdFormat; 80IdFormat = Activity.Current != null ? Activity.Current.IdFormat : Activity.DefaultIdFormat; 135Func<ActivityTraceId>? traceIdGenerator = Activity.TraceIdGenerator;
System\Diagnostics\ActivityEvent.cs (5)
15private readonly Activity.TagsLinkedList? _tags; 40_tags = tagsCount > 0 ? new Activity.TagsLinkedList(tags!) : null; 61/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 62public Activity.Enumerator<KeyValuePair<string, object?>> EnumerateTagObjects() => new Activity.Enumerator<KeyValuePair<string, object?>>(_tags?.First);
System\Diagnostics\ActivityLink.cs (5)
17private readonly Activity.TagsLinkedList? _tags; 28_tags = tags?.Count > 0 ? new Activity.TagsLinkedList(tags) : null; 50/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 51public Activity.Enumerator<KeyValuePair<string, object?>> EnumerateTagObjects() => new Activity.Enumerator<KeyValuePair<string, object?>>(_tags?.First);
System\Diagnostics\ActivityListener.cs (12)
14/// Define the callback to be used in <see cref="ActivityListener"/> to receive notifications when exceptions are added to the <see cref="Activity"/>. 16public delegate void ExceptionRecorder(Activity activity, Exception exception, ref TagList tags); 24/// Construct a new <see cref="ActivityListener"/> object to start listening to the <see cref="Activity"/> events. 31/// Set or get the callback used to listen to the <see cref="Activity"/> start event. 33public Action<Activity>? ActivityStarted { get; set; } 36/// Set or get the callback used to listen to the <see cref="Activity"/> stop event. 38public Action<Activity>? ActivityStopped { get; set; } 41/// Set or get the callback used to listen to <see cref="Activity"/> events when exceptions are added. 46/// Set or get the callback used to decide if want to listen to <see cref="Activity"/> objects events which created using <see cref="ActivitySource"/> object. 51/// Set or get the callback used to decide allowing creating <see cref="Activity"/> objects with specific data state. 56/// Set or get the callback used to decide allowing creating <see cref="Activity"/> objects with specific data state. 61/// Dispose will unregister this <see cref="ActivityListener"/> object from listening to <see cref="Activity"/> events.
System\Diagnostics\ActivitySource.cs (38)
111/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 115/// <returns>The created <see cref="Activity"/> object or null if there is no any event listener.</returns> 117/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it. 119public Activity? CreateActivity(string name, ActivityKind kind) 123/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 124/// If the Activity object is created, it will not automatically start. Callers will need to call <see cref="Activity.Start()"/> to start it. 132/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 134/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it. 136public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 140/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 148/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 150/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it. 152public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 156/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 160/// <returns>The created <see cref="Activity"/> object or null if there is no any event listener.</returns> 161public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 165/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise. 173/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 174public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 178/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise. 186/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 187public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 191/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise. 199/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 200public Activity? StartActivity(ActivityKind kind, ActivityContext parentContext = default, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default, [CallerMemberName] string name = "") 203private Activity? CreateActivity(string name, ActivityKind kind, ActivityContext context, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags, 213Activity? activity = null; 299bool useCurrentActivityContext = context == default && Activity.Current != null; 300var aco = new ActivityCreationOptions<ActivityContext>(this, name, useCurrentActivityContext ? Activity.Current!.Context : context, kind, tags, links, idFormat); 328activity = Activity.Create(this, name, kind, parentId, context, tags, links, startTime, samplerTags, samplingResult, startIt, idFormat, traceState); 344/// Add a listener to the <see cref="Activity"/> starting and stopping events. 346/// <param name="listener"> The <see cref="ActivityListener"/> object to use for listening to the <see cref="Activity"/> events.</param> 381internal void NotifyActivityStart(Activity activity) 389listeners.EnumWithAction((listener, obj) => listener.ActivityStarted?.Invoke((Activity)obj), activity); 393internal void NotifyActivityStop(Activity activity) 401listeners.EnumWithAction((listener, obj) => listener.ActivityStopped?.Invoke((Activity)obj), activity); 405internal void NotifyActivityAddException(Activity activity, Exception exception, ref TagList tags) 510public void EnumWithExceptionNotification(Activity activity, Exception exception, ref TagList tags)
System\Diagnostics\DiagnosticListener.cs (4)
280internal Action<Activity, object?>? OnActivityImport; 281internal Action<Activity, object?>? OnActivityExport; 431Action<Activity, object?>? onActivityImport, Action<Activity, object?>? onActivityExport)
System\Diagnostics\DiagnosticSourceActivity.cs (17)
19/// was started. Consumers could access <see cref="Activity.Current"/> 27/// <seealso cref="Activity"/> 29public Activity StartActivity(Activity activity, object? args) 39public Activity StartActivity<[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] T>(Activity activity, T args) 44/// that Activity was stopped. Consumers could access <see cref="Activity.Current"/> 51/// <seealso cref="Activity"/> 53public void StopActivity(Activity activity, object? args) 58activity.SetEndTime(Activity.GetUtcNow()); 66public void StopActivity<[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] T>(Activity activity, T args) 93public virtual void OnActivityImport(Activity activity, object? payload) { } 119public virtual void OnActivityExport(Activity activity, object? payload) { } 124public override void OnActivityImport(Activity activity, object? payload) 130public override void OnActivityExport(Activity activity, object? payload) 144Action<Activity, object?>? onActivityImport = null, Action<Activity, object?>? onActivityExport = null)
System\Diagnostics\DistributedContextPropagator.cs (2)
45/// Injects the trace values stored in the <see cref="Activity"/> object into a carrier. For example, into the headers of an HTTP request. 50public abstract void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter);
System\Diagnostics\DsesActivitySourceListener.cs (3)
164[DynamicDependency(DynamicallyAccessedMemberTypes.PublicProperties, typeof(Activity))] 172private void OnActivityStarted(Activity activity) 183private void OnActivityStopped(Activity activity)
System\Diagnostics\DsesFilterAndTransform.cs (1)
953return Activity.Current;
System\Diagnostics\LegacyPropagator.cs (1)
16public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter)
System\Diagnostics\NoOutputPropagator.cs (1)
14public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter)
System\Diagnostics\PassThroughPropagator.cs (5)
14public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter) 46Activity? activity = Activity.Current; 48while (activity?.Parent is Activity parent) 55isW3c = parentId is not null ? Activity.TryConvertIdToContext(parentId, traceState, isRemote: false, out _) : false;
System\Diagnostics\W3CPropagator.cs (1)
26public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter)