Activity

Model\DashboardClientTests.cs (1)

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

Model\SqliteResourceRepositoryTests.cs (1)

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

ResourceOutgoingPeerResolverTests.cs (1)

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

TelemetryRepositoryTests\MetricsTests.cs (5)

1694using var parent = new Activity("metric exemplar attributes test").Start(); 1726using var parent = new Activity("metric metadata test").Start(); 2139using var parent = new Activity("metric ingestion test").Start(); 2272using var parent = new Activity("metric exemplar test").Start(); 2324using var parent = new Activity("metric update test").Start();

TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (1)

209using var parent = new Activity("cache hydration test").Start();

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

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)

1193Activity 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(); 493using var activity = telemetry.StartDiagnosticActivity(); 510using var activity = telemetry.StartDiagnosticActivity(); 525using var activity = telemetry.StartDiagnosticActivity(); 540using var activity = telemetry.StartDiagnosticActivity(); 559using var activity = telemetry.StartDiagnosticActivity();

Backchannel\ExtensionBackchannel.cs (27)

Certificates\CertificateService.cs (1)

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

Commands\AddCommand.cs (1)

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

Commands\AgentTelemetryCommand.cs (1)

113using 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)

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

Commands\DescribeCommand.cs (1)

126using 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)

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

Commands\IntegrationSearchCommand.cs (1)

52using 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)

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

Commands\PipelineCommandBase.cs (1)

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

Commands\PsCommand.cs (1)

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

Commands\RestoreCommand.cs (1)

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

Commands\RunCommand.cs (1)

249Activity? runActivity = null;

Commands\TelemetryLogsCommand.cs (1)

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

Commands\TelemetrySpansCommand.cs (1)

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

Commands\TelemetryTracesCommand.cs (1)

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

Commands\TerminalAttachCommand.cs (1)

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

Commands\TerminalPsCommand.cs (1)

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

Commands\WaitCommand.cs (1)

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

DotNet\DotNetCliRunner.cs (16)

NuGet\NuGetPackageCache.cs (2)

120using var activity = telemetry.StartDiagnosticActivity(); 191using var activity = telemetry.StartDiagnosticActivity();

Program.cs (1)

1127using var mainActivity = isAgentTelemetryInvocation

Projects\ExtensionGuestLauncher.cs (1)

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

Projects\GuestAppHostProject.cs (2)

392var startProjectContext = Activity.Current?.Context ?? default; 1053var startProjectContext = Activity.Current?.Context ?? default;

Projects\ProcessGuestLauncher.cs (5)

52var activity = GetCurrentProfilingActivity(); 198private static Activity? GetCurrentProfilingActivity() 200var activity = Activity.Current; 204private static void AddEvent(Activity? activity, string eventName, string? tagName = null, object? tagValue = null)

Projects\ProjectLocator.cs (1)

291using var activity = telemetry.StartDiagnosticActivity();

Telemetry\AspireCliTelemetry.cs (11)

137public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 145public Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext) 157public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 165public Activity? StartDiagnosticActivity(string name, ActivityKind kind, ActivityContext parentContext) 170private static Activity? StartActivityCore(ActivitySource source, string name, ActivityKind kind) 175private static Activity? StartActivityCore(ActivitySource source, string name, ActivityKind kind, ActivityContext? parentContext) 180var activity = parentContext is { } context 196var activity = FindReportedActivity(Activity.Current); 342private Activity? FindReportedActivity(Activity? activity)

Telemetry\CliTagEnrichmentProcessor.cs (2)

15internal sealed class CliTagEnrichmentProcessor : BaseProcessor<Activity> 24public override void OnEnd(Activity activity)

Telemetry\ProfilingTelemetry.cs (19)

255public ActivityScope CurrentActivity => IsEnabled ? new(Activity.Current, ownsActivity: false) : default; 265AddActivityContextToEnvironment(Activity.Current, environment); 268public static void AddActivityContextToEnvironment(Activity? activity, IDictionary<string, string> environment) 671var ambientActivity = Activity.Current; 672Activity? activity; 693if (restoreAmbientActivity && ReferenceEquals(Activity.Current, activity)) 695Activity.Current = ambientActivity; 701private void AddProfilingSession(Activity? activity, Activity? ambientActivity) 740private static string? GetProfilingSessionId(Activity? activity) 745private static string? GetProfilingSessionIdFromAncestors(Activity? activity) 747for (var current = activity; current is not null; current = current.Parent) 758private static void AddProfilingSessionBaggage(Activity? activity, string sessionId) 760for (var current = activity; current is not null; current = current.Parent) 779internal static void SetProcessInvocation(Activity? activity, string executablePath, IReadOnlyList<string> args) 813var currentActivity = Activity.Current; 819internal readonly struct ActivityScope(Activity? activity, bool ownsActivity = true) : IDisposable

Utils\AppHostHelper.cs (1)

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

Utils\SdkInstallHelper.cs (1)

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

Commands\AgentTelemetryCommandTests.cs (8)

36var activity = Assert.Single(capturedActivities); 68var activity = Assert.Single(capturedActivities); 99var activity = Assert.Single(capturedActivities); 131var activity = Assert.Single(capturedActivities); 157var activity = Assert.Single(capturedActivities); 251var activity = Assert.Single(capturedActivities); 257private static (List<Activity> Activities, ActivityListener Listener) CreateCapturingListener(out string reportedSourceName) 260var captured = new List<Activity>();

Commands\AppHostLauncherTests.cs (4)

852using var activity = source.StartActivity("parent"); 918var environment = AppHostLauncher.CreateDetachedChildEnvironment(Activity.Current, appHostSelectionOrigin: null); 925Assert.Equal(Activity.Current?.Id, environment[ProfilingTelemetry.EnvironmentVariables.TraceParent]); 933using 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)

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

DotNet\DotNetCliRunnerTests.cs (6)

721var currentActivity = Activity.Current; 752var startedActivities = new ConcurrentQueue<Activity>(); 785runSpanId = Activity.Current!.SpanId; 809var processActivity = Assert.Single(sessionActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.Process); 810var 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 => 146private static bool IsActivityFromSession(Activity activity, string operationName, string sessionId)

Projects\AppHostCandidateFinderTests.cs (6)

218var startedActivities = new List<Activity>(); 232var discoveryActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateDiscovery); 238var matchActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateGitMatch); 274var startedActivities = new List<Activity>(); 293var discoveryActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateDiscovery); 297var walkActivity = Assert.Single(startedActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.AppHostCandidateFilesystemWalk);

Projects\AppHostServerSessionTests.cs (2)

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

Projects\GuestRuntimeTests.cs (3)

261var stoppedActivities = new ConcurrentBag<Activity>(); 775var stoppedActivities = new ConcurrentBag<Activity>(); 807var activity = Assert.Single(stoppedActivities, activity =>

Telemetry\AspireCliTelemetryTests.cs (12)

20using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 33using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal, parentContext); 45using var activity = fixture.Telemetry.StartDiagnosticActivity("test-diagnostic"); 65using var activity = fixture.Telemetry.StartDiagnosticActivity("test-client", ActivityKind.Client); 78using var activity = fixture.Telemetry.StartDiagnosticActivity("test-activity", ActivityKind.Internal, parentContext); 90using var activity = fixture.Telemetry.StartDiagnosticActivity(); 117using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 173using var reportedActivity = fixture.Telemetry.StartReportedActivity("parent-activity", ActivityKind.Internal); 178using var childActivity = otherSource.StartActivity("child-activity"); 199using var activity = fixture.Telemetry.StartDiagnosticActivity("test-activity"); 252using var activity = fixture.Telemetry.StartReportedActivity(TelemetryConstants.Activities.Main); 416using var activity = fixture.Telemetry.StartReportedActivity("test-activity");

Telemetry\CliTagEnrichmentProcessorTests.cs (2)

28using var activity = source.StartActivity("test-op")!; 73using var activity = source.StartActivity("test-op")!;

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\TelemetryConfigurationTests.cs (2)

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

Telemetry\TelemetryFixture.cs (1)

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

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. 526List<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)

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

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

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

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)

566using 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;

Pages\MetricsTests.cs (5)

128var activities = new ConcurrentQueue<Activity>(); 284var activityStarted = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); 285var activityStopped = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); 326var started = await activityStarted.Task.WaitAsync(DefaultWaitTimeout); 327var activity = await activityStopped.Task.WaitAsync(DefaultWaitTimeout);

Integration\HealthTests.cs (14)

46using var testActivity = fixture.TestActivitySource.StartActivity(nameof(HealthEndpoint_OtlpExporterConfigured_ExportsAspNetCoreActivity)); 56var activity = await observation.Task.DefaultTimeout(); 65using var testActivity = fixture.TestActivitySource.StartActivity(nameof(OtlpExporterConfigured_ExportsResourceServiceActivity)); 72using (var activity = activitySource.ActivitySource.StartActivity("Test resource update", ActivityKind.Consumer)) 77var exported = await observation.Task.DefaultTimeout(); 108internal sealed class TestActivityExporter : BaseExporter<Activity> 113public Observation ObserveNext(ActivityTraceId traceId, Func<Activity, bool> predicate) 124public override ExportResult Export(in Batch<Activity> batch) 126foreach (var activity in batch) 154internal sealed class Observation(TestActivityExporter exporter, ActivityTraceId traceId, Func<Activity, bool> predicate) : IDisposable 156private readonly TaskCompletionSource<Activity> _completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 159public Func<Activity, bool> Predicate { get; } = predicate; 160public Task<Activity> Task => _completion.Task; 164public void TrySetResult(Activity activity) => _completion.TrySetResult(activity);

Model\DashboardClientTests.cs (5)

289using var activity = new Activity("request").Start(); 309var activities = new ConcurrentQueue<Activity>(); 329static void AssertActivity(Activity activity, WatchResourcesUpdate.KindOneofCase kind) 604public Activity? ActivityOnGetApplicationInformation { get; private set; } 630ActivityOnGetApplicationInformation = Activity.Current;

Model\DashboardSqliteDatabaseTests.cs (9)

103var activities = new ConcurrentQueue<Activity>(); 111var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), query)); 126var activities = new ConcurrentQueue<Activity>(); 133var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), query)); 143var activities = new ConcurrentQueue<Activity>(); 162var activities = new ConcurrentQueue<Activity>(); 182var activities = new ConcurrentQueue<Activity>(); 190var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), "COMMIT;")); 204var activities = new ConcurrentQueue<Activity>();

Model\SqliteResourceRepositoryTests.cs (1)

938using 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); 706ActivityOnSubscribe.TrySetResult(Activity.Current);

TelemetryRepositoryTests\MetricsTests.cs (10)

1692var activities = new ConcurrentQueue<Activity>(); 1694using var parent = new Activity("metric exemplar attributes test").Start(); 1724var activities = new ConcurrentQueue<Activity>(); 1726using var parent = new Activity("metric metadata test").Start(); 2137var activities = new ConcurrentQueue<Activity>(); 2139using var parent = new Activity("metric ingestion test").Start(); 2270var activities = new ConcurrentQueue<Activity>(); 2272using var parent = new Activity("metric exemplar test").Start(); 2322var activities = new ConcurrentQueue<Activity>(); 2324using var parent = new Activity("metric update test").Start();

TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (2)

207var activities = new ConcurrentQueue<Activity>(); 209using var parent = new Activity("cache hydration test").Start();

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\RemoteHostProfilingTelemetry.cs (12)

226var ambientActivity = Activity.Current; 227Activity? activity; 254private static bool TryGetAmbientRemoteParentContext(Activity? ambientActivity, out ActivityContext parentContext) 274private void AddProfilingSession(Activity? activity, Activity? ambientActivity) 318private static string? GetProfilingSessionId(Activity? activity) 323private static string? GetProfilingSessionIdFromAncestors(Activity? activity) 325for (var current = activity; current is not null; current = current.Parent) 336private static void AddProfilingSessionBaggage(Activity? activity, string sessionId) 338for (var current = activity; current is not null; current = current.Parent) 357internal readonly struct ActivityScope(Activity? activity) : IDisposable

AssemblyLoaderTests.cs (2)

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

RemoteHostProfilingTelemetryTests.cs (14)

25using (var parent = parentSource.StartActivity("parent")) 39var activities = new List<Activity>(); 46var activity = Assert.Single(activities); 58var activities = new List<Activity>(); 73var activities = new List<Activity>(); 87var activity = Assert.Single(activities); 100var activities = new List<Activity>(); 109var activity = Assert.Single(activities); 122var activities = new List<Activity>(); 135var activity = Assert.Single(activities); 151var activities = new List<Activity>(); 167var clientActivity = clientSource.StartActivity("client", ActivityKind.Client); 173using (var jsonRpcActivity = jsonRpcSource.StartActivity("server", ActivityKind.Server, clientContext)) 179var 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)

488var activities = new ConcurrentBag<Activity>(); 509var 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); 2442private static ActivityListener CreateActivityListener(string sourceName, Action<Activity> activityStopped)

AspireNatsClientExtensionsTests.cs (1)

269var activity = activityList[0];

ConformanceTests.cs (1)

151List<Activity> exportedActivities = new();

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)

ConformanceTests.cs (1)

165List<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)

48internal readonly ConcurrentDictionary<(ActivityTraceId TraceId, ActivitySpanId SpanId), (Activity Activity, ProfilingSession Session)> Cache 93var parent = Activity.Current; 129var 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);

CommandFactory\CommandResolution\ActivityContextFactory.cs (2)

17var currentActivity = Activity.Current;

CommandFactory\CommandResolution\CompositeCommandResolver.cs (1)

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

CommandFactory\CommandResolution\DotnetToolsCommandResolver.cs (1)

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

CommandInvocation.cs (1)

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

Commands\MSBuild\MSBuildLogger.cs (2)

53private Activity? _activity; 211Activity.Current?.Context

Commands\Tool\Execute\ToolExecuteCommand.cs (2)

60var toolLocationActivity = Activities.Source.StartActivity("find-tool"); 139using var toolExecuteActivity = Activities.Source.StartActivity("execute-tool");

Commands\Tool\Install\ToolInstallGlobalOrToolPathCommand.cs (3)

172using var _activity = Activities.Source.StartActivity("install-tool"); 224var toolPackageDownloaderActivity = Activities.Source.StartActivity("download-tool-package"); 249var shimActivity = Activities.Source.StartActivity("create-shell-shim");

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

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

Extensions\ActivityExtensions.cs (1)

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

FirstRunExperience.cs (1)

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

InteractiveConsole.cs (1)

32using var _ = Activities.Source.StartActivity("confirm-run-from-source");

Program.cs (5)

22private static readonly Activity? s_mainActivity; 51using (var telemetrySetupActivity = Activities.Source.StartActivity("telemetry-setup")) 160using (var parseActivity = Activities.Source.StartActivity("parse")) 178using (var lookupActivity = Activities.Source.StartActivity("lookup-external-command")) 194using var __ = Activities.Source.StartActivity("execute-extensible-command");

Telemetry\TelemetryClient.cs (4)

29private static readonly List<Activity> s_activities = []; 315Activity[] activities = [.. s_activities]; 318foreach (Activity activity in activities) 360Activity.Current?.AddEvent(@event);

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(

ToolPackage\ToolPackageDownloader.cs (2)

69var _downloadActivity = Activities.Source.StartActivity("download-tool"); 96var _extractActivity = Activities.Source.StartActivity("extract-tool");

ToolPackage\ToolPackageDownloaderBase.cs (2)

193var _moveContentActivity = Activities.Source.StartActivity("move-global-tool-content"); 382using var _updateRuntimeConfigActivity = Activities.Source.StartActivity("update-runtimeconfig");

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")) 301private static bool TryInvokeExternalCommand(ParseResult parseResult, string[] args, string sdkDir, Activity? mainActivity, string? globalJsonState, out int exitCode, out bool success) 311using (var lookupActivity = Activities.Source.StartActivity("lookup-external-command")) 383using (var invoke = Activities.Source.StartActivity("execute-extensible-command"))

src\sdk\src\Cli\dotnet\CommandFactory\CommandResolution\ActivityContextFactory.cs (2)

17var currentActivity = Activity.Current;

src\sdk\src\Cli\dotnet\CommandFactory\CommandResolution\CompositeCommandResolver.cs (1)

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

src\sdk\src\Cli\dotnet\CommandFactory\CommandResolution\DotnetToolsCommandResolver.cs (1)

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

src\sdk\src\Cli\dotnet\CommandInvocation.cs (1)

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

src\sdk\src\Cli\dotnet\Commands\Tool\Run\ToolRunCommand.cs (1)

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

src\sdk\src\Cli\dotnet\Extensions\ActivityExtensions.cs (1)

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

src\sdk\src\Cli\dotnet\FirstRunExperience.cs (1)

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

src\sdk\src\Cli\dotnet\Telemetry\TelemetryClient.cs (4)

29private static readonly List<Activity> s_activities = []; 315Activity[] activities = [.. s_activities]; 318foreach (Activity activity in activities) 360Activity.Current?.AddEvent(@event);

src\sdk\src\Cli\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)

132public Activity? Activity

Internal\HostingApplicationDiagnostics.cs (8)

230var activity = context.Activity; 405private Activity? StartActivity(HttpContext httpContext, bool diagnosticsOrLoggingEnabled, out bool hasDiagnosticListener) 418var activity = ActivityCreator.CreateFromRemote( 504private void StopActivity(HttpContext httpContext, Activity activity, Exception? exception, bool hasDiagnosticListener) 521private static void SetActivityEndTags(HttpContext httpContext, Activity activity, Exception? exception) 569private Activity StartActivity(Activity activity, HttpContext httpContext) 583private 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)

68internal 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); 672if (Activity.Current != previousActivity) 674Activity.Current = previousActivity; 950private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger, HubConnectionContext? connection = null) 980Activity? activity; 1015private 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)

47Activity? activity = Activity.Current?.HasRemoteParent == true 48? _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)

Activities.cs (2)

9/// Contains helpers for working with <see cref="Activity">Activities</see> in the .NET CLI. 14/// The main entrypoint for creating <see cref="Activity">Activities</see> in the .NET CLI.

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) 157Activity? invokeAgentActivity = FunctionInvocationHelpers.CurrentActivityIsInvokeAgent ? Activity.Current : null; 160using 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)

355/// If the current <see cref="Activity"/> represents a "chat" operation span, 367/// If the current <see cref="Activity"/> represents a "chat" operation span, 390/// per-tag <see cref="Activity.SetTag(string, object?)"/> call. 437/// Returns <see cref="Activity.Current"/> if it has data requested and its 438/// <see cref="Activity.DisplayName"/> represents a gen_ai "chat" span 441private static Activity? GetCurrentChatActivity() 443Activity? activity = Activity.Current;

OpenAIChatClientTests.cs (2)

2015var activities = new List<Activity>(); 2045var activity = Assert.Single(activities);

OpenAIResponseClientTests.cs (2)

6757var activities = new List<Activity>(); 6787var activity = Assert.Single(activities);

ChatCompletion\FunctionInvokingChatClientTests.cs (17)

1119var activities = new List<Activity>(); 1137var executeTool = activities[1]; 1695var activities = new List<Activity>(); 1704using (var invokeAgentActivity = agentSource.StartActivity(displayName)) 1714var invokeAgent = Assert.Single(activities, a => a.DisplayName == displayName); 1726var activities = new List<Activity>(); 1758using var invokeAgentActivity = agentSource.StartActivity(displayName); 1806var activities = new List<Activity>(); 1815using (var invokeAgentActivity = agentSource.StartActivity(displayName)) 1848var activities = new List<Activity>(); 1857using (var invokeAgentActivity = agentSource.StartActivity(displayName)) 1895var activities = new List<Activity>(); 1904using (var invokeAgentActivity = agentSource.StartActivity(operationName)) 1927var executeToolActivity = Assert.Single(activities, a => a.DisplayName == "execute_tool Func1"); 1970var activities = new List<Activity>(); 1985var orchestrateTools = Assert.Single(activities, a => a.DisplayName == "orchestrate_tools"); 1989foreach (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;

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

CoordinatorTelemetry.cs (1)

11/// On .NET, activities are emitted via <see cref="System.Diagnostics.Activity"/>.

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

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)

104var activity = Activity.Current; 105Activity.Current = null; 109Activity.Current = activity; 145var current = Activity.Current; 146Activity.Current = null; 160Activity.Current = current; 384var span1 = traceCreator.CreateActivity("Test 1", "0485b1947fe788bb"); 387var span2 = traceCreator.CreateActivity("Test 2", "0485b1947fe788bb"); 397var current = Activity.Current; 398Activity.Current = null; 405Activity.Current = current; 426using var activity = source.StartActivity("ValidateAndUpdateCacheService.ExecuteAsync"); 429using var innerActivity = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 448using var innerActivity2 = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 476var activity = source.StartActivity("chat gpt", ActivityKind.Client); 772var activity = source.StartActivity("chat gpt", ActivityKind.Client); 791var activity = source.StartActivity("langchain llm call", ActivityKind.Client); 830var activity = source.StartActivity("chat gpt with evaluations", ActivityKind.Client); 902using var activity = source.StartActivity($"WorkIteration{index + 1}"); 912using 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) 206public Activity? Parent { get; private set; } 383for (Activity? activity = this; activity != null; activity = activity.Parent) 393static IEnumerable<KeyValuePair<string, string?>> Iterate(Activity? activity) 485public Activity AddTag(string key, string? value) => AddTag(key, (object?)value); 495public Activity AddTag(string key, object? value) 519public Activity SetTag(string key, object? value) 536public Activity AddEvent(ActivityEvent e) 561public Activity AddException(Exception exception, in TagList tags = default, DateTimeOffset timestamp = default) 621public Activity AddLink(ActivityLink link) 640public Activity AddBaggage(string key, string? value) 664public Activity SetBaggage(string key, string? value) 685public Activity SetParentId(string parentId) 715public Activity SetParentId(ActivityTraceId traceId, ActivitySpanId spanId, ActivityTraceFlags activityTraceFlags = ActivityTraceFlags.None) 745public Activity SetStartTime(DateTime startTimeUtc) 765public Activity SetEndTime(DateTime endTimeUtc) 794/// Use <see cref="DiagnosticSource.StartActivity(Activity, object)"/> to start activity and write start event. 796/// <seealso cref="DiagnosticSource.StartActivity(Activity, object)"/> 798public Activity Start() 850/// Use <see cref="DiagnosticSource.StopActivity(Activity, object)"/> to stop activity and write stop event. 852/// <seealso cref="DiagnosticSource.StopActivity(Activity, object)"/> 895for (Activity? activity = this; activity != null; activity = activity.Parent) 1060public Activity SetIdFormat(ActivityIdFormat format) 1189internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 1193Activity activity = new Activity(name); 1274private static void SetCurrent(Activity? activity) 1283Activity? previous = s_current.Value; 1445private static bool ValidateSetCurrent(Activity? activity) 1530/// Indicates whether this <see cref="Activity"/> object is stopped 1533/// 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. 1618private Activity? _activity; 1623internal BaggageEnumerator(Activity? activity) 2267internal sealed class ActivityDebuggerProxy(Activity activity) 2280public 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)

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); 125internal static void InjectBaggage(object? carrier, Activity? activity, PropagatorSetterCallback setter) 132Activity.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) 237internal static void InjectW3CBaggage(object? carrier, Activity activity, PropagatorSetterCallback setter) 239Activity.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)

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

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

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