Activity

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

75activity = new Activity(activityName);

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

75activity = new Activity(activityName);

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

75activity = new Activity(activityName);

HttpConnectionDispatcherTests.cs (1)

3123var activityFeature = new TestActivityFeature(new Activity("name"));

ActivityReplacer.cs (1)

14_activity = new Activity("Test");

HubConnection.cs (1)

1113activity = new Activity(ActivityName);

HubConnectionTests.Tracing.cs (3)

77clientParentActivity1 = new Activity("ClientActivity1"); 99clientParentActivity2 = new Activity("ClientActivity2"); 260clientParentActivity = new Activity("ClientActivity");

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

75activity = new Activity(activityName);

HubConnectionHandlerTests.Activity.cs (8)

44var mockHttpRequestActivity = new Activity("HttpRequest"); 119var mockHttpRequestActivity = new Activity("HttpRequest"); 188var mockHttpRequestActivity = new Activity("HttpRequest"); 247var mockHttpRequestActivity = new Activity("HttpRequest"); 320var mockHttpRequestActivity = new Activity("HttpRequest"); 367var mockHttpRequestActivity = new Activity("HttpRequest"); 419var mockHttpRequestActivity = new Activity("HttpRequest"); 470var mockHttpRequestActivity = new Activity("HttpRequest");

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)

1179Activity activity = new Activity(name);

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

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

Backchannel\AppHostBackchannel.cs (9)

Backchannel\ExtensionBackchannel.cs (19)

Certificates\CertificateService.cs (1)

24using var activity = telemetry.ActivitySource.StartActivity(nameof(EnsureCertificatesTrustedAsync), ActivityKind.Client);

Commands\AddCommand.cs (1)

74using var activity = _telemetry.ActivitySource.StartActivity(this.Name);

Commands\ExecCommand.cs (1)

131using var activity = _telemetry.ActivitySource.StartActivity(this.Name);

Commands\NewCommand.cs (1)

115using var activity = _telemetry.ActivitySource.StartActivity(this.Name);

Commands\PublishCommandBase.cs (1)

97using var activity = _telemetry.ActivitySource.StartActivity(this.Name);

Commands\RunCommand.cs (1)

92using var activity = _telemetry.ActivitySource.StartActivity(this.Name);

DotNet\DotNetCliRunner.cs (12)

NuGet\NuGetPackageCache.cs (1)

72using var activity = telemetry.ActivitySource.StartActivity();

Program.cs (1)

218using var activity = telemetry.ActivitySource.StartActivity();

Projects\ProjectLocator.cs (1)

26using var activity = telemetry.ActivitySource.StartActivity();

Utils\AppHostHelper.cs (1)

55using var activity = telemetry.ActivitySource.StartActivity(nameof(GetAppHostInformationAsync), ActivityKind.Client);

ActivityNotifier.cs (9)

14public sealed class ActivityNotifier : BaseProcessor<Activity> 16private readonly Channel<Activity> _activityChannel = Channel.CreateUnbounded<Activity>(); 18public async Task<List<Activity>> TakeAsync(int count, TimeSpan timeout) 20var activityList = new List<Activity>(); 22await foreach (var activity in WaitAsync(cts.Token)) 34public override void OnEnd(Activity data) 39private async IAsyncEnumerable<Activity> WaitAsync([EnumeratorCancellation] CancellationToken cancellationToken) 41await foreach (var activity in _activityChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ConformanceTests.cs (2)

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

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)

34List<Activity> activities = new();

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

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

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (2)

49var activity = Activity.Current;

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\DiagnosticSourceListener.cs (1)

35if (!this.handler.SupportsNullActivity && Activity.Current == null)

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\ListenerHandler.cs (1)

28/// Gets a value indicating whether the <see cref="ListenerHandler"/> supports NULL <see cref="Activity"/>.

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\SqlClientTraceInstrumentationOptions.cs (5)

120/// Gets or sets an action to enrich an <see cref="Activity"/> with the 128/// <item>The <see cref="Activity"/> being enriched.</item> 133/// cref="Activity"/>.</item> 136public Action<Activity, string, object> Enrich { get; set; } 257internal void AddConnectionLevelDetailsToActivity(string dataSource, Activity sqlActivity)

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (2)

49var activity = Activity.Current;

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\DiagnosticSourceListener.cs (1)

35if (!this.handler.SupportsNullActivity && Activity.Current == null)

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\ListenerHandler.cs (1)

28/// Gets a value indicating whether the <see cref="ListenerHandler"/> supports NULL <see cref="Activity"/>.

src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\SqlClientTraceInstrumentationOptions.cs (5)

120/// Gets or sets an action to enrich an <see cref="Activity"/> with the 128/// <item>The <see cref="Activity"/> being enriched.</item> 133/// cref="Activity"/>.</item> 136public Action<Activity, string, object> Enrich { get; set; } 257internal void AddConnectionLevelDetailsToActivity(string dataSource, Activity sqlActivity)

AspireNatsClientExtensionsTests.cs (1)

230var activity = activityList[0];

ConformanceTests.cs (1)

150List<Activity> exportedActivities = new();

src\Components\Aspire.RabbitMQ.Client\AspireRabbitMQExtensions.cs (4)

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

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

76public static Activity? ProfilerCommandToActivity(Activity? parentActivity, IProfiledCommand command, StackExchangeRedisInstrumentationOptions options) 84var activity = StackExchangeRedisConnectionInstrumentation.ActivitySource.StartActivity( 182public static void DrainSession(Activity? parentActivity, IEnumerable<IProfiledCommand> sessionCommands, StackExchangeRedisInstrumentationOptions options)

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

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

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

16/// Gets or sets the maximum time that should elapse between flushing the internal buffer of Redis profiling sessions and creating <see cref="Activity"/> objects. Default value: 00:00:10. 29/// <para><see cref="Activity"/>: the activity being enriched.</para> 32public Action<Activity, IProfiledCommand>? Enrich { get; set; }

AspireRedisExtensionsTests.cs (1)

294var activity = activityList[0];

CatalogDbInitializer.cs (1)

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

Controllers\HomeController.cs (1)

26return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });

Controllers\HomeController.cs (1)

26return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });

ApiDbInitializer.cs (1)

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

Pages\Error.cshtml.cs (1)

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

Pages\Error.cshtml.cs (1)

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

Pages\Error.cshtml.cs (1)

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

Pages\Error.cshtml.cs (1)

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

ComponentsActivitySource.cs (13)

28var activity = ActivitySource.CreateActivity(OnRouteName, ActivityKind.Internal, parentId: null, null, null); 31var httpActivity = Activity.Current; 33Activity.Current = null; // do not inherit the parent activity 64var activity = ActivitySource.CreateActivity(OnEventName, ActivityKind.Internal, parentId: null, null, null); 68var previousActivity = Activity.Current; 70Activity.Current = null; // do not inherit the parent activity 114var activity = activityHandle.Activity; 128if (Activity.Current == null && activityHandle.Previous != null && !activityHandle.Previous.IsStopped) 130Activity.Current = activityHandle.Previous; 141public Activity? Previous; 142public Activity? Activity;

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

44public void AddActivityContexts(string exceptCategory, Activity targetActivity)

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

44public void AddActivityContexts(string exceptCategory, Activity targetActivity)

Circuits\CircuitActivitySourceTest.cs (5)

21private readonly List<Activity> _activities; 25_activities = new List<Activity>(); 48var activity = activityHandle.Activity; 74var activity = activityHandle.Activity; 96var activity = activityHandle.Activity;

ComponentsActivitySourceTest.cs (9)

12private readonly List<Activity> _activities; 16_activities = new List<Activity>(); 54var activity = activityHandle.Activity; 90var activity = activityHandle.Activity; 117var activity = activityHandle.Activity; 137var activity = activityHandle.Activity; 156var activity = activityHandle.Activity; 179var activity = activityHandle.Activity; 196var activity = activityHandle.Activity;

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

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

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

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

Internal\HostingApplication.cs (1)

132public Activity? Activity

Internal\HostingApplicationDiagnostics.cs (7)

229var activity = context.Activity; 404private Activity? StartActivity(HttpContext httpContext, bool diagnosticsOrLoggingEnabled, out bool hasDiagnosticListener) 417var activity = ActivityCreator.CreateFromRemote( 494private void StopActivity(HttpContext httpContext, Activity activity, bool hasDiagnosticListener) 522private Activity StartActivity(Activity activity, HttpContext httpContext) 536private void StopActivity(Activity activity, HttpContext httpContext)

Internal\HttpActivityFeature.cs (2)

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

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

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

HostingApplicationDiagnosticsTests.cs (51)

HostingApplicationTests.cs (7)

113var initialActivity = Activity.Current; 116using var dummyActivity = dummySource.StartActivity("DummyActivity"); 118Assert.Equal(Activity.Current, dummyActivity); 122Assert.Equal(activityFeature.Activity.Id, Activity.Current.ParentId); 123Assert.NotEqual(Activity.Current, activityFeature.Activity); 131public Activity Activity { get; set; }

Features\IHttpActivityFeature.cs (1)

16Activity Activity { get; set; }

HttpConnectionDispatcherTests.cs (3)

3095public TestActivityFeature(Activity activity) 3100public Activity Activity { get; set; } 3129Assert.Equal("true", Activity.Current.GetTagItem("http.long_running"));

DefaultProblemDetailsWriter.cs (1)

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

ProblemDetailsDefaultWriterTest.cs (15)

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;

DependencyInjection\ApiBehaviorOptionsSetupTest.cs (1)

110Assert.Equal(Activity.Current.Id, problemDetails.Extensions["traceId"]);

Infrastructure\ProblemDetalsClientErrorFactoryTest.cs (1)

91Assert.Equal(Activity.Current.Id, problemDetails.Extensions["traceId"]);

ActivityReplacer.cs (2)

10private readonly Activity _activity; 20Debug.Assert(Activity.Current == _activity);

XmlSerializerFormattersWrappingTest.cs (1)

211$"<traceId>{Activity.Current.Id}</traceId>" +

HubConnection.cs (7)

1021private async Task<(ConnectionState, Activity?)> WaitForActiveConnectionWithActivityAsync(string sendingMethodName, string invokedMethodName, CancellationToken token) 1025var activity = CreateActivity(invokedMethodName); 1069static void SetServerTags(Activity? activity, Uri? uri) 1108private Activity? CreateActivity(string methodName) 1110var activity = _activitySource.CreateActivity(ActivityName, ActivityKind.Client); 1111if (activity is null && Activity.Current is not null && _logger.IsEnabled(LogLevel.Critical)) 1195private static void InjectHeaders(Activity currentActivity, HubInvocationMessage invocationMessage)

Internal\InvocationRequest.cs (6)

26public Activity? Activity { get; } 28protected InvocationRequest(CancellationToken cancellationToken, Type resultType, string invocationId, ILogger logger, HubConnection hubConnection, Activity? activity) 48public static InvocationRequest Invoke(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out Task<object?> result) 56ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out ChannelReader<object?> result) 83public Streaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity) 171public NonStreaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity)

HubConnectionTests.Tracing.cs (26)

35var serverChannel = Channel.CreateUnbounded<Activity>(); 36var clientChannel = Channel.CreateUnbounded<Activity>(); 66Activity clientParentActivity1 = null; 67Activity clientActivity1 = null; 68Activity clientParentActivity2 = null; 69Activity clientActivity2 = null; 86Assert.Equal(clientParentActivity1, Activity.Current); 108Assert.Equal(clientParentActivity2, Activity.Current); 229var serverChannel = Channel.CreateUnbounded<Activity>(); 230var clientActivityTcs = new TaskCompletionSource<Activity>(); 231Activity clientActivity = null; 255Activity clientParentActivity = null; 280Assert.Equal(clientParentActivity, Activity.Current); 374var serverChannel = Channel.CreateUnbounded<Activity>(); 375var clientActivityTcs = new TaskCompletionSource<Activity>(); 440var clientActivity = await clientActivityTcs.Task.DefaultTimeout(); 477var serverChannel = Channel.CreateUnbounded<Activity>(); 478var clientActivityTcs = new TaskCompletionSource<Activity>(); 537var clientActivity = await clientActivityTcs.Task.DefaultTimeout(); 573var serverChannel = Channel.CreateUnbounded<Activity>(); 574var clientActivityTcs = new TaskCompletionSource<Activity>(); 632var clientActivity = await clientActivityTcs.Task.DefaultTimeout(); 663var serverChannel = Channel.CreateUnbounded<Activity>(); 664var clientActivityTcs = new TaskCompletionSource<Activity>(); 704Assert.Null(Activity.Current); 731var clientActivity = await clientActivityTcs.Task.DefaultTimeout();

HubConnectionTests.Tracing.cs (6)

25Activity clientActivity = null; 62Activity clientActivity = null; 100Activity clientActivity = null; 134Activity clientActivity = null; 172var clientActivityTcs = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); ; 196var clientActivity = await clientActivityTcs.Task.DefaultTimeout();

HubConnectionContext.cs (1)

62internal Activity? OriginalActivity { get; set; }

HubConnectionHandler.cs (1)

136OriginalActivity = Activity.Current,

Internal\DefaultHubDispatcher.cs (18)

89Activity? activity = null; 125Activity? activity = null; 399var previousActivity = Activity.Current; 402Activity.Current = null; 407var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger); 428if (Activity.Current != previousActivity) 430Activity.Current = previousActivity; 519var previousActivity = Activity.Current; 522Activity.Current = null; 525var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger); 592if (Activity.Current != previousActivity) 594Activity.Current = previousActivity; 832private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger) 857Activity? activity; 892private static void SetActivityError(Activity? activity, Exception ex)

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

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

HubConnectionHandlerTests.Activity.cs (47)

HubConnectionHandlerTestUtils\Hubs.cs (1)

376var activity = testActivitySource.ActivitySource.StartActivity("inner", ActivityKind.Server);

Telemetry\ActivityExtensions.cs (9)

13/// Extension methods for <see cref="Activity"/>. usage in VS OpenTelemetry. 20public static Activity WithTags(this Activity activity, IActivityTelemetryDataHolder? dataHolder) 32public static Activity WithTags(this Activity activity, IList<TelemetryItem> tags) 43public static Activity WithTag(this Activity activity, TelemetryItem item) 53public static Activity WithStartTime(this Activity activity, DateTime? startTime)

Telemetry\IActivityTelemetryDataHolder.cs (1)

10/// Interface for classes that hold telemetry data that should be added as tags to an <see cref="Activity"/>.

Telemetry\MSBuildActivitySource.cs (4)

26public Activity? StartActivity(string name) 28var activity = Activity.Current?.HasRemoteParent == true 29? _source.StartActivity($"{TelemetryConstants.EventPrefix}{name}", ActivityKind.Internal, parentId: Activity.Current.ParentId)

ChatCompletion\FunctionInvokingChatClient.cs (6)

235using Activity? activity = _activitySource?.StartActivity($"{nameof(FunctionInvokingChatClient)}.{nameof(GetResponseAsync)}"); 330using Activity? activity = _activitySource?.StartActivity($"{nameof(FunctionInvokingChatClient)}.{nameof(GetStreamingResponseAsync)}"); 375Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 423Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 438private static void AddUsageTags(Activity? activity, UsageDetails? usage) 840using Activity? activity = _activitySource?.StartActivity(

ChatCompletion\OpenTelemetryChatClient.cs (6)

138using Activity? activity = CreateAndConfigureActivity(options); 169using Activity? activity = CreateAndConfigureActivity(options); 211Activity.Current = activity; // workaround for https://github.com/dotnet/runtime/issues/47802 223private Activity? CreateAndConfigureActivity(ChatOptions? options) 225Activity? activity = null; 333Activity? activity,

Embeddings\OpenTelemetryEmbeddingGenerator.cs (4)

113using Activity? activity = CreateAndConfigureActivity(options); 149private Activity? CreateAndConfigureActivity(EmbeddingGenerationOptions? options) 151Activity? activity = null; 203Activity? activity,

ChatClientIntegrationTests.cs (8)

219var activities = new List<Activity>(); 286var activities = new List<Activity>(); 318var activities = new List<Activity>(); 350var activities = new List<Activity>(); 377private static void AssertUsageAgainstActivities(ChatResponse response, List<Activity> activities) 407var activities = new List<Activity>(); 931var activities = new List<Activity>(); 943var activity = Assert.Single(activities);

EmbeddingGeneratorIntegrationTests.cs (2)

111var activities = new List<Activity>(); 125var activity = activities.Single();

ChatCompletion\FunctionInvokingChatClientTests.cs (1)

687var activities = new List<Activity>();

ChatCompletion\OpenTelemetryChatClientTests.cs (2)

27var activities = new List<Activity>(); 149var activity = Assert.Single(activities);

Embeddings\OpenTelemetryEmbeddingGeneratorTests.cs (2)

25var activities = new List<Activity>(); 75var activity = Assert.Single(activities);

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)

75Activity? activity = Activity.Current;

Resolver\DnsResolver.Telemetry.cs (1)

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

Logging\Import\LoggerFactoryScopeProvider.cs (7)

56Activity? activity = Activity.Current; 97private static ActivityBaggageLogScopeWrapper GetOrCreateActivityBaggageLogScopeWrapper(Activity activity, IEnumerable<KeyValuePair<string, string?>> items) 156public ActivityLogScope(Activity activity, ActivityTrackingOptions activityTrackingOption) 309public static string GetSpanId(this Activity activity) 319public static string GetTraceId(this Activity activity) 329public static string GetParentId(this Activity activity)

Sampling\SamplingLoggerBuilderExtensions.cs (1)

26/// <remarks>Sampling decisions for logs match exactly the sampling decisions for the underlying <see cref="System.Diagnostics.Activity"/>.

Sampling\TraceBasedSampler.cs (1)

13Activity.Current?.Recorded ?? true;

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

Controllers\HomeController.cs (1)

48return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });

OrderProcessingWorker.cs (2)

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

Controllers\HomeController.cs (1)

26return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });

Program.cs (1)

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

Controllers\HomeController.cs (1)

24return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });

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

74var activity = Activity.Current; 75Activity.Current = null; 79Activity.Current = activity; 115var current = Activity.Current; 116Activity.Current = null; 130Activity.Current = current; 287var span1 = traceCreator.CreateActivity("Test 1", "0485b1947fe788bb"); 290var span2 = traceCreator.CreateActivity("Test 2", "0485b1947fe788bb"); 300var current = Activity.Current; 301Activity.Current = null; 308Activity.Current = current; 329using var activity = source.StartActivity("ValidateAndUpdateCacheService.ExecuteAsync"); 332using var innerActivity = source.StartActivity("ValidateAndUpdateCacheService.activeUser", 351using var innerActivity2 = source.StartActivity("ValidateAndUpdateCacheService.activeUser",

TraceCreator.cs (11)

17private readonly List<Activity> _allActivities = new List<Activity>(); 19public Activity? CreateActivity(string name, string? spandId) 21var activity = s_activitySource.StartActivity(name, ActivityKind.Client); 27typeof(Activity).GetField("_spanId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, spandId); 28typeof(Activity).GetField("_traceId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, activity.TraceId.ToString()); 37var activityStack = new Stack<Activity>(); 47using var activity = s_activitySource.StartActivity(rootName ?? name, ActivityKind.Client); 75using var activity = s_activitySource.StartActivity(ActivityKind.Client, name: name, links: links.DistinctBy(l => l.Context.SpanId)); 93private static void AddEvents(Activity activity) 128var a = _allActivities[Random.Shared.Next(0, _allActivities.Count)];

System\Diagnostics\Activity.cs (43)

18/// Carries the <see cref="Activity.Current"/> changed event data. 22internal ActivityChangedEventArgs(Activity? previous, Activity? current) 29/// Gets <see cref="Activity"/> object before the event. 31public Activity? Previous { get; init; } 34/// Gets <see cref="Activity"/> object after the event. 36public Activity? Current { get; init; } 65private static readonly AsyncLocal<Activity?> s_current = new AsyncLocal<Activity?>(); 79/// Event occur when the <see cref="Activity.Current"/> value changes. 117private Activity? _previousActiveActivity; 138public static Activity? Current 160public Activity SetStatus(ActivityStatusCode code, string? description = null) 203public Activity? Parent { get; private set; } 380for (Activity? activity = this; activity != null; activity = activity.Parent) 390static IEnumerable<KeyValuePair<string, string?>> Iterate(Activity? activity) 476public Activity AddTag(string key, string? value) => AddTag(key, (object?)value); 486public Activity AddTag(string key, object? value) 510public Activity SetTag(string key, object? value) 527public Activity AddEvent(ActivityEvent e) 552public Activity AddException(Exception exception, in TagList tags = default, DateTimeOffset timestamp = default) 612public Activity AddLink(ActivityLink link) 631public Activity AddBaggage(string key, string? value) 655public Activity SetBaggage(string key, string? value) 676public Activity SetParentId(string parentId) 706public Activity SetParentId(ActivityTraceId traceId, ActivitySpanId spanId, ActivityTraceFlags activityTraceFlags = ActivityTraceFlags.None) 736public Activity SetStartTime(DateTime startTimeUtc) 756public Activity SetEndTime(DateTime endTimeUtc) 785/// Use <see cref="DiagnosticSource.StartActivity(Activity, object)"/> to start activity and write start event. 787/// <seealso cref="DiagnosticSource.StartActivity(Activity, object)"/> 789public Activity Start() 841/// Use <see cref="DiagnosticSource.StopActivity(Activity, object)"/> to stop activity and write stop event. 843/// <seealso cref="DiagnosticSource.StopActivity(Activity, object)"/> 886for (Activity? activity = this; activity != null; activity = activity.Parent) 1046public Activity SetIdFormat(ActivityIdFormat format) 1175internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 1179Activity activity = new Activity(name); 1260private static void SetCurrent(Activity? activity) 1269Activity? previous = s_current.Value; 1409private static bool ValidateSetCurrent(Activity? activity) 1472/// Indicates whether this <see cref="Activity"/> object is stopped 1475/// When subscribing to <see cref="Activity"/> stop event using <see cref="ActivityListener.ActivityStopped"/>, the received <see cref="Activity"/> object in the event callback will have <see cref="IsStopped"/> as true.

System\Diagnostics\ActivityContext.cs (2)

78return Activity.TryConvertIdToContext(traceParent, traceState, isRemote, out context); 101if (!Activity.TryConvertIdToContext(traceParent, traceState, isRemote: false, out ActivityContext context))

System\Diagnostics\ActivityCreationOptions.cs (6)

38if (IdFormat == ActivityIdFormat.Unknown && Activity.ForceDefaultIdFormat) 40IdFormat = Activity.DefaultIdFormat; 80IdFormat = Activity.Current != null ? Activity.Current.IdFormat : Activity.DefaultIdFormat; 135Func<ActivityTraceId>? traceIdGenerator = Activity.TraceIdGenerator;

System\Diagnostics\ActivityEvent.cs (5)

15private readonly Activity.TagsLinkedList? _tags; 40_tags = tagsCount > 0 ? new Activity.TagsLinkedList(tags!) : null; 61/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 62public Activity.Enumerator<KeyValuePair<string, object?>> EnumerateTagObjects() => new Activity.Enumerator<KeyValuePair<string, object?>>(_tags?.First);

System\Diagnostics\ActivityLink.cs (5)

17private readonly Activity.TagsLinkedList? _tags; 28_tags = tags?.Count > 0 ? new Activity.TagsLinkedList(tags) : null; 50/// <returns><see cref="Activity.Enumerator{T}"/>.</returns> 51public Activity.Enumerator<KeyValuePair<string, object?>> EnumerateTagObjects() => new Activity.Enumerator<KeyValuePair<string, object?>>(_tags?.First);

System\Diagnostics\ActivityListener.cs (12)

System\Diagnostics\ActivitySource.cs (38)

System\Diagnostics\DiagnosticListener.cs (4)

280internal Action<Activity, object?>? OnActivityImport; 281internal Action<Activity, object?>? OnActivityExport; 431Action<Activity, object?>? onActivityImport, Action<Activity, object?>? onActivityExport)

System\Diagnostics\DiagnosticSourceActivity.cs (17)

System\Diagnostics\DistributedContextPropagator.cs (2)

45/// Injects the trace values stored in the <see cref="Activity"/> object into a carrier. For example, into the headers of an HTTP request. 50public abstract void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter);

System\Diagnostics\DsesActivitySourceListener.cs (3)

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

System\Diagnostics\DsesFilterAndTransform.cs (1)

953return Activity.Current;

System\Diagnostics\LegacyPropagator.cs (1)

16public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter)

System\Diagnostics\NoOutputPropagator.cs (1)

14public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter)

System\Diagnostics\PassThroughPropagator.cs (5)

14public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter) 46Activity? activity = Activity.Current; 48while (activity?.Parent is Activity parent) 55isW3c = parentId is not null ? Activity.TryConvertIdToContext(parentId, traceState, isRemote: false, out _) : false;

System\Diagnostics\W3CPropagator.cs (1)

26public override void Inject(Activity? activity, object? carrier, PropagatorSetterCallback? setter)

System\Net\Http\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); 84public static void AddConnectionLinkToRequestActivity(Activity connectionSetupActivity) 91Activity? requestActivity = Activity.Current;

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (2)

557private async ValueTask<(Stream, TransportContext?, Activity?, IPEndPoint?)> ConnectAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 564Activity? activity = ConnectionSetupDistributedTracing.StartConnectionSetupActivity(IsSecure, _telemetryServerAddress, OriginAuthority.Port);

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (2)

296(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(request, async, cancellationToken).ConfigureAwait(false); 300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)

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

187(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(queueItem.Request, true, cts.Token).ConfigureAwait(false); 246private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken) 289private async Task HandleHttp11Downgrade(HttpRequestMessage request, Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)

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

261Activity? connectionSetupActivity = null;

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionWaiter.cs (2)

24|| (GlobalHttpSettings.DiagnosticsHandler.EnableActivityPropagation && Activity.Current?.Source == DiagnosticsHandler.s_activitySource); 37using Activity? waitForConnectionActivity = ConnectionSetupDistributedTracing.StartWaitForConnectionActivity(pool.OriginAuthority);

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

134public Http2Connection(HttpConnectionPool pool, Stream stream, Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint)

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

93public void InitQuicConnection(QuicConnection connection, Activity? connectionSetupActivity) 951private Activity? _activity;

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

76Activity? connectionSetupActivity,

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

41public Activity? ConnectionSetupActivity { get; private set; } 50public HttpConnectionBase(HttpConnectionPool pool, Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint) 56protected void MarkConnectionAsEstablished(Activity? connectionSetupActivity, IPEndPoint? remoteEndPoint)

System\Net\Dns.cs (3)

728Activity? activityToRestore = tracingEnabled ? Activity.Current : null; 733Activity.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)

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

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

3352Activity? activity = SocketsTelemetry.Log.ConnectStart(socketAddress, _protocolType, endPointSnapshot, keepActivityCurrent: false);

System\Net\Sockets\SocketAsyncEventArgs.cs (4)

75private static ConditionalWeakTable<SocketAsyncEventArgs, Activity>? s_connectActivityTable; 310internal Activity? ConnectActivity 315get => s_connectActivityTable?.TryGetValue(this, out Activity? result) == true ? result : null; 320LazyInitializer.EnsureInitialized(ref s_connectActivityTable, () => new ConditionalWeakTable<SocketAsyncEventArgs, Activity>());

System\Net\Sockets\SocketsTelemetry.cs (7)

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)