Resource allocation improvement

build/Common.prod.props

@@ -61,8 +61,8 @@
 
   <!--PublicApi Analyzer-->
   <ItemGroup>
-    <AdditionalFiles Include=".publicApi\$(TargetFramework)\PublicAPI.Shipped.txt" />
-    <AdditionalFiles Include=".publicApi\$(TargetFramework)\PublicAPI.Unshipped.txt" />
+    <AdditionalFiles Include=".publicApi\*\PublicAPI.Shipped.txt" />
+    <AdditionalFiles Include=".publicApi\*\PublicAPI.Unshipped.txt" />
   </ItemGroup>
 
 </Project>

src/OpenTelemetry.Api/.publicApi/net452/PublicAPI.Unshipped.txt

@@ -14,6 +14,10 @@ OpenTelemetry.Baggage.RemoveBaggage(string name) -> OpenTelemetry.Baggage
 OpenTelemetry.Baggage.SetBaggage(System.Collections.Generic.IEnumerable<System.Collections.Generic.KeyValuePair<string, string>> baggageItems) -> OpenTelemetry.Baggage
 OpenTelemetry.Baggage.SetBaggage(params System.Collections.Generic.KeyValuePair<string, string>[] baggageItems) -> OpenTelemetry.Baggage
 OpenTelemetry.Baggage.SetBaggage(string name, string value) -> OpenTelemetry.Baggage
+OpenTelemetry.BaseProvider
+OpenTelemetry.BaseProvider.BaseProvider() -> void
+OpenTelemetry.BaseProvider.Dispose() -> void
+OpenTelemetry.BaseProvider.~BaseProvider() -> void
 OpenTelemetry.Context.Propagation.B3Propagator
 OpenTelemetry.Context.Propagation.B3Propagator.B3Propagator() -> void
 OpenTelemetry.Context.Propagation.B3Propagator.B3Propagator(bool singleHeader) -> void
@@ -70,7 +74,6 @@ OpenTelemetry.Metrics.Meter.Meter() -> void
 OpenTelemetry.Metrics.MeterFactoryBase
 OpenTelemetry.Metrics.MeterFactoryBase.MeterFactoryBase() -> void
 OpenTelemetry.Metrics.MeterProvider
-OpenTelemetry.Metrics.MeterProvider.Dispose() -> void
 OpenTelemetry.Metrics.MeterProvider.MeterProvider() -> void
 OpenTelemetry.Metrics.NoopBoundCounterMetric<T>
 OpenTelemetry.Metrics.NoopBoundCounterMetric<T>.NoopBoundCounterMetric() -> void
@@ -166,7 +169,6 @@ OpenTelemetry.Trace.Tracer.StartRootSpan(string name, OpenTelemetry.Trace.SpanKi
 OpenTelemetry.Trace.Tracer.StartSpan(string name, OpenTelemetry.Trace.SpanKind kind = OpenTelemetry.Trace.SpanKind.Internal, in OpenTelemetry.Trace.SpanContext parentContext = default(OpenTelemetry.Trace.SpanContext), OpenTelemetry.Trace.SpanAttributes initialAttributes = null, System.Collections.Generic.IEnumerable<OpenTelemetry.Trace.Link> links = null, System.DateTimeOffset startTime = default(System.DateTimeOffset)) -> OpenTelemetry.Trace.TelemetrySpan
 OpenTelemetry.Trace.Tracer.StartSpan(string name, OpenTelemetry.Trace.SpanKind kind, in OpenTelemetry.Trace.TelemetrySpan parentSpan, OpenTelemetry.Trace.SpanAttributes initialAttributes = null, System.Collections.Generic.IEnumerable<OpenTelemetry.Trace.Link> links = null, System.DateTimeOffset startTime = default(System.DateTimeOffset)) -> OpenTelemetry.Trace.TelemetrySpan
 OpenTelemetry.Trace.TracerProvider
-OpenTelemetry.Trace.TracerProvider.Dispose() -> void
 OpenTelemetry.Trace.TracerProvider.GetTracer(string name, string version = null) -> OpenTelemetry.Trace.Tracer
 OpenTelemetry.Trace.TracerProvider.TracerProvider() -> void
 abstract OpenTelemetry.Context.RuntimeContextSlot<T>.Get() -> T
@@ -300,10 +302,9 @@ static readonly OpenTelemetry.Metrics.NoopMeasureMetric<T>.Instance -> OpenTelem
 static readonly OpenTelemetry.Trace.Status.Error -> OpenTelemetry.Trace.Status
 static readonly OpenTelemetry.Trace.Status.Ok -> OpenTelemetry.Trace.Status
 static readonly OpenTelemetry.Trace.Status.Unset -> OpenTelemetry.Trace.Status
+virtual OpenTelemetry.BaseProvider.Dispose(bool disposing) -> void
 virtual OpenTelemetry.Context.RuntimeContextSlot<T>.Dispose(bool disposing) -> void
 virtual OpenTelemetry.Metrics.LabelSet.Labels.get -> System.Collections.Generic.IEnumerable<System.Collections.Generic.KeyValuePair<string, string>>
 virtual OpenTelemetry.Metrics.LabelSet.Labels.set -> void
 virtual OpenTelemetry.Metrics.MeterFactoryBase.GetMeter(string name, string version = null) -> OpenTelemetry.Metrics.Meter
-virtual OpenTelemetry.Metrics.MeterProvider.Dispose(bool disposing) -> void
 virtual OpenTelemetry.Metrics.MeterProvider.GetMeter(string name, string version = null) -> OpenTelemetry.Metrics.Meter
-virtual OpenTelemetry.Trace.TracerProvider.Dispose(bool disposing) -> void

src/OpenTelemetry.Api/.publicApi/netstandard2.0/PublicAPI.Unshipped.txt

@@ -14,6 +14,10 @@ OpenTelemetry.Baggage.RemoveBaggage(string name) -> OpenTelemetry.Baggage
 OpenTelemetry.Baggage.SetBaggage(System.Collections.Generic.IEnumerable<System.Collections.Generic.KeyValuePair<string, string>> baggageItems) -> OpenTelemetry.Baggage
 OpenTelemetry.Baggage.SetBaggage(params System.Collections.Generic.KeyValuePair<string, string>[] baggageItems) -> OpenTelemetry.Baggage
 OpenTelemetry.Baggage.SetBaggage(string name, string value) -> OpenTelemetry.Baggage
+OpenTelemetry.BaseProvider
+OpenTelemetry.BaseProvider.BaseProvider() -> void
+OpenTelemetry.BaseProvider.Dispose() -> void
+OpenTelemetry.BaseProvider.~BaseProvider() -> void
 OpenTelemetry.Context.AsyncLocalRuntimeContextSlot<T>
 OpenTelemetry.Context.AsyncLocalRuntimeContextSlot<T>.AsyncLocalRuntimeContextSlot(string name) -> void
 OpenTelemetry.Context.Propagation.B3Propagator
@@ -70,7 +74,6 @@ OpenTelemetry.Metrics.Meter.Meter() -> void
 OpenTelemetry.Metrics.MeterFactoryBase
 OpenTelemetry.Metrics.MeterFactoryBase.MeterFactoryBase() -> void
 OpenTelemetry.Metrics.MeterProvider
-OpenTelemetry.Metrics.MeterProvider.Dispose() -> void
 OpenTelemetry.Metrics.MeterProvider.MeterProvider() -> void
 OpenTelemetry.Metrics.NoopBoundCounterMetric<T>
 OpenTelemetry.Metrics.NoopBoundCounterMetric<T>.NoopBoundCounterMetric() -> void
@@ -166,7 +169,6 @@ OpenTelemetry.Trace.Tracer.StartRootSpan(string name, OpenTelemetry.Trace.SpanKi
 OpenTelemetry.Trace.Tracer.StartSpan(string name, OpenTelemetry.Trace.SpanKind kind = OpenTelemetry.Trace.SpanKind.Internal, in OpenTelemetry.Trace.SpanContext parentContext = default(OpenTelemetry.Trace.SpanContext), OpenTelemetry.Trace.SpanAttributes initialAttributes = null, System.Collections.Generic.IEnumerable<OpenTelemetry.Trace.Link> links = null, System.DateTimeOffset startTime = default(System.DateTimeOffset)) -> OpenTelemetry.Trace.TelemetrySpan
 OpenTelemetry.Trace.Tracer.StartSpan(string name, OpenTelemetry.Trace.SpanKind kind, in OpenTelemetry.Trace.TelemetrySpan parentSpan, OpenTelemetry.Trace.SpanAttributes initialAttributes = null, System.Collections.Generic.IEnumerable<OpenTelemetry.Trace.Link> links = null, System.DateTimeOffset startTime = default(System.DateTimeOffset)) -> OpenTelemetry.Trace.TelemetrySpan
 OpenTelemetry.Trace.TracerProvider
-OpenTelemetry.Trace.TracerProvider.Dispose() -> void
 OpenTelemetry.Trace.TracerProvider.GetTracer(string name, string version = null) -> OpenTelemetry.Trace.Tracer
 OpenTelemetry.Trace.TracerProvider.TracerProvider() -> void
 abstract OpenTelemetry.Context.RuntimeContextSlot<T>.Get() -> T
@@ -300,10 +302,9 @@ static readonly OpenTelemetry.Metrics.NoopMeasureMetric<T>.Instance -> OpenTelem
 static readonly OpenTelemetry.Trace.Status.Error -> OpenTelemetry.Trace.Status
 static readonly OpenTelemetry.Trace.Status.Ok -> OpenTelemetry.Trace.Status
 static readonly OpenTelemetry.Trace.Status.Unset -> OpenTelemetry.Trace.Status
+virtual OpenTelemetry.BaseProvider.Dispose(bool disposing) -> void
 virtual OpenTelemetry.Context.RuntimeContextSlot<T>.Dispose(bool disposing) -> void
 virtual OpenTelemetry.Metrics.LabelSet.Labels.get -> System.Collections.Generic.IEnumerable<System.Collections.Generic.KeyValuePair<string, string>>
 virtual OpenTelemetry.Metrics.LabelSet.Labels.set -> void
 virtual OpenTelemetry.Metrics.MeterFactoryBase.GetMeter(string name, string version = null) -> OpenTelemetry.Metrics.Meter
-virtual OpenTelemetry.Metrics.MeterProvider.Dispose(bool disposing) -> void
 virtual OpenTelemetry.Metrics.MeterProvider.GetMeter(string name, string version = null) -> OpenTelemetry.Metrics.Meter
-virtual OpenTelemetry.Trace.TracerProvider.Dispose(bool disposing) -> void

src/OpenTelemetry.Api/BaseProvider.cs

@@ -0,0 +1,49 @@
+// <copyright file="BaseProvider.cs" company="OpenTelemetry Authors">
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+// </copyright>
+
+using System;
+
+namespace OpenTelemetry
+{
+    /// <summary>
+    /// Contains logic shared by all OpenTelemetry providers.
+    /// </summary>
+    public abstract class BaseProvider : IDisposable
+    {
+        /// <summary>
+        /// Finalizes an instance of the <see cref="BaseProvider"/> class.
+        /// </summary>
+        ~BaseProvider()
+        {
+            this.Dispose(false);
+        }
+
+        /// <inheritdoc/>
+        public void Dispose()
+        {
+            this.Dispose(true);
+            GC.SuppressFinalize(this);
+        }
+
+        /// <summary>
+        /// Releases the unmanaged resources used by this class and optionally releases the managed resources.
+        /// </summary>
+        /// <param name="disposing"><see langword="true"/> to release both managed and unmanaged resources; <see langword="false"/> to release only unmanaged resources.</param>
+        protected virtual void Dispose(bool disposing)
+        {
+        }
+    }
+}

src/OpenTelemetry.Api/Metrics/MeterProvider.cs

@@ -21,7 +21,7 @@ namespace OpenTelemetry.Metrics
     /// <summary>
     /// MeterProvider is the entry point of the OpenTelemetry Metrics API. It provides access to Meters.
     /// </summary>
-    public class MeterProvider : IDisposable
+    public class MeterProvider : BaseProvider
     {
         private static ProxyMeter proxyMeter = new ProxyMeter();
         private static bool isInitialized;
@@ -71,13 +71,6 @@ public static void SetDefault(MeterProvider meterProvider)
             isInitialized = true;
         }
 
-        /// <inheritdoc/>
-        public void Dispose()
-        {
-            this.Dispose(true);
-            GC.SuppressFinalize(this);
-        }
-
         /// <summary>
         /// Returns a Meter for a given name and version.
         /// </summary>
@@ -96,13 +89,5 @@ internal static void Reset()
             isInitialized = false;
             defaultProvider = new MeterProvider();
         }
-
-        /// <summary>
-        /// Releases the unmanaged resources used by this class and optionally releases the managed resources.
-        /// </summary>
-        /// <param name="disposing"><see langword="true"/> to release both managed and unmanaged resources; <see langword="false"/> to release only unmanaged resources.</param>
-        protected virtual void Dispose(bool disposing)
-        {
-        }
     }
 }

src/OpenTelemetry.Api/Trace/TracerProvider.cs

@@ -14,15 +14,14 @@
 // limitations under the License.
 // </copyright>
 
-using System;
 using System.Diagnostics;
 
 namespace OpenTelemetry.Trace
 {
     /// <summary>
     /// TracerProvider is the entry point of the OpenTelemetry API. It provides access to <see cref="Tracer"/>.
     /// </summary>
-    public class TracerProvider : IDisposable
+    public class TracerProvider : BaseProvider
     {
         /// <summary>
         /// Initializes a new instance of the <see cref="TracerProvider"/> class.
@@ -51,20 +50,5 @@ public Tracer GetTracer(string name, string version = null)
 
             return new Tracer(new ActivitySource(name, version));
         }
-
-        /// <inheritdoc/>
-        public void Dispose()
-        {
-            this.Dispose(true);
-            GC.SuppressFinalize(this);
-        }
-
-        /// <summary>
-        /// Releases the unmanaged resources used by this class and optionally releases the managed resources.
-        /// </summary>
-        /// <param name="disposing"><see langword="true"/> to release both managed and unmanaged resources; <see langword="false"/> to release only unmanaged resources.</param>
-        protected virtual void Dispose(bool disposing)
-        {
-        }
     }
 }

src/OpenTelemetry.Exporter.Console/ConsoleExporter.cs

@@ -21,7 +21,6 @@
 using OpenTelemetry.Logs;
 #endif
 using OpenTelemetry.Resources;
-using OpenTelemetry.Trace;
 
 namespace OpenTelemetry.Exporter
 {
@@ -99,7 +98,7 @@ public override ExportResult Export(in Batch<T> batch)
                         }
                     }
 
-                    var resource = activity.GetResource();
+                    var resource = this.ParentProvider.GetResource();
                     if (resource != Resource.Empty)
                     {
                         this.WriteLine("Resource associated with Activity:");

src/OpenTelemetry.Exporter.Jaeger/JaegerExporter.cs

@@ -67,11 +67,6 @@ public override ExportResult Export(in Batch<Activity> activityBatch)
             {
                 foreach (var activity in activityBatch)
                 {
-                    if (this.processCache == null)
-                    {
-                        this.ApplyLibraryResource(activity.GetResource());
-                    }
-
                     this.AppendSpan(activity.ToJaegerSpan());
                 }
 
@@ -87,18 +82,18 @@ public override ExportResult Export(in Batch<Activity> activityBatch)
             }
         }
 
-        internal void ApplyLibraryResource(Resource libraryResource)
+        internal void SetResource(Resource resource)
         {
-            if (libraryResource is null)
+            if (resource is null)
             {
-                throw new ArgumentNullException(nameof(libraryResource));
+                throw new ArgumentNullException(nameof(resource));
             }
 
             var process = this.Process;
 
             string serviceName = null;
             string serviceNamespace = null;
-            foreach (var label in libraryResource.Attributes)
+            foreach (var label in resource.Attributes)
             {
                 string key = label.Key;
 
@@ -203,6 +198,12 @@ protected override void Dispose(bool disposing)
             base.Dispose(disposing);
         }
 
+        /// <inheritdoc/>
+        protected override void OnParentProviderSet()
+        {
+            this.SetResource(this.ParentProvider.GetResource());
+        }
+
         private void SendCurrentBatches(Batch workingBatch)
         {
             try

src/OpenTelemetry.Exporter.OpenTelemetryProtocol/Implementation/ActivityExtensions.cs

@@ -28,6 +28,7 @@
 using OpenTelemetry.Trace;
 using OtlpCollector = Opentelemetry.Proto.Collector.Trace.V1;
 using OtlpCommon = Opentelemetry.Proto.Common.V1;
+using OtlpResource = Opentelemetry.Proto.Resource.V1;
 using OtlpTrace = Opentelemetry.Proto.Trace.V1;
 
 namespace OpenTelemetry.Exporter.OpenTelemetryProtocol.Implementation
@@ -40,23 +41,18 @@ internal static class ActivityExtensions
 
         internal static void AddBatch(
             this OtlpCollector.ExportTraceServiceRequest request,
-            OtlpExporter otlpExporter,
+            OtlpResource.Resource processResource,
             in Batch<Activity> activityBatch)
         {
             Dictionary<string, OtlpTrace.InstrumentationLibrarySpans> spansByLibrary = new Dictionary<string, OtlpTrace.InstrumentationLibrarySpans>();
-            OtlpTrace.ResourceSpans resourceSpans = null;
+            OtlpTrace.ResourceSpans resourceSpans = new OtlpTrace.ResourceSpans
+            {
+                Resource = processResource,
+            };
+            request.ResourceSpans.Add(resourceSpans);
 
             foreach (var activity in activityBatch)
             {
-                if (resourceSpans == null)
-                {
-                    resourceSpans = new OtlpTrace.ResourceSpans
-                    {
-                        Resource = otlpExporter.EnsureProcessResource(activity),
-                    };
-                    request.ResourceSpans.Add(resourceSpans);
-                }
-
                 OtlpTrace.Span span = activity.ToOtlpSpan();
                 if (span == null)
                 {

src/OpenTelemetry.Exporter.OpenTelemetryProtocol/OtlpExporter.cs

@@ -18,7 +18,6 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
-using System.Runtime.CompilerServices;
 using System.Threading.Tasks;
 using Grpc.Core;
 using OpenTelemetry.Exporter.OpenTelemetryProtocol.Implementation;
@@ -40,7 +39,6 @@ public class OtlpExporter : BaseExporter<Activity>
         private readonly Channel channel;
         private readonly OtlpCollector.TraceService.ITraceServiceClient traceClient;
         private readonly Metadata headers;
-        private OtlpResource.Resource processResource;
 
         /// <summary>
         /// Initializes a new instance of the <see cref="OtlpExporter"/> class.
@@ -62,12 +60,14 @@ internal OtlpExporter(OtlpExporterOptions options, OtlpCollector.TraceService.IT
             }
         }
 
+        internal OtlpResource.Resource ProcessResource { get; private set; }
+
         /// <inheritdoc/>
         public override ExportResult Export(in Batch<Activity> activityBatch)
         {
             OtlpCollector.ExportTraceServiceRequest request = new OtlpCollector.ExportTraceServiceRequest();
 
-            request.AddBatch(this, activityBatch);
+            request.AddBatch(this.ProcessResource, activityBatch);
 
             try
             {
@@ -87,17 +87,11 @@ public override ExportResult Export(in Batch<Activity> activityBatch)
             return ExportResult.Success;
         }
 
-        [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        internal OtlpResource.Resource EnsureProcessResource(Activity activity)
+        internal void SetResource(Resource resource)
         {
-            if (this.processResource != null)
-            {
-                return this.processResource;
-            }
-
             OtlpResource.Resource processResource = new OtlpResource.Resource();
 
-            foreach (KeyValuePair<string, object> attribute in activity.GetResource().Attributes)
+            foreach (KeyValuePair<string, object> attribute in resource.Attributes)
             {
                 var oltpAttribute = attribute.ToOtlpAttribute();
                 if (oltpAttribute != null)
@@ -121,7 +115,7 @@ internal OtlpResource.Resource EnsureProcessResource(Activity activity)
                 });
             }
 
-            return this.processResource = processResource;
+            this.ProcessResource = processResource;
         }
 
         /// <inheritdoc/>
@@ -134,5 +128,11 @@ protected override bool OnShutdown(int timeoutMilliseconds)
 
             return Task.WaitAny(new Task[] { this.channel.ShutdownAsync(), Task.Delay(timeoutMilliseconds) }) == 0;
         }
+
+        /// <inheritdoc/>
+        protected override void OnParentProviderSet()
+        {
+            this.SetResource(this.ParentProvider.GetResource());
+        }
     }
 }