36 instantiations of Activity
Microsoft.AspNetCore.Diagnostics (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
75activity = new Activity(activityName);
Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
75activity = new Activity(activityName);
Microsoft.AspNetCore.Hosting (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
75activity = 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)
75activity = 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.Build.Engine.UnitTests (7)
Telemetry\OpenTelemetryActivities_Tests.cs (7)
18var activity = new Activity("TestActivity"); 38var activity = new Activity("TestActivity"); 55var activity = new Activity("TestActivity"); 79var activity = new Activity("TestActivity"); 98var activity = new Activity("TestActivity"); 110var activity = new Activity("TestActivity"); 164var parentActivity = new Activity("ParentActivity");
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)
1182Activity activity = new Activity(name);
System.Net.Http (1)
System\Net\Http\DiagnosticsHandler.cs (1)
70activity = new Activity(DiagnosticsHandlerLoggingStrings.RequestActivityName).Start();
772 references to Activity
aspire (64)
Backchannel\AppHostBackchannel.cs (10)
41using var activity = telemetry.ActivitySource.StartActivity(); 54using var activity = telemetry.ActivitySource.StartActivity(); 68using var activity = telemetry.ActivitySource.StartActivity(); 88using var activity = telemetry.ActivitySource.StartActivity(); 110using var activity = telemetry.ActivitySource.StartActivity(); 154using var activity = telemetry.ActivitySource.StartActivity(); 174using var activity = telemetry.ActivitySource.StartActivity(); 189using var activity = telemetry.ActivitySource.StartActivity(); 202using var activity = telemetry.ActivitySource.StartActivity(); 215using var activity = telemetry.ActivitySource.StartActivity();
Backchannel\ExtensionBackchannel.cs (25)
162using 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(); 335using var activity = _activitySource.StartActivity(); 352using var activity = _activitySource.StartActivity(); 368using var activity = _activitySource.StartActivity(); 384using var activity = _activitySource.StartActivity(); 400using var activity = _activitySource.StartActivity(); 421using var activity = _activitySource.StartActivity(); 451using var activity = _activitySource.StartActivity(); 476using var activity = _activitySource.StartActivity(); 502using var activity = _activitySource.StartActivity(); 528using var activity = _activitySource.StartActivity(); 552using var activity = _activitySource.StartActivity(); 573using var activity = _activitySource.StartActivity(); 587using var activity = _activitySource.StartActivity(); 603using var activity = _activitySource.StartActivity(); 625using var activity = _activitySource.StartActivity(); 643using var activity = _activitySource.StartActivity(); 659using var activity = _activitySource.StartActivity(); 676using var activity = _activitySource.StartActivity(); 693using var activity = _activitySource.StartActivity();
Certificates\CertificateService.cs (1)
24using var activity = telemetry.ActivitySource.StartActivity(nameof(EnsureCertificatesTrustedAsync), ActivityKind.Client);
Commands\AddCommand.cs (1)
78using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\ExecCommand.cs (1)
136using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\InitCommand.cs (1)
105using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\NewCommand.cs (1)
132using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\PipelineCommandBase.cs (1)
116using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
Commands\RunCommand.cs (1)
117using var activity = _telemetry.ActivitySource.StartActivity(this.Name);
DotNet\DotNetCliRunner.cs (17)
78using var activity = telemetry.ActivitySource.StartActivity(); 161using var activity = telemetry.ActivitySource.StartActivity(); 234using var activity = telemetry.ActivitySource.StartActivity(); 329using var activity = telemetry.ActivitySource.StartActivity(); 344using var activity = telemetry.ActivitySource.StartActivity(); 359using var activity = telemetry.ActivitySource.StartActivity(nameof(InstallTemplateAsync), ActivityKind.Client); 485using var activity = telemetry.ActivitySource.StartActivity(); 515using var activity = telemetry.ActivitySource.StartActivity(); 672using var activity = telemetry.ActivitySource.StartActivity(); 752using var activity = telemetry.ActivitySource.StartActivity(); 773using var activity = telemetry.ActivitySource.StartActivity(); 834using var activity = telemetry.ActivitySource.StartActivity(); 872using var activity = telemetry.ActivitySource.StartActivity(nameof(ComputeNuGetConfigHierarchySha256Async)); 926using var activity = telemetry.ActivitySource.StartActivity(); 1063using var activity = telemetry.ActivitySource.StartActivity(); 1103using var activity = telemetry.ActivitySource.StartActivity(); 1169using var activity = telemetry.ActivitySource.StartActivity();
NuGet\NuGetPackageCache.cs (1)
79using var activity = telemetry.ActivitySource.StartActivity();
Program.cs (1)
275using var activity = telemetry.ActivitySource.StartActivity();
Projects\ProjectLocator.cs (2)
35using var activity = telemetry.ActivitySource.StartActivity(); 440using 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. 449List<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)
35List<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)
203using var activity = s_activitySource.StartActivity("rabbitmq connect", ActivityKind.Client); 209using var connectAttemptActivity = s_activitySource.StartActivity("rabbitmq connect attempt", ActivityKind.Client); 241private static void AddRabbitMQTags(Activity? activity, Uri address, string? operation = null) 257private 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];
AzureAIFoundryEndToEnd.WebStory (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
AzureOpenAIEndToEnd.WebStory (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
BlazorUnitedApp (1)
artifacts\obj\BlazorUnitedApp\Release\net10.0\Microsoft.CodeAnalysis.Razor.Compiler\Microsoft.NET.Sdk.Razor.SourceGenerators.RazorSourceGenerator\Pages_Error_razor.g.cs (1)
163RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
BrowserTelemetry.Web (1)
Pages_Shared__Layout_cshtml.g.cs (1)
111if (Activity.Current is { } currentActivity)
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);
DevTunnels.WebFrontEnd (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
dotnet (12)
Commands\Tool\Execute\ToolExecuteCommand.cs (2)
47var toolLocationActivity = Activities.Source.StartActivity("find-tool"); 131using var toolExecuteActivity = Activities.Source.StartActivity("execute-tool");
Commands\Tool\Install\ToolInstallGlobalOrToolPathCommand.cs (3)
143using var _activity = Activities.Source.StartActivity("install-tool"); 197var toolPackageDownloaderActivity = Activities.Source.StartActivity("download-tool-package"); 224var shimActivity = Activities.Source.StartActivity("create-shell-shim");
Commands\Tool\Run\ToolRunCommand.cs (1)
30using var _ = Activities.Source.StartActivity("execute-local-tool");
InteractiveConsole.cs (1)
34using var _ = Activities.Source.StartActivity("confirm-run-from-source");
Telemetry\Telemetry.cs (1)
187Activity.Current?.AddEvent(CreateActivityEvent(eventName, eventProperties, eventMeasurements));
ToolPackage\ToolPackageDownloader.cs (2)
69var _downloadActivity = Activities.Source.StartActivity("download-tool"); 96var _extractActivity = Activities.Source.StartActivity("extract-tool");
ToolPackage\ToolPackageDownloaderBase.cs (2)
190var _moveContentActivity = Activities.Source.StartActivity("move-global-tool-content"); 379using var _updateRuntimeConfigActivity = Activities.Source.StartActivity("update-runtimeconfig");
DynamicSchemes (1)
Pages\Error.cshtml.cs (1)
21RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
FileBasedApps.WebFrontEnd (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
GitHubModelsEndToEnd.WebStory (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
HostedBlazorWebassemblyApp.Server (1)
Pages\Error.cshtml.cs (1)
32RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
Keycloak.Web (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = 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 63var activity = activityHandle.Activity; 77if (Activity.Current == null && activityHandle.Previous != null && !activityHandle.Previous.IsStopped) 79Activity.Current = activityHandle.Previous; 90public Activity? Previous; 91public 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; 74var activity = activityHandle.Activity; 96var 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)
18public static Activity? CreateFromRemote( 29Activity? activity = null;
Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore (2)
src\Shared\Diagnostics\ActivityCreator.cs (2)
18public static Activity? CreateFromRemote( 29Activity? activity = null;
Microsoft.AspNetCore.Hosting (12)
Internal\HostingApplication.cs (1)
132public Activity? Activity
Internal\HostingApplicationDiagnostics.cs (7)
229var activity = context.Activity; 404private Activity? StartActivity(HttpContext httpContext, bool diagnosticsOrLoggingEnabled, out bool hasDiagnosticListener) 417var activity = ActivityCreator.CreateFromRemote( 494private void StopActivity(HttpContext httpContext, Activity activity, bool hasDiagnosticListener) 522private Activity StartActivity(Activity activity, HttpContext httpContext) 536private 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)
18public static Activity? CreateFromRemote( 29Activity? activity = null;
Microsoft.AspNetCore.Hosting.Tests (58)
HostingApplicationDiagnosticsTests.cs (51)
176Activity measurementActivity = null; 205measurementActivity = Activity.Current; 556Assert.Null(Activity.Current); 596Assert.Null(Activity.Current); 627Assert.Null(Activity.Current); 664Assert.NotNull(Activity.Current); 684Assert.NotNull(Activity.Current); 685Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 691Assert.NotNull(Activity.Current); 708Assert.NotNull(Activity.Current); 709Assert.True(Activity.Current.Duration > TimeSpan.Zero); 710Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 732Assert.NotNull(Activity.Current); 733Assert.True(Activity.Current.Duration > TimeSpan.Zero); 734Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 756Assert.NotNull(Activity.Current); 757Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 784Assert.NotNull(Activity.Current); 785Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 813Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 814Assert.Null(Activity.Current.ParentId); 815Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 816Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 843Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 844Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 845Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 873Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 874Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 875Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 904Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 905Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value3"); 906Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value4"); 934Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 943Assert.Equal(expectedBaggage, Activity.Current.Baggage.ToArray()); 971Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 972Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1/1"); 1001Assert.Equal("Microsoft.AspNetCore.Hosting.HttpRequestIn", Activity.Current.OperationName); 1002Assert.Equal(ActivityIdFormat.W3C, Activity.Current.IdFormat); 1003Assert.Equal("0123456789abcdef0123456789abcdef", Activity.Current.TraceId.ToHexString()); 1004Assert.Equal("0123456789abcdef", Activity.Current.ParentSpanId.ToHexString()); 1005Assert.Equal("tracestate=1", Activity.Current.TraceStateString); 1007Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key1" && pair.Value == "value1"); 1008Assert.Contains(Activity.Current.Baggage, pair => pair.Key == "Key2" && pair.Value == "value2"); 1068Assert.Null(Activity.Current); 1079Assert.NotNull(Activity.Current); 1080Assert.True(Activity.Current.Recorded); 1096parentSpanId = Activity.Current.ParentSpanId.ToHexString(); 1097tags = Activity.Current.TagObjects.OrderBy(t => t.Key).ToList(); 1138parentSpanId = Activity.Current.ParentSpanId.ToHexString(); 1139tags = Activity.Current.TagObjects.OrderBy(t => t.Key).ToList(); 1196tags = Activity.Current.TagObjects.ToDictionary();
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.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)
18public static Activity? CreateFromRemote( 29Activity? 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 (1)
TelemetryInfra\TelemetryDataUtils.cs (1)
19/// <returns>Node Telemetry data wrapped in <see cref="IActivityTelemetryDataHolder"/> a list of properties that can be attached as tags to a <see cref="System.Diagnostics.Activity"/>.</returns>
Microsoft.Build.Engine.UnitTests (12)
Telemetry\OpenTelemetryActivities_Tests.cs (10)
18var activity = new Activity("TestActivity"); 38var activity = new Activity("TestActivity"); 55var activity = new Activity("TestActivity"); 79var activity = new Activity("TestActivity"); 98var activity = new Activity("TestActivity"); 110var activity = new Activity("TestActivity"); 152var activity = source.StartActivity("Build"); 164var parentActivity = new Activity("ParentActivity"); 178var childActivity = source.StartActivity("ChildBuild"); 186if (Activity.Current?.HasRemoteParent == true)
Telemetry\Telemetry_Tests.cs (2)
189var capturedActivities = new List<Activity>(); 254var activity = capturedActivities.FindLast(a => a.DisplayName == "VS/MSBuild/Build").ShouldNotBeNull();
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 (33)
ChatCompletion\FunctionInvokingChatClient.cs (10)
272using Activity? activity = _activitySource?.StartActivity(OpenTelemetryConsts.GenAI.OrchestrateToolsName); 411using Activity? activity = _activitySource?.StartActivity(OpenTelemetryConsts.GenAI.OrchestrateToolsName); 454Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 468Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 538Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 565Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 582Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 613Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 642private static void AddUsageTags(Activity? activity, UsageDetails? usage) 1122using Activity? activity = _activitySource?.StartActivity(
ChatCompletion\OpenTelemetryChatClient.cs (8)
136using Activity? activity = CreateAndConfigureActivity(options); 167using Activity? activity = CreateAndConfigureActivity(options); 209Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 332private Activity? CreateAndConfigureActivity(ChatOptions? options) 334Activity? activity = null; 454Activity? activity, 568private void AddInputMessagesTags(IEnumerable<ChatMessage> messages, ChatOptions? options, Activity? activity) 585private void AddOutputMessagesTags(ChatResponse response, Activity? activity)
ChatCompletion\OpenTelemetryImageGenerator.cs (4)
121using Activity? activity = CreateAndConfigureActivity(request, options); 144private Activity? CreateAndConfigureActivity(ImageGenerationRequest request, ImageGenerationOptions? options) 146Activity? activity = null; 220Activity? activity,
Embeddings\OpenTelemetryEmbeddingGenerator.cs (4)
113using Activity? activity = CreateAndConfigureActivity(options); 149private Activity? CreateAndConfigureActivity(EmbeddingGenerationOptions? options) 151Activity? activity = null; 197Activity? activity,
SpeechToText\OpenTelemetrySpeechToTextClient.cs (7)
122using Activity? activity = CreateAndConfigureActivity(options); 150using Activity? activity = CreateAndConfigureActivity(options); 190Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 202private Activity? CreateAndConfigureActivity(SpeechToTextOptions? options) 204Activity? activity = null; 251Activity? activity, 358private void AddOutputMessagesTags(SpeechToTextResponse response, Activity? activity)
Microsoft.Extensions.AI.Integration.Tests (10)
ChatClientIntegrationTests.cs (8)
228var activities = new List<Activity>(); 295var activities = new List<Activity>(); 327var activities = new List<Activity>(); 359var activities = new List<Activity>(); 386private static void AssertUsageAgainstActivities(ChatResponse response, List<Activity> activities) 416var activities = new List<Activity>(); 940var activities = new List<Activity>(); 952var activity = Assert.Single(activities);
EmbeddingGeneratorIntegrationTests.cs (2)
111var activities = new List<Activity>(); 125var activity = activities.Single();
Microsoft.Extensions.AI.Tests (12)
ChatCompletion\FunctionInvokingChatClientTests.cs (2)
687var activities = new List<Activity>(); 705var executeTool = activities[1];
ChatCompletion\OpenTelemetryChatClientTests.cs (4)
27var activities = new List<Activity>(); 156var activity = Assert.Single(activities); 338var activities = new List<Activity>(); 375var activity = Assert.Single(activities);
Embeddings\OpenTelemetryEmbeddingGeneratorTests.cs (2)
24var activities = new List<Activity>(); 74var activity = Assert.Single(activities);
Image\OpenTelemetryImageGeneratorTests.cs (2)
29var activities = new List<Activity>(); 92var activity = Assert.Single(activities);
SpeechToText\OpenTelemetrySpeechToTextClientTests.cs (2)
34var activities = new List<Activity>(); 106var 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)
52Activity? activity = Activity.Current; 93private static ActivityBaggageLogScopeWrapper GetOrCreateActivityBaggageLogScopeWrapper(Activity activity, IEnumerable<KeyValuePair<string, string?>> items) 152public ActivityLogScope(Activity activity, ActivityTrackingOptions activityTrackingOption) 305public static string GetSpanId(this Activity activity) 315public static string GetTraceId(this Activity activity) 325public 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");
Microsoft.TemplateEngine.Cli (10)
Commands\create\InstantiateCommand.cs (4)
77using var createTemplateGroupsActivity = Activities.Source.StartActivity("create-template-groups"); 88using var getTemplateActivity = Activities.Source.StartActivity("get-template-command"); 209using var createActivity = Activities.Source.StartActivity("instantiate-command"); 280var templateParseActivity = Activities.Source.StartActivity("reparse-for-template");
Commands\create\TemplateCommand.cs (2)
149using var templateInvocationActivity = Activities.Source.StartActivity("invoke-template"); 163using var constraintResultsActivity = Activities.Source.StartActivity("validate-constraints");
TemplateInvoker.cs (3)
40using var invokerActivity = Activities.Source.StartActivity("invoker-invoking"); 162using var templateCreationActivity = Activities.Source.StartActivity("actual-instantiate-template"); 311using var postActionActivity = Activities.Source.StartActivity("post-actions");
TemplateListCoordinator.cs (1)
32using var constraintManagerActivity = Activities.Source.StartActivity("create-constraints");
MvcFormSample (1)
Controllers\HomeController.cs (1)
48return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
MyFrontend (1)
Components_Pages_Error_razor.g.cs (1)
167requestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
OpenAIEndToEnd.WebStory (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = 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 });
Publishers.Frontend (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
Seq.ApiService (1)
Program.cs (1)
23using var activity = source.StartActivity("Chose {Number}");
SignalRServerlessWeb (1)
Pages_Shared__Layout_cshtml.g.cs (1)
111if (Activity.Current is { } currentActivity)
SignalRWeb (1)
Pages_Shared__Layout_cshtml.g.cs (1)
111if (Activity.Current is { } currentActivity)
StaticFilesAuth (1)
Controllers\HomeController.cs (1)
24return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
Stress.ApiService (37)
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 (21)
90var activity = Activity.Current; 91Activity.Current = null; 95Activity.Current = activity; 131var current = Activity.Current; 132Activity.Current = null; 146Activity.Current = current; 340var span1 = traceCreator.CreateActivity("Test 1", "0485b1947fe788bb"); 343var span2 = traceCreator.CreateActivity("Test 2", "0485b1947fe788bb"); 353var current = Activity.Current; 354Activity.Current = null; 361Activity.Current = current; 382using var activity = source.StartActivity("ValidateAndUpdateCacheService.ExecuteAsync"); 385using var innerActivity = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 404using var innerActivity2 = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 432var activity = source.StartActivity("chat gpt", ActivityKind.Client); 493var activity = source.StartActivity("chat gpt", ActivityKind.Client); 510using var activity = source.StartActivity($"WorkIteration{index + 1}"); 520using var activity = source.StartActivity("HereActivity");
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 (148)
System\Diagnostics\Activity.cs (45)
19/// Carries the <see cref="Activity.Current"/> changed event data. 23internal ActivityChangedEventArgs(Activity? previous, Activity? current) 30/// Gets <see cref="Activity"/> object before the event. 32public Activity? Previous { get; init; } 35/// Gets <see cref="Activity"/> object after the event. 37public Activity? Current { get; init; } 68private static readonly AsyncLocal<Activity?> s_current = new AsyncLocal<Activity?>(); 82/// Event occur when the <see cref="Activity.Current"/> value changes. 120private Activity? _previousActiveActivity; 141public static Activity? Current 163public Activity SetStatus(ActivityStatusCode code, string? description = null) 206public Activity? Parent { get; private set; } 383for (Activity? activity = this; activity != null; activity = activity.Parent) 393static IEnumerable<KeyValuePair<string, string?>> Iterate(Activity? activity) 479public Activity AddTag(string key, string? value) => AddTag(key, (object?)value); 489public Activity AddTag(string key, object? value) 513public Activity SetTag(string key, object? value) 530public Activity AddEvent(ActivityEvent e) 555public Activity AddException(Exception exception, in TagList tags = default, DateTimeOffset timestamp = default) 615public Activity AddLink(ActivityLink link) 634public Activity AddBaggage(string key, string? value) 658public Activity SetBaggage(string key, string? value) 679public Activity SetParentId(string parentId) 709public Activity SetParentId(ActivityTraceId traceId, ActivitySpanId spanId, ActivityTraceFlags activityTraceFlags = ActivityTraceFlags.None) 739public Activity SetStartTime(DateTime startTimeUtc) 759public Activity SetEndTime(DateTime endTimeUtc) 788/// Use <see cref="DiagnosticSource.StartActivity(Activity, object)"/> to start activity and write start event. 790/// <seealso cref="DiagnosticSource.StartActivity(Activity, object)"/> 792public Activity Start() 844/// Use <see cref="DiagnosticSource.StopActivity(Activity, object)"/> to stop activity and write stop event. 846/// <seealso cref="DiagnosticSource.StopActivity(Activity, object)"/> 889for (Activity? activity = this; activity != null; activity = activity.Parent) 1049public Activity SetIdFormat(ActivityIdFormat format) 1178internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 1182Activity activity = new Activity(name); 1263private static void SetCurrent(Activity? activity) 1272Activity? previous = s_current.Value; 1412private static bool ValidateSetCurrent(Activity? activity) 1475/// Indicates whether this <see cref="Activity"/> object is stopped 1478/// 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. 2183internal sealed class ActivityDebuggerProxy(Activity activity) 2196public Activity? Parent => activity.Parent;
System\Diagnostics\ActivityContext.cs (2)
79return Activity.TryConvertIdToContext(traceParent, traceState, isRemote, out context); 102if (!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)
16private readonly Activity.TagsLinkedList? _tags; 41_tags = tagsCount > 0 ? new Activity.TagsLinkedList(tags!) : null; 62/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 63public Activity.Enumerator<KeyValuePair<string, object?>> EnumerateTagObjects() => new Activity.Enumerator<KeyValuePair<string, object?>>(_tags?.First);
System\Diagnostics\ActivityLink.cs (5)
18private readonly Activity.TagsLinkedList? _tags; 29_tags = tags?.Count > 0 ? new Activity.TagsLinkedList(tags) : null; 53/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 54public 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)
112/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 116/// <returns>The created <see cref="Activity"/> object or null if there is no any event listener.</returns> 118/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it. 120public Activity? CreateActivity(string name, ActivityKind kind) 124/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 125/// If the Activity object is created, it will not automatically start. Callers will need to call <see cref="Activity.Start()"/> to start it. 133/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 135/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it. 137public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 141/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 149/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 151/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it. 153public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 157/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise. 161/// <returns>The created <see cref="Activity"/> object or null if there is no any event listener.</returns> 162public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 166/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise. 174/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 175public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 179/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise. 187/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 188public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 192/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise. 200/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns> 201public Activity? StartActivity(ActivityKind kind, ActivityContext parentContext = default, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default, [CallerMemberName] string name = "") 204private Activity? CreateActivity(string name, ActivityKind kind, ActivityContext context, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags, 214Activity? activity = null; 300bool useCurrentActivityContext = context == default && Activity.Current != null; 301var aco = new ActivityCreationOptions<ActivityContext>(this, name, useCurrentActivityContext ? Activity.Current!.Context : context, kind, tags, links, idFormat); 329activity = Activity.Create(this, name, kind, parentId, context, tags, links, startTime, samplerTags, samplingResult, startIt, idFormat, traceState); 345/// Add a listener to the <see cref="Activity"/> starting and stopping events. 347/// <param name="listener"> The <see cref="ActivityListener"/> object to use for listening to the <see cref="Activity"/> events.</param> 382internal void NotifyActivityStart(Activity activity) 390listeners.EnumWithAction((listener, obj) => listener.ActivityStarted?.Invoke((Activity)obj), activity); 394internal void NotifyActivityStop(Activity activity) 402listeners.EnumWithAction((listener, obj) => listener.ActivityStopped?.Invoke((Activity)obj), activity); 406internal void NotifyActivityAddException(Activity activity, Exception exception, ref TagList tags) 511public 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)
System.Net.Http (33)
System\Net\Http\DiagnosticsHandler.cs (6)
53return Activity.Current != null || 58private static Activity? StartActivity(HttpRequestMessage request) 60Activity? activity = null; 67(Activity.Current is not null || 111Activity? activity = StartActivity(request); 355private void InjectHeaders(Activity currentActivity, HttpRequestMessage request)
System\Net\Http\SocketsHttpHandler\ConnectionPool\ConnectionSetupDistributedTracing.cs (10)
15public static Activity? StartConnectionSetupActivity(bool isSecure, string? serverAddress, int port) 17Activity? activity = null; 22Activity.Current = null; 41public static void StopConnectionSetupActivity(Activity activity, Exception? exception, IPEndPoint? remoteEndPoint) 59public static void ReportError(Activity? activity, Exception exception) 73public static Activity? StartWaitForConnectionActivity(HttpAuthority authority) 75Activity? activity = s_connectionsActivitySource.StartActivity(DiagnosticsHandlerLoggingStrings.WaitForConnectionActivityName); 81public static void AddConnectionLinkToRequestActivity(Activity connectionSetupActivity) 88Activity? requestActivity = Activity.Current;
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (2)
557private async ValueTask<(Stream, TransportContext?, Activity?, IPEndPoint?)> ConnectAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 564Activity? activity = ConnectionSetupDistributedTracing.StartConnectionSetupActivity(IsSecure, _telemetryServerAddress, OriginAuthority.Port);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (2)
296(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(request, async, cancellationToken).ConfigureAwait(false); 300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (3)
187(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(queueItem.Request, true, cts.Token).ConfigureAwait(false); 246private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken) 289private async Task HandleHttp11Downgrade(HttpRequestMessage request, Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (1)
261Activity? connectionSetupActivity = null;
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionWaiter.cs (2)
24|| (GlobalHttpSettings.DiagnosticsHandler.EnableActivityPropagation && Activity.Current?.Source == DiagnosticsHandler.s_activitySource); 37using Activity? waitForConnectionActivity = ConnectionSetupDistributedTracing.StartWaitForConnectionActivity(pool.OriginAuthority);
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
134public Http2Connection(HttpConnectionPool pool, Stream stream, Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)
93public void InitQuicConnection(QuicConnection connection, Activity? connectionSetupActivity) 951private Activity? _activity;
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (1)
76Activity? connectionSetupActivity,
System\Net\Http\SocketsHttpHandler\HttpConnectionBase.cs (3)
41public Activity? ConnectionSetupActivity { get; private set; } 50public HttpConnectionBase(HttpConnectionPool pool, Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint) 56protected void MarkConnectionAsEstablished(Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint)
System.Net.NameResolution (4)
System\Net\Dns.cs (3)
728Activity? activityToRestore = tracingEnabled ? Activity.Current : null; 733Activity.Current = activityToRestore;
System\Net\NameResolutionTelemetry.cs (1)
174private readonly Activity? _activity;
System.Net.Security (4)
System\Net\Security\NetSecurityTelemetry.cs (3)
323public static Activity? StartActivity(SslStream stream) 325using Activity? activity = s_activitySource.StartActivity(ActivityName); 338public static void StopActivity(Activity? activity, Exception? exception, SslStream stream)
System\Net\Security\SslStream.IO.cs (1)
139Activity? activity = NetSecurityTelemetry.StartActivity(this);
System.Net.Sockets (12)
System\Net\Sockets\Socket.cs (1)
3352Activity? activity = SocketsTelemetry.Log.ConnectStart(socketAddress, _protocolType, endPointSnapshot, keepActivityCurrent: false);
System\Net\Sockets\SocketAsyncEventArgs.cs (4)
75private static ConditionalWeakTable<SocketAsyncEventArgs, Activity>? s_connectActivityTable; 310internal Activity? ConnectActivity 315get => s_connectActivityTable?.TryGetValue(this, out Activity? result) == true ? result : null; 320LazyInitializer.EnsureInitialized(ref s_connectActivityTable, () => new ConditionalWeakTable<SocketAsyncEventArgs, Activity>());
System\Net\Sockets\SocketsTelemetry.cs (7)
91public Activity? ConnectStart(SocketAddress address, ProtocolType protocolType, EndPoint endPoint, bool keepActivityCurrent) 100Activity? activity = null; 103Activity? activityToReset = keepActivityCurrent ? Activity.Current : null; 108Activity.Current = activityToReset; 146static void SetNetworkTransport(Activity activity, string transportType) => activity.SetTag("network.transport", transportType); 152public void AfterConnect(SocketError error, Activity? activity, string? exceptionMessage = null)
WaitFor.Frontend (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
WebFrontEnd (1)
Components_Pages_Error_razor.g.cs (1)
155RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
WebPubSubWeb (1)
Pages_Shared__Layout_cshtml.g.cs (1)
111if (Activity.Current is { } currentActivity)