Activity

Telemetry\ReportedLogExportTests.cs (2)

170using var activity = new Activity("ambient").Start(); 249using var activity = new Activity("typed-span");

Model\DashboardClientTests.cs (1)

790using var activity = new Activity("request").Start();

Model\DashboardCommandExecutorTests.cs (1)

88using var parent = new Activity("parent").Start();

Model\SqliteResourceRepositoryTests.cs (1)

1002using var operation = new Activity("Capture resource persistence queries").Start();

ResourceOutgoingPeerResolverTests.cs (1)

359using var activity = new Activity("request").Start();

Telemetry\DashboardTelemetryLogExportTests.cs (1)

75using var activity = new Activity("ambient").Start();

Telemetry\DashboardTelemetryMetadataTests.cs (1)

64using var activity = new Activity("test-operation");

Telemetry\DashboardTelemetryServiceTests.cs (2)

24using var parent = new Activity("parent").Start(); 107using var parent = new Activity("parent").Start();

Telemetry\TagEnrichmentProcessorTests.cs (2)

20using var activity = new Activity("test-operation"); 39using var activity = new Activity("test-operation");

Telemetry\TelemetryLoggerProviderTests.cs (1)

47using var frameworkActivity = withActivity ? new Activity("Blazor").Start() : null;

tests\Aspire.Hosting.Native.Core.Tests\TestServices\DiagnosticCapture.cs (1)

20Root = new Activity("native.diagnostics.test")

TestServices\DiagnosticCapture.cs (1)

20Root = new Activity("native.diagnostics.test")

Rpc\NativeRpcConnection.cs (1)

464var activity = new Activity("native.rpc.incoming")

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

75activity = new Activity(activityName);

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

75activity = new Activity(activityName);

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

75activity = new Activity(activityName);

HubConnection.cs (1)

1384activity = new Activity(ActivityName);

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

75activity = new Activity(activityName);

Buffering\GlobalBufferIncludeScopesTests.cs (1)

107using var activity = new Activity("logging");

Buffering\GlobalBufferTests.cs (5)

29using Activity activity = new Activity("logging"); 37using (Activity flushingActivity = new Activity("flushing")) 63using Activity? activity = useHierarchicalActivity ? new Activity("logging") : null; 70using (Activity flushingActivity = new Activity("flushing")) 150using (Activity activity = new Activity("logging"))

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\Activity.cs (1)

1197Activity activity = new Activity(name);

System\Net\Http\DiagnosticsHandler.cs (1)

70activity = new Activity(DiagnosticsHandlerLoggingStrings.RequestActivityName).Start();

Agents\AspireSkills\AspireSkillsInstaller.cs (6)

67using var activity = telemetry.StartReportedActivity("AspireSkillsInstaller.Install"); 166Activity? activity, 289Activity? activity, 559Activity? activity, 589Activity? activity, 661Activity? activity,

Backchannel\AppHostCliBackchannel.cs (7)

76using var activity = telemetry.StartDiagnosticActivity(); 162using var activity = telemetry.StartDiagnosticActivity(); 486using var activity = telemetry.StartDiagnosticActivity(); 503using var activity = telemetry.StartDiagnosticActivity(); 518using var activity = telemetry.StartDiagnosticActivity(); 533using var activity = telemetry.StartDiagnosticActivity(); 552using var activity = telemetry.StartDiagnosticActivity();

Backchannel\ExtensionBackchannel.cs (29)

Certificates\CertificateService.cs (1)

65using var activity = telemetry.StartDiagnosticActivity(kind: ActivityKind.Client);

Commands\AddCommand.cs (1)

80using var activity = Telemetry.StartDiagnosticActivity(this.Name);

Commands\AgentTelemetryCommand.cs (1)

190using (var activity = Telemetry.StartReportedActivity(TelemetryConstants.Activities.AgentTelemetry))

Commands\ApiGetCommand.cs (1)

48using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\ApiListCommand.cs (1)

50using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\ApiSearchCommand.cs (1)

62using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\AppHostLauncher.cs (2)

404internal static Dictionary<string, string> CreateDetachedChildEnvironment(Activity? activity, string? appHostSelectionOrigin) 453CreateDetachedChildEnvironment(Activity.Current, appHostSelectionOrigin),

Commands\DescribeCommand.cs (1)

130using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\DocsGetCommand.cs (1)

53using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\DocsListCommand.cs (1)

43using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\DocsSearchCommand.cs (1)

55using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\ExportCommand.cs (1)

74using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\InitCommand.cs (1)

121using var activity = Telemetry.StartDiagnosticActivity(this.Name);

Commands\IntegrationSearchCommand.cs (1)

53using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\LogsCommand.cs (1)

144using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\LsCommand.cs (1)

73using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\NewCommand.cs (1)

503using var activity = Telemetry.StartDiagnosticActivity(this.Name);

Commands\PipelineCommandBase.cs (1)

225using var activity = Telemetry.StartDiagnosticActivity(this.Name);

Commands\PsCommand.cs (1)

138using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\RestoreCommand.cs (1)

66using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\RunCommand.cs (1)

255Activity? runActivity = null;

Commands\TelemetryLogsCommand.cs (1)

81using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\TelemetrySpansCommand.cs (1)

72using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\TelemetryTracesCommand.cs (1)

71using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\TerminalAttachCommand.cs (1)

79using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\TerminalPsCommand.cs (1)

74using var activity = Telemetry.StartDiagnosticActivity(Name);

Commands\TerminalTapePlayCommand.cs (1)

73using var activity = Telemetry.StartDiagnosticActivity("terminal tape play");

Commands\WaitCommand.cs (1)

63using var activity = Telemetry.StartDiagnosticActivity(Name);

DotNet\DotNetCliRunner.cs (16)

NuGet\NuGetPackageCache.cs (2)

175using var activity = telemetry.StartDiagnosticActivity(); 255using var activity = telemetry.StartDiagnosticActivity();

Program.cs (3)

1249using var mainActivity = isAgentTelemetryInvocation 1386internal static Activity? StartMainActivity(AspireCliTelemetry telemetry, InstallSourceDetector installSourceDetector) 1388var activity = telemetry.StartReportedActivity(TelemetryConstants.Activities.Main, ActivityKind.Internal);

Projects\ExtensionGuestLauncher.cs (1)

46ProfilingTelemetry.AddActivityContextToEnvironment(Activity.Current, effectiveEnvironmentVariables);

Projects\GuestAppHostProject.cs (2)

555var startProjectContext = Activity.Current?.Context ?? default; 1407var startProjectContext = Activity.Current?.Context ?? default;

Projects\ProcessGuestLauncher.cs (5)

49var activity = GetCurrentProfilingActivity(); 196private static Activity? GetCurrentProfilingActivity() 198var activity = Activity.Current; 202private static void AddEvent(Activity? activity, string eventName, string? tagName = null, object? tagValue = null)

Projects\ProjectLocator.cs (1)

291using var activity = telemetry.StartDiagnosticActivity();

src\Shared\Telemetry\ActivityTagEnrichmentProcessor.cs (2)

12internal sealed class ActivityTagEnrichmentProcessor(AspireTelemetryBase telemetry) : BaseProcessor<Activity> 14public override void OnEnd(Activity data)

src\Shared\Telemetry\AspireTelemetryBase.cs (9)

58public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 71public Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext) 85protected Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<ActivityLink> links) 97public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 110public Activity? StartDiagnosticActivity(string name, ActivityKind kind, ActivityContext parentContext) 152protected void AddReportedActivityProperties(Activity activity, IEnumerable<KeyValuePair<string, object?>>? properties) 167public void SetActivityProperty(Activity? activity, string key, object? value) 187public void SetActivityProperties(Activity? activity, IEnumerable<KeyValuePair<string, object?>> properties) 253internal virtual IEnumerable<KeyValuePair<string, object?>> GetActivityDefaultTags(Activity activity) => GetDefaultTags();

Telemetry\AspireCliTelemetry.cs (2)

140internal override IEnumerable<KeyValuePair<string, object?>> GetActivityDefaultTags(Activity activity) 359using var activity = StartReportedActivity(TelemetryConstants.Activities.InternalMicrosoftDetector);

Telemetry\ProfilingTelemetry.cs (19)

253public ActivityScope CurrentActivity => IsEnabled ? new(Activity.Current, ownsActivity: false) : default; 263AddActivityContextToEnvironment(Activity.Current, environment); 266public static void AddActivityContextToEnvironment(Activity? activity, IDictionary<string, string> environment) 667var ambientActivity = Activity.Current; 668Activity? activity; 689if (restoreAmbientActivity && ReferenceEquals(Activity.Current, activity)) 691Activity.Current = ambientActivity; 697private void AddProfilingSession(Activity? activity, Activity? ambientActivity) 736private static string? GetProfilingSessionId(Activity? activity) 741private static string? GetProfilingSessionIdFromAncestors(Activity? activity) 743for (var current = activity; current is not null; current = current.Parent) 754private static void AddProfilingSessionBaggage(Activity? activity, string sessionId) 756for (var current = activity; current is not null; current = current.Parent) 775internal static void SetProcessInvocation(Activity? activity, string executablePath, IReadOnlyList<string> args) 809var currentActivity = Activity.Current; 815internal readonly struct ActivityScope(Activity? activity, bool ownsActivity = true) : IDisposable

Utils\AppHostHelper.cs (1)

73using var activity = telemetry.StartDiagnosticActivity(kind: ActivityKind.Client);

Utils\SdkInstallHelper.cs (1)

37using var activity = telemetry.StartReportedActivity(name: TelemetryConstants.Activities.EnsureSdkInstalled);

tests\Shared\FoundryClientTestHelpers.cs (4)

43internal sealed class FoundryTestActivityExporter : BaseExporter<Activity> 45public ConcurrentQueue<Activity> Activities { get; } = new(); 47public override ExportResult Export(in Batch<Activity> batch) 49foreach (var activity in batch)

tests\Shared\FoundryClientTestHelpers.cs (4)

43internal sealed class FoundryTestActivityExporter : BaseExporter<Activity> 45public ConcurrentQueue<Activity> Activities { get; } = new(); 47public override ExportResult Export(in Batch<Activity> batch) 49foreach (var activity in batch)

Commands\AgentTelemetryCommandTests.cs (10)

80var activity = Assert.IsType<Activity>(fixture.CapturedActivity); 174var activity = Assert.Single(capturedActivities); 206var activity = Assert.Single(capturedActivities); 237var activity = Assert.Single(capturedActivities); 269var activity = Assert.Single(capturedActivities); 295var activity = Assert.Single(capturedActivities); 389var activity = Assert.Single(capturedActivities); 395private static (List<Activity> Activities, ActivityListener Listener) CreateCapturingListener(out string reportedSourceName) 398var captured = new List<Activity>();

Commands\AppHostLauncherTests.cs (4)

952using var activity = source.StartActivity("parent"); 1018var environment = AppHostLauncher.CreateDetachedChildEnvironment(Activity.Current, appHostSelectionOrigin: null); 1025Assert.Equal(Activity.Current?.Id, environment[ProfilingTelemetry.EnvironmentVariables.TraceParent]); 1033using var activity = source.StartActivity("parent");

Commands\LsCommandTests.cs (4)

760var startedActivities = new ConcurrentBag<Activity>(); 791var lsActivity = Assert.Single(startedActivities, activity => IsActivityFromSession(activity, ProfilingTelemetry.Activities.LsCommand, sessionId)); 797var findActivity = Assert.Single(startedActivities, activity => IsActivityFromSession(activity, ProfilingTelemetry.Activities.LsFindAppHosts, sessionId)); 802private static bool IsActivityFromSession(Activity activity, string operationName, string sessionId)

Commands\StopCommandTests.cs (2)

660var stoppedActivities = new ConcurrentQueue<Activity>(); 689var stopCommandActivity = Assert.Single(stoppedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.StopCommand);

DotNet\DotNetCliRunnerTests.cs (6)

1136var currentActivity = Activity.Current; 1167var startedActivities = new ConcurrentQueue<Activity>(); 1200runSpanId = Activity.Current!.SpanId; 1224var processActivity = Assert.Single(sessionActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.Process); 1225var backchannelActivity = Assert.Single(sessionActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.BackchannelConnect);

Git\GitRepositoryTests.cs (3)

118var startedActivities = new ConcurrentBag<Activity>(); 129var startedActivity = Assert.Single(startedActivities, activity => 154private static bool IsActivityFromSession(Activity activity, string operationName, string sessionId)

ProgramTests.cs (3)

58using var activity = Program.StartMainActivity(fixture.Telemetry, detector); 70using var otherActivity = fixture.Telemetry.StartReportedActivity("other"); 90using var activity = Program.StartMainActivity(fixture.Telemetry, detector);

Projects\AppHostCandidateFinderTests.cs (6)

219var startedActivities = new List<Activity>(); 233var discoveryActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateDiscovery); 239var matchActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateGitMatch); 275var startedActivities = new List<Activity>(); 294var discoveryActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateDiscovery); 298var walkActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateFilesystemWalk);

Projects\AppHostServerSessionTests.cs (2)

117using var parentActivity = parentSource.StartActivity("aspire/cli/run"); 126Assert.Same(parentActivity, Activity.Current);

Projects\GuestRuntimeTests.cs (3)

258var stoppedActivities = new ConcurrentBag<Activity>(); 961var stoppedActivities = new ConcurrentBag<Activity>(); 992var activity = Assert.Single(stoppedActivities, activity =>

Telemetry\ActivityTagEnrichmentProcessorTests.cs (3)

28using var activity = source.StartActivity("test-op")!; 74using var activity = source.StartActivity("test-op")!; 114using var activity = source.StartActivity(TelemetryConstants.Activities.InternalMicrosoftDetector)!;

Telemetry\AgentTelemetryPersistenceTests.cs (3)

116using (var activity = source.StartActivity("reported-operation")) 408using (var activity = source.StartActivity(TelemetryConstants.Activities.AgentTelemetry)) 535using var activity = source.StartActivity(TelemetryConstants.Activities.AgentTelemetry);

Telemetry\AspireCliTelemetryTests.cs (19)

Telemetry\ProfilingTelemetryContextTests.cs (6)

19using var activity = source.StartActivity("parent"); 53using var activity = source.StartActivity("parent"); 65var startedActivities = new List<Activity>(); 76var startedActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.RunCommand); 101var startedActivities = new List<Activity>(); 112var startedActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.RunCommand);

Telemetry\ProfilingTelemetryTests.cs (11)

18Activity? startedActivity = null; 31Activity? startedActivity = null; 50var startedActivities = new ConcurrentQueue<Activity>(); 120var startedActivities = new ConcurrentQueue<Activity>(); 166var startedActivities = new ConcurrentQueue<Activity>(); 289var startedActivities = new ConcurrentQueue<Activity>(); 295using var parentActivity = parentSource.StartActivity("parent"); 320var startedActivities = new ConcurrentQueue<Activity>(); 328using var parentActivity = parentSource.StartActivity("parent"); 368private static Activity[] GetSessionActivities(IEnumerable<Activity> activities, string sessionId)

Telemetry\ReportedLogExportTests.cs (3)

54using (var activity = source.StartActivity("reported-operation")) 170using var activity = new Activity("ambient").Start(); 249using var activity = new Activity("typed-span");

Telemetry\TelemetryConfigurationTests.cs (2)

249using var activity = source.StartActivity("parent"); 324using var diagnosticActivity = telemetry.StartDiagnosticActivity("TestDiagnosticActivity");

Telemetry\TelemetryFixture.cs (1)

118public Activity? CapturedActivity { get; private set; }

Telemetry\TelemetryShutdownTests.cs (3)

53var traceProcessor = new TestTelemetryProcessor<Activity> { ShutdownCallback = timeout => Shutdown("trace", timeout) }; 206builder.AddProcessor(new TestTelemetryProcessor<Activity> 233using var activity = source.StartActivity($"operation-{i}");

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)

100/// Do anything that is going to trigger the <see cref="Activity"/> and <see cref="ILogger"/> creation. Example: try to create a DB. 528List<Activity> exportedActivities = new();

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);

OtelTracesTests.cs (1)

35List<Activity> activities = new();

Components\Controls\Chart\ChartContainer.razor.cs (1)

135using var activity = DashboardActivitySource.ActivitySource.StartActivity("Update metric chart data from tick");

Components\Pages\Error.razor.cs (1)

24RequestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;

Model\DashboardCommandExecutor.cs (1)

53using var activity = telemetryService.StartOperation(TelemetryEventKeys.ExecuteCommand,

Model\ResourceOutgoingPeerResolver.cs (1)

75using var activity = _activitySource.StartActivity("Process resource subscription changes", ActivityKind.Consumer);

Model\TelemetryImportService.cs (1)

60using var activity = _activitySource.StartActivity("Import telemetry data", ActivityKind.Internal);

ServiceClient\DashboardClient.cs (1)

611using var activity = _activitySource.StartActivity("Process resource update", ActivityKind.Consumer);

ServiceClient\TracingSqliteConnection.cs (12)

76private static Activity? StartActivity(string query, string databaseName, ActivitySource activitySource) 79var activity = activitySource.StartActivity( 134private static void RecordException(Activity? activity, Exception exception) 189using var activity = StartActivity(query, databaseName, activitySource); 203using var activity = StartActivity(query, databaseName, activitySource); 293var activity = StartActivity(); 309var activity = StartActivity(); 335using var activity = StartActivity(); 349using var activity = StartActivity(); 361private Activity? StartActivity() => TracingSqliteConnection.StartActivity(CommandText, databaseName, activitySource); 363private sealed class TracingDbDataReader(DbDataReader reader, Activity activity) : DbDataReader 365private Activity? _activity = activity;

src\Shared\Telemetry\ActivityTagEnrichmentProcessor.cs (2)

12internal sealed class ActivityTagEnrichmentProcessor(AspireTelemetryBase telemetry) : BaseProcessor<Activity> 14public override void OnEnd(Activity data)

src\Shared\Telemetry\AspireTelemetryBase.cs (9)

58public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 71public Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext) 85protected Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<ActivityLink> links) 97public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 110public Activity? StartDiagnosticActivity(string name, ActivityKind kind, ActivityContext parentContext) 152protected void AddReportedActivityProperties(Activity activity, IEnumerable<KeyValuePair<string, object?>>? properties) 167public void SetActivityProperty(Activity? activity, string key, object? value) 187public void SetActivityProperties(Activity? activity, IEnumerable<KeyValuePair<string, object?>> properties) 253internal virtual IEnumerable<KeyValuePair<string, object?>> GetActivityDefaultTags(Activity activity) => GetDefaultTags();

Telemetry\DashboardTelemetryService.cs (4)

53public Activity? StartOperation(string eventName, Dictionary<string, AspireTelemetryProperty> startEventProperties) 60var activity = StartReportedActivity(eventName); 77public void SetActivityProperties(Activity? activity, IReadOnlyDictionary<string, AspireTelemetryProperty> properties) 88public void SetOperationStatus(Activity? activity, ActivityStatusCode status)

Pages\MetricsTests.cs (5)

397var activities = new ConcurrentQueue<Activity>(); 562var activityStarted = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); 563var activityStopped = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); 604var started = await activityStarted.Task.WaitAsync(DefaultWaitTimeout); 605var activity = await activityStopped.Task.WaitAsync(DefaultWaitTimeout);

Pages\ResourcesTests.cs (1)

64using var activity = fixture.Telemetry.StartReportedActivity("resources");

tests\Shared\DashboardTelemetryFixture.cs (2)

27public Channel<Activity> ActivityChannel { get; } = Channel.CreateUnbounded<Activity>();

Integration\HealthTests.cs (14)

47using var testActivity = fixture.TestActivitySource.StartActivity(nameof(HealthEndpoint_OtlpExporterConfigured_ExportsAspNetCoreActivity)); 57var activity = await observation.Task.DefaultTimeout(); 66using var testActivity = fixture.TestActivitySource.StartActivity(nameof(OtlpExporterConfigured_ExportsResourceServiceActivity)); 73using (var activity = activitySource.ActivitySource.StartActivity("Test resource update", ActivityKind.Consumer)) 78var exported = await observation.Task.DefaultTimeout(); 148internal sealed class TestActivityExporter : BaseExporter<Activity> 153public Observation ObserveNext(ActivityTraceId traceId, Func<Activity, bool> predicate) 164public override ExportResult Export(in Batch<Activity> batch) 166foreach (var activity in batch) 194internal sealed class Observation(TestActivityExporter exporter, ActivityTraceId traceId, Func<Activity, bool> predicate) : IDisposable 196private readonly TaskCompletionSource<Activity> _completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 199public Func<Activity, bool> Predicate { get; } = predicate; 200public Task<Activity> Task => _completion.Task; 204public void TrySetResult(Activity activity) => _completion.TrySetResult(activity);

Model\DashboardClientTests.cs (5)

790using var activity = new Activity("request").Start(); 810var activities = new ConcurrentQueue<Activity>(); 830static void AssertActivity(Activity activity, WatchResourcesUpdate.KindOneofCase kind) 1244public Activity? ActivityOnGetApplicationInformation { get; private set; } 1280ActivityOnGetApplicationInformation = Activity.Current;

Model\DashboardCommandExecutorTests.cs (5)

67Activity? commandActivity = null; 72commandActivity = Activity.Current; 88using var parent = new Activity("parent").Start(); 95Assert.Same(parent, Activity.Current); 98Assert.True(fixture.ActivityChannel.Reader.TryRead(out var activity));

Model\DashboardSqliteDatabaseTests.cs (9)

110var activities = new ConcurrentQueue<Activity>(); 118var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), query)); 133var activities = new ConcurrentQueue<Activity>(); 140var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), query)); 150var activities = new ConcurrentQueue<Activity>(); 169var activities = new ConcurrentQueue<Activity>(); 189var activities = new ConcurrentQueue<Activity>(); 197var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), "COMMIT;")); 211var activities = new ConcurrentQueue<Activity>();

Model\SqliteResourceRepositoryTests.cs (1)

1002using var operation = new Activity("Capture resource persistence queries").Start();

Model\TelemetryImportServiceTests.cs (2)

43var activities = new List<Activity>(); 49var activity = Assert.Single(activities);

ResourceOutgoingPeerResolverTests.cs (5)

359using var activity = new Activity("request").Start(); 401var activities = new ConcurrentQueue<Activity>(); 425static void AssertActivity(Activity activity) 684public TaskCompletionSource<Activity?> ActivityOnSubscribe { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 710ActivityOnSubscribe.TrySetResult(Activity.Current);

Telemetry\AspireTelemetryBaseTests.cs (6)

18using var activity = telemetry.StartReportedActivity("test-operation"); 75using var activity = telemetry.StartOperation(properties); 100using var operation = withActivity ? telemetry.StartOperation([]) : null; 101var current = Activity.Current; 106Assert.Same(current, Activity.Current);

Telemetry\AzureMonitorTelemetryProviderTests.cs (3)

27var traceProcessor = new TestTelemetryProcessor<Activity> 87var traceProcessor = new TestTelemetryProcessor<Activity>(); 133var traceProcessor = new TestTelemetryProcessor<Activity> { ForceFlushCallback = Flush, ShutdownCallback = Shutdown };

Telemetry\DashboardTelemetryLogExportTests.cs (1)

75using var activity = new Activity("ambient").Start();

Telemetry\DashboardTelemetryManagerTests.cs (1)

196var traceProcessor = new TestTelemetryProcessor<Activity> { ShutdownCallback = timeout => Shutdown("trace", timeout) };

Telemetry\DashboardTelemetryMetadataTests.cs (1)

64using var activity = new Activity("test-operation");

Telemetry\DashboardTelemetryServiceTests.cs (29)

24using var parent = new Activity("parent").Start(); 25Activity activity; 26using (var operation = service.StartOperation(TelemetryEventKeys.ExecuteCommand, new() 31activity = Assert.IsType<Activity>(operation); 33Assert.Same(activity, Activity.Current); 41Assert.Same(parent, Activity.Current); 42Assert.True(fixture.ActivityChannel.Reader.TryRead(out var recorded)); 57using var activity = fixture.Telemetry.StartReportedActivity("dashboard-operation"); 91using var activity = fixture.Telemetry.StartReportedActivity("dashboard-operation"); 107using var parent = new Activity("parent").Start(); 111Assert.Same(parent, Activity.Current); 134var previous = Activity.Current; 135Activity.Current = null; 140Assert.Null(Activity.Current); 154Activity.Current = previous; 165var activity = service.StartOperation(TelemetryEventKeys.ExecuteCommand, []); 210Activity activity; 211using (var operation = service.StartOperation(TelemetryEventKeys.ExecuteCommand, [])) 213activity = Assert.IsType<Activity>(operation); 236Assert.True(fixture.ActivityChannel.Reader.TryRead(out var recorded)); 248using var activity = service.StartReportedActivity("dashboard-operation"); 274var previous = Activity.Current; 275Activity.Current = null; 281Assert.Null(Activity.Current); 301Activity.Current = previous; 332var activity = service.StartOperation(TelemetryEventKeys.ExecuteCommand, []); 365using var activity = service.StartOperation(TelemetryEventKeys.ExecuteCommand, properties);

Telemetry\TagEnrichmentProcessorTests.cs (2)

20using var activity = new Activity("test-operation"); 39using var activity = new Activity("test-operation");

Telemetry\TelemetryLoggerProviderTests.cs (4)

47using var frameworkActivity = withActivity ? new Activity("Blazor").Start() : null; 48var current = Activity.Current; 75Assert.Same(current, Activity.Current);

Telemetry\TestTelemetryService.cs (2)

19public Activity? StartOperation(IEnumerable<KeyValuePair<string, object?>> properties) 21var activity = StartReportedActivity("test-operation");

tests\Shared\DashboardTelemetryFixture.cs (2)

27public Channel<Activity> ActivityChannel { get; } = Channel.CreateUnbounded<Activity>();

Diagnostics\ProfilingTelemetry.cs (20)

253IsEnabled(configuration) ? new(Activity.Current, configuration, ownsActivity: false) : default; 313var parentActivity = Activity.Current; 320var activity = s_activitySource.StartActivity(Activities.AppHostEventCallback); 497var activity = (Activity.Current is null || Activity.Current.Source.Name != ActivitySourceName) && 513Activity? activity; 521else if (Activity.Current is { } currentActivity) 546Activity? activity = null; 575Activity? activity; 587else if ((Activity.Current is null || Activity.Current.Source.Name != ActivitySourceName) && 602private static void AddProfilingSessionId(Activity? activity, IConfiguration? configuration, IDictionary<string, string>? annotations = null) 620private static void AddProfilingSessionId(Activity? activity, string? sessionId) 632private static void AddBaggage(Activity? activity, BackchannelTraceContext? traceContext) 645private static void AddProfilingSessionId(Activity? activity, IConfiguration? configuration, BackchannelTraceContext? traceContext) 677var ambientActivity = Activity.Current; 775internal readonly struct ActivityScope(Activity? activity, IConfiguration? configuration = null, bool ownsActivity = true) : IDisposable

Diagnostics\NativeDiagnostics.cs (3)

52private readonly Activity? _activity; 117var activity = _activity ?? Activity.Current;

tests\Aspire.Hosting.Native.Core.Tests\TestServices\DiagnosticCapture.cs (3)

56public Activity Root { get; } 57public ConcurrentQueue<Activity> Activities { get; } = []; 92if (Activity.Current?.TraceId == Root.TraceId)

DcpConnectionMaterialTests.cs (2)

22var activity = Assert.Single(capture.Activities); 88var activity = Assert.Single(capture.Activities);

NativeDiagnosticsTests.cs (3)

51var activity = Assert.Single(capture.Activities); 122var sessionRetirement = Assert.Single(capture.Activities, activity => activity.OperationName == "session.generation.retire"); 123var modelRetirement = Assert.Single(capture.Activities, activity => activity.OperationName == "model.retire");

NativeSocketIsolationTests.cs (1)

162var activity = Assert.Single(capture.Activities, value => value.OperationName == "rpc.request" &&

TestServices\DiagnosticCapture.cs (3)

56public Activity Root { get; } 57public ConcurrentQueue<Activity> Activities { get; } = []; 92if (Activity.Current?.TraceId == Root.TraceId)

Rpc\NativeRpcConnection.cs (3)

321using var incomingTrace = StartIncomingTrace(envelope); 460private static Activity? StartIncomingTrace(JsonElement envelope) 464var activity = new Activity("native.rpc.incoming")

src\Shared\DcpConnectionMaterial.cs (1)

90using var activity = s_activities.StartActivity("dcp.connection.ready");

Diagnostics\RemoteHostProfilingTelemetry.cs (12)

243var ambientActivity = Activity.Current; 244Activity? activity; 271private static bool TryGetAmbientRemoteParentContext(Activity? ambientActivity, out ActivityContext parentContext) 291private void AddProfilingSession(Activity? activity, Activity? ambientActivity) 335private static string? GetProfilingSessionId(Activity? activity) 340private static string? GetProfilingSessionIdFromAncestors(Activity? activity) 342for (var current = activity; current is not null; current = current.Parent) 353private static void AddProfilingSessionBaggage(Activity? activity, string sessionId) 355for (var current = activity; current is not null; current = current.Parent) 374internal readonly struct ActivityScope(Activity? activity) : IDisposable

AssemblyLoaderTests.cs (2)

184var activities = new List<Activity>(); 191var activity = Assert.Single(activities);

RemoteHostProfilingTelemetryTests.cs (15)

20var activities = new List<Activity>(); 59using (var parent = parentSource.StartActivity("parent")) 73var activities = new List<Activity>(); 80var activity = Assert.Single(activities); 92var activities = new List<Activity>(); 107var activities = new List<Activity>(); 121var activity = Assert.Single(activities); 134var activities = new List<Activity>(); 143var activity = Assert.Single(activities); 156var activities = new List<Activity>(); 169var activity = Assert.Single(activities); 185var activities = new List<Activity>(); 201var clientActivity = clientSource.StartActivity("client", ActivityKind.Client); 207using (var jsonRpcActivity = jsonRpcSource.StartActivity("server", ActivityKind.Server, clientContext)) 213var serverActivity = Assert.Single(activities, activity => activity.OperationName == RemoteHostProfilingTelemetry.Activities.JsonRpcServerCall);

Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (7)

2149var activities = new List<Activity>(); 2193var resolveActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.DashboardResolveUrls); 2197var connectionInfoActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.DashboardGetConnectionInfo); 2205var activities = new List<Activity>(); 2230var clientActivity = clientSource.StartActivity("client", ActivityKind.Client); 2236using (var jsonRpcActivity = jsonRpcSource.StartActivity("server", ActivityKind.Server, clientContext)) 2242var serverActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.JsonRpcServerCall);

Backchannel\BackchannelContractTests.cs (9)

251using var clientActivity = source.StartActivity("client", ActivityKind.Client); 265Assert.NotNull(Activity.Current); 266Assert.Equal(clientActivity.TraceId, Activity.Current.TraceId); 267Assert.Equal(clientActivity.SpanId, Activity.Current.ParentSpanId); 274Activity? startedActivity = null; 300var activities = new List<Activity>(); 304using var processActivity = processSource.StartActivity("process npx.CMD", ActivityKind.Internal); 313using var ambientActivity = ambientSource.StartActivity("hidden ambient", ActivityKind.Internal); 323var dcpActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.DcpRunApplication);

Dcp\DcpHostNotificationTests.cs (2)

455var activities = new ConcurrentBag<Activity>(); 476var certificateActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.DcpPrepareTlsCertificate);

DistributedApplicationTests.cs (5)

136var activities = new ConcurrentBag<Activity>(); 158var appHostStartActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostStart); 168var activities = new ConcurrentBag<Activity>(); 183var hostStartupActivity = Assert.Single(activities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostHostStartup); 2453private static ActivityListener CreateActivityListener(string sourceName, Action<Activity> activityStopped)

AspireNatsClientExtensionsTests.cs (1)

269var activity = activityList[0];

ConformanceTests.cs (1)

151List<Activity> exportedActivities = new();

AspireRabbitMQExtensions.cs (4)

193using var activity = s_activitySource.StartActivity("rabbitmq connect", ActivityKind.Client); 198using var connectAttemptActivity = s_activitySource.StartActivity("rabbitmq connect attempt", ActivityKind.Client); 213private static void AddRabbitMQTags(Activity? activity, Uri address, string? operation = null) 229private static void AddRabbitMQExceptionTags(Activity? connectAttemptActivity, Exception ex)

ConformanceTests.cs (1)

147List<Activity> exportedActivities = [];

src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\Implementation\RedisProfilerEntryToActivityConverter.cs (4)

77public static Activity? ProfilerCommandToActivity(Activity? parentActivity, IProfiledCommand command, StackExchangeRedisInstrumentationOptions options) 110var activity = activitySource.StartActivity( 239public static void DrainSession(Activity? parentActivity, IEnumerable<IProfiledCommand> sessionCommands, StackExchangeRedisInstrumentationOptions options)

src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\RedisInstrumentationContext.cs (3)

10/// Represents contextual information about a profiled Redis command off of which an <see cref="Activity"/> can be created. 14/// <see cref="Activity.Current"/> is not guaranteed to be the parent activity since commands are profiled asynchronously. 20Activity? ParentActivity,

src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\StackExchangeRedisConnectionInstrumentation.cs (4)

49internal readonly ConcurrentDictionary<(ActivityTraceId TraceId, ActivitySpanId SpanId), (Activity Activity, ProfilingSession Session)> Cache 94var parent = Activity.Current; 130var parent = entry.Value.Activity;

src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\StackExchangeRedisInstrumentationOptions.cs (7)

32/// 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. 60/// <para><see cref="Activity"/>: the activity being enriched.</para> 63public Action<Activity, RedisInstrumentationContext>? Enrich { get; set; } 81/// Gets a value indicating whether commands should be drained from profiling sessions prior to parent <see cref="Activity"/> completion. 82/// Filter and Enrich callbacks have historically been passed completed parent <see cref="Activity"/> instances. 83/// If both callbacks are null, commands may be drained prior to the parent <see cref="Activity"/> completion, 85/// If either callback is set, the old behavior is used to ensure the callbacks are passed completed parent <see cref="Activity"/> instances.

AspireRedisExtensionsTests.cs (1)

294var activity = activityList[0];

ActivityListenerHelper.cs (2)

20public static ActivityListener Create(ActivitySource targetSource, Action<Activity>? onActivityStarted = null, Action<Activity>? onActivityStopped = null)

CatalogDbInitializer.cs (1)

18using var activity = _activitySource.StartActivity("Initializing catalog database", ActivityKind.Client);

ApiDbInitializer.cs (1)

22using var activity = s_activitySource.StartActivity("Migrating database", ActivityKind.Client);

ManagedHost.cs (3)

130var _init = Activities.Source.StartActivity("hostfxr-initialization"); 167if (Activity.Current is { } currentActivity) 178using var invoke = Activities.Source.StartActivity("coreclr-invocation");

NativeEntryPoint.cs (6)

113Activity? mainActivity = null; 145using var telemetryActivity = Activities.Source.StartActivity("telemetry-setup"); 184using (var parse = Activities.Source.StartActivity("parse")) 303private static bool TryInvokeExternalCommand(ParseResult parseResult, string[] args, string sdkDir, Activity? mainActivity, string? globalJsonState, out int exitCode, out bool success) 313using (var lookupActivity = Activities.Source.StartActivity("lookup-external-command")) 385using (var invoke = Activities.Source.StartActivity("execute-extensible-command"))

parent\dotnet\CommandFactory\CommandResolution\ActivityContextFactory.cs (2)

17var currentActivity = Activity.Current;

parent\dotnet\CommandFactory\CommandResolution\CompositeCommandResolver.cs (1)

38using var resolverActivity = Activities.Source.StartActivity("resolve-command");

parent\dotnet\CommandFactory\CommandResolution\DotnetToolsCommandResolver.cs (1)

37Activity.Current?.AddTag("lookup.root_path", _dotnetToolPath);

parent\dotnet\CommandInvocation.cs (1)

31using var _ = Activities.Source.StartActivity("invocation");

parent\dotnet\Commands\Tool\Run\ToolRunCommand.cs (1)

36using var _ = Activities.Source.StartActivity("execute-local-tool");

parent\dotnet\Extensions\ActivityExtensions.cs (1)

11public static void SetDisplayName(this Activity? activity, ParseResult parseResult)

parent\dotnet\FirstRunExperience.cs (1)

61using var activity = Activities.Source.StartActivity("first-time-use");

parent\dotnet\Telemetry\InternalMicrosoft\InternalMicrosoftTelemetry.cs (2)

123internal sealed class InternalMicrosoftTelemetryProcessor(InternalMicrosoftTelemetry telemetry) : BaseProcessor<Activity> 125public override void OnEnd(Activity activity)

parent\dotnet\Telemetry\TelemetryClient.cs (4)

30private static readonly List<Activity> s_activities = []; 326Activity[] activities = [.. s_activities]; 329foreach (Activity activity in activities) 374Activity.Current?.AddEvent(@event);

parent\dotnet\Telemetry\TelemetryDiskLogger.cs (3)

50public static bool WriteLog(string logPath, IEnumerable<Activity> activities) 58foreach (var activity in activities) 73private static ActivityModel CreateActivityJsonModel(Activity activity) => new(

ComponentsActivitySource.cs (13)

34var activity = ActivitySource.CreateActivity(OnRouteName, ActivityKind.Internal, parentId: null, null, null); 37var httpActivity = Activity.Current; 39Activity.Current = null; // do not inherit the parent activity 70var activity = ActivitySource.CreateActivity(OnEventName, ActivityKind.Internal, parentId: null, null, null); 74var previousActivity = Activity.Current; 76Activity.Current = null; // do not inherit the parent activity 120var activity = activityHandle.Activity; 134if (Activity.Current == null && activityHandle.Previous != null && !activityHandle.Previous.IsStopped) 136Activity.Current = activityHandle.Previous; 147public Activity? Previous; 148public Activity? Activity;

src\aspnetcore\src\Shared\Components\ComponentsActivityLinkStore.cs (1)

44public void AddActivityContexts(string exceptCategory, Activity targetActivity)

src\aspnetcore\src\Shared\Components\ComponentsActivityLinkStore.cs (1)

44public void AddActivityContexts(string exceptCategory, Activity targetActivity)

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\aspnetcore\src\Shared\Components\ComponentsActivityLinkStore.cs (1)

44public void AddActivityContexts(string exceptCategory, Activity targetActivity)

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (2)

18public static Activity? CreateFromRemote( 29Activity? activity = null;

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (2)

18public static Activity? CreateFromRemote( 29Activity? activity = null;

Internal\HostingApplication.cs (1)

139public Activity? Activity

Internal\HostingApplicationDiagnostics.cs (8)

245var activity = context.Activity; 420private Activity? StartActivity(HttpContext httpContext, bool diagnosticsOrLoggingEnabled, out bool hasDiagnosticListener) 433var activity = ActivityCreator.CreateFromRemote( 537private void StopActivity(HttpContext httpContext, Activity activity, Exception? exception, bool hasDiagnosticListener) 554private static void SetActivityEndTags(HttpContext httpContext, Activity activity, Exception? exception) 611private Activity StartActivity(Activity activity, HttpContext httpContext) 625private void StopActivity(Activity activity, HttpContext httpContext)

Internal\HttpActivityFeature.cs (2)

14internal HttpActivityFeature(Activity activity) 20public Activity Activity { get; set; }

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (2)

18public static Activity? CreateFromRemote( 29Activity? activity = null;

Features\IHttpActivityFeature.cs (1)

16Activity Activity { get; set; }

DefaultProblemDetailsWriter.cs (1)

58var traceId = Activity.Current?.Id ?? httpContext.TraceIdentifier;

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;

Infrastructure\DefaultProblemDetailsFactory.cs (1)

105var traceId = Activity.Current?.Id ?? httpContext?.TraceIdentifier;

HubConnection.cs (7)

1282private async Task<(ConnectionState, Activity?)> WaitForActiveConnectionWithActivityAsync(string sendingMethodName, string invokedMethodName, CancellationToken token) 1286var activity = CreateActivity(invokedMethodName); 1330static void SetServerTags(Activity? activity, Uri? uri) 1379private Activity? CreateActivity(string methodName) 1381var activity = _activitySource.CreateActivity(ActivityName, ActivityKind.Client); 1382if (activity is null && Activity.Current is not null && _logger.IsEnabled(LogLevel.Critical)) 1503private static void InjectHeaders(Activity currentActivity, HubInvocationMessage invocationMessage)

Internal\InvocationRequest.cs (6)

27public Activity? Activity { get; } 29protected InvocationRequest(CancellationToken cancellationToken, Type resultType, string invocationId, ILogger logger, HubConnection hubConnection, Activity? activity) 49public static InvocationRequest Invoke(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out Task<object?> result) 57ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out ChannelReader<object?> result) 90public Streaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity) 178public NonStreaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity)

HubConnectionContext.cs (1)

70internal Activity? OriginalActivity { get; set; }

HubConnectionHandler.cs (1)

141OriginalActivity = Activity.Current,

Internal\DefaultHubDispatcher.cs (19)

89Activity? activity = null; 126Activity? activity = null; 173Activity? activity = null; 450var previousActivity = Activity.Current; 453Activity.Current = null; 458var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger, connection); 495if (Activity.Current != previousActivity) 497Activity.Current = previousActivity; 597var previousActivity = Activity.Current; 600Activity.Current = null; 603var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger, connection); 673if (Activity.Current != previousActivity) 675Activity.Current = previousActivity; 966private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger, HubConnectionContext? connection = null) 996Activity? activity; 1031private static void SetActivityError(Activity? activity, Exception ex)

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (2)

18public static Activity? CreateFromRemote( 29Activity? activity = null;

Telemetry\DiagnosticActivity.cs (3)

12/// Wraps a <see cref="Activity"/> and implements <see cref="IActivity"/>. 16private readonly Activity _activity; 19public DiagnosticActivity(Activity activity)

Telemetry\MSBuildActivitySource.cs (3)

59Activity? activity = Activity.Current?.HasRemoteParent == true 60? _source.StartActivity(eventName, ActivityKind.Internal, parentId: Activity.Current.ParentId)

Implementation\AzureMonitorTelemetrySerializer.cs (6)

10/// Serializes a batch of <see cref="Activity"/> instances into the Application Insights 36public static byte[]? SerializeBatch(in Batch<Activity> batch, TelemetryResourceContext resource, string instrumentationKey) 41foreach (var activity in batch) 49private static bool WriteActivity(Stream stream, Activity activity, TelemetryResourceContext resource, string instrumentationKey) 213private static Dictionary<string, string> BuildSpanTags(Activity activity, string traceId, bool isRequest, TelemetryResourceContext resource) 240private static Dictionary<string, string>? BuildProperties(Activity.Enumerator<KeyValuePair<string, object?>> tags)

PersistentStorageTraceExporter.cs (2)

27internal sealed class PersistentStorageTraceExporter : BaseExporter<Activity> 54public override ExportResult Export(in Batch<Activity> batch)

MSBuildForwardingAppWithoutLogging.cs (1)

185using var activity = Activities.PerformanceSource.StartActivity("msbuild-submission");

ChatCompletion\FunctionInvokingChatClient.cs (9)

285using Activity? activity = FunctionInvocationHelpers.CurrentActivityIsInvokeAgent ? null : _activitySource?.StartActivity(OpenTelemetryConsts.GenAI.OrchestrateToolsName); 445using Activity? activity = FunctionInvocationHelpers.CurrentActivityIsInvokeAgent ? null : _activitySource?.StartActivity(OpenTelemetryConsts.GenAI.OrchestrateToolsName); 489Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 506Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 595Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 632Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 658Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 692Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 722private static void AddUsageTags(Activity? activity, UsageDetails? usage)

ChatCompletion\OpenTelemetryChatClient.cs (8)

141using Activity? activity = CreateAndConfigureActivity(options); 172using Activity? activity = CreateAndConfigureActivity(options, streaming: true); 261Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 274private Activity? CreateAndConfigureActivity(ChatOptions? options, bool streaming = false) 276Activity? activity = null; 397Activity? activity, 522private void AddInputMessagesTags(IEnumerable<ChatMessage> messages, ChatOptions? options, Activity? activity) 539private void AddOutputMessagesTags(ChatResponse response, Activity? activity)

ChatCompletion\OpenTelemetryImageGenerator.cs (4)

109using Activity? activity = CreateAndConfigureActivity(request, options); 132private Activity? CreateAndConfigureActivity(ImageGenerationRequest request, ImageGenerationOptions? options) 134Activity? activity = null; 208Activity? activity,

Common\FunctionInvocationHelpers.cs (2)

14/// <summary>Gets a value indicating whether <see cref="Activity.Current"/> represents an "invoke_agent" or "invoke_workflow" span.</summary> 19string? name = Activity.Current?.DisplayName;

Common\FunctionInvocationProcessor.cs (5)

26private readonly Func<Activity?, bool> _isSensitiveDataEnabled; 43Func<Activity?, bool>? isSensitiveDataEnabled = null) 162Activity? invokeAgentActivity = FunctionInvocationHelpers.CurrentActivityIsInvokeAgent ? Activity.Current : null; 165using Activity? activity = source?.StartActivity(

Common\OpenTelemetryLog.cs (1)

21internal static void RecordOperationError(Activity? activity, ILogger? logger, Exception? error)

Embeddings\OpenTelemetryEmbeddingGenerator.cs (4)

100using Activity? activity = CreateAndConfigureActivity(options); 136private Activity? CreateAndConfigureActivity(EmbeddingGenerationOptions? options) 138Activity? activity = null; 184Activity? activity,

Files\OpenTelemetryHostedFileClient.cs (10)

141using Activity? activity = StartActivity(UploadOperationName); 202using Activity? activity = StartActivity(DownloadOperationName); 239using Activity? activity = StartActivity(GetInfoOperationName); 290using Activity? activity = StartActivity(ListOperationName); 344Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 366using Activity? activity = StartActivity(DeleteOperationName); 398private void SetErrorStatus(Activity? activity, Exception? error) => 401private void TagAdditionalProperties(Activity activity, HostedFileClientOptions? options) 412private Activity? StartActivity(string operationName) 414Activity? activity = null;

Realtime\FunctionInvokingRealtimeClientSession.cs (1)

152using Activity? activity = FunctionInvocationHelpers.CurrentActivityIsInvokeAgent ? null : _activitySource?.StartActivity(OpenTelemetryConsts.GenAI.OrchestrateToolsName);

Realtime\OpenTelemetryRealtimeClientSession.cs (9)

184using Activity? inputActivity = CreateAndConfigureActivity(options: null); 220using Activity? errorActivity = CreateAndConfigureActivity(options, streamingResponse: true); 278using Activity? responseActivity = CreateAndConfigureActivity(options, streamingResponse: true); 294using Activity? errorActivity = CreateAndConfigureActivity(options, streamingResponse: true); 305private static void AddOutputModalitiesTag(Activity? activity, HashSet<string>? outputModalities) 314private static void AddOutputMessagesTag(Activity? activity, List<RealtimeOtelMessage>? outputMessages) 662private Activity? CreateAndConfigureActivity(RealtimeSessionOptions? options, bool streamingResponse = false) 664Activity? activity = null; 739Activity? activity,

SpeechToText\OpenTelemetrySpeechToTextClient.cs (7)

110using Activity? activity = CreateAndConfigureActivity(options); 138using Activity? activity = CreateAndConfigureActivity(options); 180Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 193private Activity? CreateAndConfigureActivity(SpeechToTextOptions? options) 195Activity? activity = null; 242Activity? activity, 344private void AddOutputMessagesTags(SpeechToTextResponse response, Activity? activity)

TextToSpeech\OpenTelemetryTextToSpeechClient.cs (6)

109using Activity? activity = CreateAndConfigureActivity(options); 137using Activity? activity = CreateAndConfigureActivity(options); 179Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 192private Activity? CreateAndConfigureActivity(TextToSpeechOptions? options) 194Activity? activity = null; 241Activity? activity,

ChatClientIntegrationTests.cs (8)

218var activities = new List<Activity>(); 285var activities = new List<Activity>(); 317var activities = new List<Activity>(); 349var activities = new List<Activity>(); 376private static void AssertUsageAgainstActivities(ChatResponse response, List<Activity> activities) 406var activities = new List<Activity>(); 931var activities = new List<Activity>(); 943var activity = Assert.Single(activities);

EmbeddingGeneratorIntegrationTests.cs (2)

110var activities = new List<Activity>(); 124var activity = activities.Single();

OpenAIClientExtensions.cs (8)

323/// If the current <see cref="Activity"/> represents a "chat" operation span, 335/// If the current <see cref="Activity"/> represents a "chat" operation span, 358/// per-tag <see cref="Activity.SetTag(string, object?)"/> call. 405/// Returns <see cref="Activity.Current"/> if it has data requested and its 406/// <see cref="Activity.DisplayName"/> represents a gen_ai "chat" span 409private static Activity? GetCurrentChatActivity() 411Activity? activity = Activity.Current;

OpenAIChatClientTests.cs (2)

2096var activities = new List<Activity>(); 2126var activity = Assert.Single(activities);

OpenAIResponseClientTests.cs (2)

7243var activities = new List<Activity>(); 7273var activity = Assert.Single(activities);

ChatCompletion\FunctionInvokingChatClientTests.cs (17)

1119var activities = new List<Activity>(); 1137var executeTool = activities[1]; 1848var activities = new List<Activity>(); 1857using (var invokeAgentActivity = agentSource.StartActivity(displayName)) 1867var invokeAgent = Assert.Single(activities, a => a.DisplayName == displayName); 1879var activities = new List<Activity>(); 1911using var invokeAgentActivity = agentSource.StartActivity(displayName); 1959var activities = new List<Activity>(); 1968using (var invokeAgentActivity = agentSource.StartActivity(displayName)) 2001var activities = new List<Activity>(); 2010using (var invokeAgentActivity = agentSource.StartActivity(displayName)) 2048var activities = new List<Activity>(); 2057using (var invokeAgentActivity = agentSource.StartActivity(operationName)) 2080var executeToolActivity = Assert.Single(activities, a => a.DisplayName == "execute_tool Func1"); 2123var activities = new List<Activity>(); 2138var orchestrateTools = Assert.Single(activities, a => a.DisplayName == "orchestrate_tools"); 2142foreach (var executeTool in executeTools)

ChatCompletion\OpenTelemetryChatClientTests.cs (18)

Embeddings\OpenTelemetryEmbeddingGeneratorTests.cs (4)

24var activities = new List<Activity>(); 74var activity = Assert.Single(activities); 102var activities = new List<Activity>(); 129var activity = Assert.Single(activities);

Files\OpenTelemetryHostedFileClientTests.cs (27)

Image\OpenTelemetryImageGeneratorTests.cs (4)

31var activities = new List<Activity>(); 94var activity = Assert.Single(activities); 175var activities = new List<Activity>(); 202var activity = Assert.Single(activities);

Realtime\OpenTelemetryRealtimeClientTests.cs (27)

SpeechToText\OpenTelemetrySpeechToTextClientTests.cs (4)

36var activities = new List<Activity>(); 108var activity = Assert.Single(activities); 159var activities = new List<Activity>(); 200var activity = Assert.Single(activities);

TextToSpeech\OpenTelemetryTextToSpeechClientTests.cs (4)

33var activities = new List<Activity>(); 112var activity = Assert.Single(activities); 139var activities = new List<Activity>(); 180var activity = Assert.Single(activities);

IngestionPipeline.cs (6)

87using (Activity? rootActivity = _activitySource.StartActivity(ProcessDirectory.ActivityName)) 111using (Activity? rootActivity = _activitySource.StartActivity(ProcessFiles.ActivityName)) 122private static void TraceException(Activity? activity, Exception ex) 128private async IAsyncEnumerable<IngestionResult> ProcessAsync(IEnumerable<FileInfo> files, Activity? rootActivity, 143using (Activity? processFileActivity = _activitySource.StartActivity(ProcessFile.ActivityName, ActivityKind.Internal, parentContext: rootActivity?.Context ?? default)) 173private async Task<IngestionDocument> IngestAsync(IngestionDocument document, Activity? parentActivity, CancellationToken cancellationToken)

IngestionPipelineTests.cs (7)

82List<Activity> activities = []; 115List<Activity> activities = []; 149List<Activity> activities = []; 197List<Activity> activities = []; 228private static TracerProvider CreateTraceProvider(List<Activity> activities) 244private static void AssertActivities(List<Activity> activities, string rootActivityName) 252private static void AssertErrorActivities(List<Activity> activities, int expectedFailedActivitiesCount)

Tracing\Configuration\TracingBuilderConfigurationExtensions.cs (2)

19/// which <see cref="ActivitySource"/> and <see cref="Activity"/> instances are enabled. 22/// <para>Tracing has two key levels: <see cref="ActivitySource.Name"/> and <see cref="Activity.OperationName"/>.</para>

Tracing\DefaultActivitySourceFactory.cs (5)

196private readonly Action<Activity>? _activityStarted; 197private readonly Action<Activity>? _activityStopped; 294private void WrappedActivityStarted(Activity activity) 304private void WrappedActivityStopped(Activity activity) 314private void WrappedExceptionRecorder(Activity activity, Exception exception, ref TagList tags)

Tracing\ActivityListenerBuilder.cs (7)

37/// Gets or sets the callback invoked when an <see cref="Activity"/> is sampled from an <see cref="ActivityContext"/>. 42/// Gets or sets the callback invoked when an <see cref="Activity"/> is sampled from a parent identifier string. 47/// Gets or sets the callback invoked when a sampled <see cref="Activity"/> starts. 49public Action<Activity>? ActivityStarted { get; set; } 52/// Gets or sets the callback invoked when a sampled <see cref="Activity"/> stops. 54public Action<Activity>? ActivityStopped { get; set; } 57/// Gets or sets the callback invoked when an exception is recorded on a sampled <see cref="Activity"/>.

Tracing\ITracingBuilder.cs (1)

10/// rules to determine which <see cref="System.Diagnostics.ActivitySource"/> and <see cref="System.Diagnostics.Activity"/>

Tracing\TracingBuilderExtensions.Rules.cs (4)

20/// <param name="operationName">The <see cref="Activity.OperationName"/>, exact match. A null or empty value matches all activities within the matching sources.</param> 32/// <param name="operationName">The <see cref="Activity.OperationName"/>, exact match. A null or empty value matches all activities within the matching sources.</param> 44/// <param name="operationName">The <see cref="Activity.OperationName"/>, exact match. A null or empty value matches all activities within the matching sources.</param> 56/// <param name="operationName">The <see cref="Activity.OperationName"/>, exact match. A null or empty value matches all activities within the matching sources.</param>

Tracing\TracingRule.cs (3)

20/// <item><description>OperationName, an exact match. See <see cref="Activity.OperationName"/>.</description></item> 31/// <param name="operationName">The <see cref="Activity.OperationName"/>, exact match. A <see langword="null"/> or empty value matches all activities within the matching sources.</param> 72/// Gets the <see cref="Activity.OperationName"/>, an exact match.

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)

EventSourceLogger.cs (2)

94Activity? activity = Activity.Current;

Resolver\DnsResolver.Telemetry.cs (1)

59private readonly Activity? _activity; // null if activity is not started

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;

src\Shared\LogBuffering\SerializedLogRecordFactory.cs (2)

75Activity? activity = Activity.Current;

Buffering\GlobalBufferIncludeScopesTests.cs (1)

107using var activity = new Activity("logging");

Buffering\GlobalBufferTests.cs (7)

29using Activity activity = new Activity("logging"); 37using (Activity flushingActivity = new Activity("flushing")) 62Activity.Current = null; 63using Activity? activity = useHierarchicalActivity ? new Activity("logging") : null; 70using (Activity flushingActivity = new Activity("flushing")) 147Activity.Current = null; 150using (Activity activity = new Activity("logging"))

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");

Commands\create\InstantiateCommand.cs (4)

48using var createTemplateGroupsActivity = Activities.Source.StartActivity("create-template-groups"); 59using var getTemplateActivity = Activities.Source.StartActivity("get-template-command"); 180using var createActivity = Activities.Source.StartActivity("instantiate-command"); 251var templateParseActivity = Activities.Source.StartActivity("reparse-for-template");

Commands\create\TemplateCommand.cs (2)

164using var templateInvocationActivity = Activities.Source.StartActivity("invoke-template"); 178using var constraintResultsActivity = Activities.Source.StartActivity("validate-constraints");

TemplateInvoker.cs (3)

42using var invokerActivity = Activities.Source.StartActivity("invoker-invoking"); 164using var templateCreationActivity = Activities.Source.StartActivity("actual-instantiate-template"); 313using var postActionActivity = Activities.Source.StartActivity("post-actions");

TemplateListCoordinator.cs (1)

33using var constraintManagerActivity = Activities.Source.StartActivity("create-constraints");

OrderProcessingWorker.cs (2)

68Activity.Current?.AddTag("order-id", order.Id); 69Activity.Current?.AddTag("product-count", order.Items.Count);

Program.cs (1)

23using var activity = source.StartActivity("Chose {Number}");

LogBuffering\SerializedLogRecordFactory.cs (2)

75Activity? activity = Activity.Current;

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 (23)

160var activity = Activity.Current; 161Activity.Current = null; 165Activity.Current = activity; 201var current = Activity.Current; 202Activity.Current = null; 216Activity.Current = current; 440var span1 = traceCreator.CreateActivity("Test 1", "0485b1947fe788bb"); 443var span2 = traceCreator.CreateActivity("Test 2", "0485b1947fe788bb"); 453var current = Activity.Current; 454Activity.Current = null; 461Activity.Current = current; 482using var activity = source.StartActivity("ValidateAndUpdateCacheService.ExecuteAsync"); 485using var innerActivity = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 504using var innerActivity2 = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 532var activity = source.StartActivity("chat gpt", ActivityKind.Client); 828var activity = source.StartActivity("chat gpt", ActivityKind.Client); 847var activity = source.StartActivity("langchain llm call", ActivityKind.Client); 886var activity = source.StartActivity("chat gpt with evaluations", ActivityKind.Client); 958using var activity = source.StartActivity($"WorkIteration{index + 1}"); 968using var activity = source.StartActivity("HereActivity");

TraceCreator.cs (19)

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); 76var currentTraceId = Activity.Current?.TraceId.ToString(); 96using var activity = s_activitySource.StartActivity(ActivityKind.Client, name: resolvedName, links: distinctLinks); 114private static void AddEvents(Activity activity) 147var a = _allActivities[Random.Shared.Next(0, _allActivities.Count)]; 172var previous = Activity.Current; 173Activity.Current = null; 175var activity = s_activitySource.StartActivity("linked-trace-span", ActivityKind.Internal); 180typeof(Activity).GetField("_spanId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, activityContext.SpanId.ToString()); 181typeof(Activity).GetField("_traceId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, activityContext.TraceId.ToString()); 185Activity.Current = previous;

System\Diagnostics\Activity.cs (47)

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) 210public Activity? Parent { get; private set; } 387for (Activity? activity = this; activity != null; activity = activity.Parent) 397static IEnumerable<KeyValuePair<string, string?>> Iterate(Activity? activity) 489public Activity AddTag(string key, string? value) => AddTag(key, (object?)value); 499public Activity AddTag(string key, object? value) 523public Activity SetTag(string key, object? value) 540public Activity AddEvent(ActivityEvent e) 565public Activity AddException(Exception exception, in TagList tags = default, DateTimeOffset timestamp = default) 625public Activity AddLink(ActivityLink link) 644public Activity AddBaggage(string key, string? value) 668public Activity SetBaggage(string key, string? value) 689public Activity SetParentId(string parentId) 719public Activity SetParentId(ActivityTraceId traceId, ActivitySpanId spanId, ActivityTraceFlags activityTraceFlags = ActivityTraceFlags.None) 749public Activity SetStartTime(DateTime startTimeUtc) 769public Activity SetEndTime(DateTime endTimeUtc) 798/// Use <see cref="DiagnosticSource.StartActivity(Activity, object)"/> to start activity and write start event. 800/// <seealso cref="DiagnosticSource.StartActivity(Activity, object)"/> 802public Activity Start() 854/// Use <see cref="DiagnosticSource.StopActivity(Activity, object)"/> to stop activity and write stop event. 856/// <seealso cref="DiagnosticSource.StopActivity(Activity, object)"/> 899for (Activity? activity = this; activity != null; activity = activity.Parent) 1064public Activity SetIdFormat(ActivityIdFormat format) 1193internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 1197Activity activity = new Activity(name); 1281private static void SetCurrent(Activity? activity) 1290Activity? previous = s_current.Value; 1452private static bool ValidateSetCurrent(Activity? activity) 1537/// Indicates whether this <see cref="Activity"/> object is stopped 1540/// 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. 1625private Activity? _activity; 1630internal BaggageEnumerator(Activity? activity) 2297internal sealed class ActivityDebuggerProxy(Activity activity) 2310public 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 (6)

16private readonly Activity.TagsLinkedList? _tags; 42_tags = tags.Count > 0 ? new Activity.TagsLinkedList(tags.Tags) : null; 53_tags = tagsCount > 0 ? new Activity.TagsLinkedList(tags!) : null; 74/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 75public 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)

System\Diagnostics\ActivitySource.cs (39)

System\Diagnostics\DiagnosticListener.cs (4)

284internal Action<Activity, object?>? OnActivityImport; 285internal Action<Activity, object?>? OnActivityExport; 435Action<Activity, object?>? onActivityImport, Action<Activity, object?>? onActivityExport)

System\Diagnostics\DiagnosticSourceActivity.cs (17)

System\Diagnostics\DistributedContextPropagator.cs (4)

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); 126internal static void InjectBaggage(object? carrier, Activity? activity, PropagatorSetterCallback setter) 133Activity.BaggageEnumerator e = activity.EnumerateBaggage();

System\Diagnostics\DsesActivitySourceListener.cs (3)

156[DynamicDependency(DynamicallyAccessedMemberTypes.PublicProperties, typeof(Activity))] 164private void OnActivityStarted(Activity activity) 175private void OnActivityStopped(Activity activity)

System\Diagnostics\DsesFilterAndTransform.cs (1)

945return 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 (7)

14public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter) 21GetRootId(out string? parentId, out string? traceState, out bool isW3c, out Activity? rootActivity); 41private static void GetRootId(out string? parentId, out string? traceState, out bool isW3c, out Activity? rootActivity) 43Activity? activity = Activity.Current; 45while (activity?.Parent is Activity parent) 52isW3c = parentId is not null ? Activity.TryConvertIdToContext(parentId, traceState, isRemote: false, out _) : false;

System\Diagnostics\W3CPropagator.cs (3)

33public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter) 268internal static void InjectW3CBaggage(object? carrier, Activity activity, PropagatorSetterCallback setter) 270Activity.BaggageEnumerator e = activity.EnumerateBaggage();

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)

578private async ValueTask<(Stream, TransportContext?, Activity?, IPEndPoint?, long)> ConnectAsync(HttpRequestMessage request, bool async, bool isForHttp2, CancellationToken cancellationToken) 590Activity? 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, long connectionId) = await ConnectAsync(request, async, isForHttp2: false, cancellationToken).ConfigureAwait(false); 300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, long connectionId, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (3)

196(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, long connectionId) = await ConnectAsync(queueItem.Request, true, isForHttp2: true, cts.Token).ConfigureAwait(false); 255private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, long connectionId, CancellationToken cancellationToken) 310private async Task HandleHttp11Downgrade(HttpRequestMessage request, Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, long connectionId, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (1)

262Activity? 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)

137public Http2Connection(HttpConnectionPool pool, Stream stream, Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint, long connectionId)

System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)

93public void InitQuicConnection(QuicConnection connection, Activity? connectionSetupActivity, DnsEndPoint connectedEndPoint) 947private Activity? _activity;

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (1)

76Activity? connectionSetupActivity,

System\Net\Http\SocketsHttpHandler\HttpConnectionBase.cs (3)

69public Activity? ConnectionSetupActivity { get; private set; } 79public HttpConnectionBase(HttpConnectionPool pool, long connectionId, Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint) 90protected void MarkConnectionAsEstablished(Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint, HttpAuthority authority, DnsEndPoint? connectedEndPoint = null)

System\Net\Dns.cs (3)

937Activity? activityToRestore = tracingEnabled ? Activity.Current : null; 942Activity.Current = activityToRestore;

System\Net\NameResolutionTelemetry.cs (1)

167private readonly Activity? _activity;

System\Net\Security\NetSecurityTelemetry.cs (3)

316public static Activity? StartActivity(SslStream stream) 318using Activity? activity = s_activitySource.StartActivity(ActivityName); 331public static void StopActivity(Activity? activity, Exception? exception, SslStream stream)

System\Net\Security\SslStream.IO.cs (1)

122Activity? activity = NetSecurityTelemetry.StartActivity(this);

System\Net\Sockets\Socket.cs (1)

3375Activity? 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)

84public Activity? ConnectStart(SocketAddress address, ProtocolType protocolType, EndPoint endPoint, bool keepActivityCurrent) 93Activity? activity = null; 96Activity? activityToReset = keepActivityCurrent ? Activity.Current : null; 101Activity.Current = activityToReset; 139static void SetNetworkTransport(Activity activity, string transportType) => activity.SetTag("network.transport", transportType); 145public void AfterConnect(SocketError error, Activity? activity, string? exceptionMessage = null)