Activity

Model\DashboardClientTests.cs (1)

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

Model\SqliteResourceRepositoryTests.cs (1)

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

228using 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 (29)

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)

191using (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)

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)

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

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

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

Commands\TerminalPsCommand.cs (1)

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

Commands\TerminalTapePlayCommand.cs (1)

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

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

Program.cs (1)

1165using var mainActivity = isAgentTelemetryInvocation

Projects\ExtensionGuestLauncher.cs (1)

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

Projects\GuestAppHostProject.cs (2)

399var startProjectContext = Activity.Current?.Context ?? default; 1073var startProjectContext = Activity.Current?.Context ?? default;

Projects\ProcessGuestLauncher.cs (5)

47var activity = GetCurrentProfilingActivity(); 193private static Activity? GetCurrentProfilingActivity() 195var activity = Activity.Current; 199private 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 (12)

143public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 151public Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext) 163public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 171public Activity? StartDiagnosticActivity(string name, ActivityKind kind, ActivityContext parentContext) 176private static Activity? StartActivityCore(ActivitySource source, string name, ActivityKind kind) 181private static Activity? StartActivityCore(ActivitySource source, string name, ActivityKind kind, ActivityContext? parentContext) 186var activity = parentContext is { } context 202var activity = FindReportedActivity(Activity.Current); 447using var activity = StartReportedActivity(TelemetryConstants.Activities.InternalMicrosoftDetector); 501private Activity? FindReportedActivity(Activity? activity)

Telemetry\CliTagEnrichmentProcessor.cs (2)

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

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

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)

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

DotNet\DotNetCliRunnerTests.cs (6)

764var currentActivity = Activity.Current; 795var startedActivities = new ConcurrentQueue<Activity>(); 828runSpanId = Activity.Current!.SpanId; 852var processActivity = Assert.Single(sessionActivities, activity => activity.OperationName == ProfilingTelemetry.Activities.Process); 853var 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)

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

Projects\GuestRuntimeTests.cs (3)

259var stoppedActivities = new ConcurrentBag<Activity>(); 962var stoppedActivities = new ConcurrentBag<Activity>(); 993var activity = Assert.Single(stoppedActivities, activity =>

Telemetry\AgentTelemetryPersistenceTests.cs (2)

128using (var activity = source.StartActivity(TelemetryConstants.Activities.AgentTelemetry)) 250using var activity = source.StartActivity(TelemetryConstants.Activities.AgentTelemetry);

Telemetry\AspireCliTelemetryTests.cs (15)

Telemetry\CliTagEnrichmentProcessorTests.cs (3)

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

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)

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

Telemetry\TelemetryFixture.cs (1)

114public 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. 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\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)

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

125var activities = new ConcurrentQueue<Activity>(); 290var activityStarted = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); 291var activityStopped = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); 332var started = await activityStarted.Task.WaitAsync(DefaultWaitTimeout); 333var 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)

605using var activity = new Activity("request").Start(); 625var activities = new ConcurrentQueue<Activity>(); 645static void AssertActivity(Activity activity, WatchResourcesUpdate.KindOneofCase kind) 1057public Activity? ActivityOnGetApplicationInformation { get; private set; } 1093ActivityOnGetApplicationInformation = Activity.Current;

Model\DashboardSqliteDatabaseTests.cs (9)

107var activities = new ConcurrentQueue<Activity>(); 115var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), query)); 130var activities = new ConcurrentQueue<Activity>(); 137var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), query)); 147var activities = new ConcurrentQueue<Activity>(); 166var activities = new ConcurrentQueue<Activity>(); 186var activities = new ConcurrentQueue<Activity>(); 194var activity = Assert.Single(activities, activity => Equals(activity.GetTagItem("db.query.text"), "COMMIT;")); 208var activities = new ConcurrentQueue<Activity>();

Model\SqliteResourceRepositoryTests.cs (1)

980using 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); 709ActivityOnSubscribe.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)

226var activities = new ConcurrentQueue<Activity>(); 228using 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)

489var activities = new ConcurrentBag<Activity>(); 510var 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();

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

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

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\TelemetryClient.cs (4)

29private static readonly List<Activity> s_activities = []; 315Activity[] activities = [.. s_activities]; 318foreach (Activity activity in activities) 360Activity.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)

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

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)

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)

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)

2020var activities = new List<Activity>(); 2050var activity = Assert.Single(activities);

OpenAIResponseClientTests.cs (2)

6908var activities = new List<Activity>(); 6938var 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");

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) 2277internal sealed class ActivityDebuggerProxy(Activity activity) 2290public 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)

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