Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Use Volatile instead of Interlocked where appropriate #6051

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

pentp
Copy link

@pentp pentp commented Jan 8, 2025

Volatile reads/writes are atomic and have acquire/release semantics, but are for the most part as fast as regular reads/writes. Any interlocked operation is at least 30-40 CPU cycles and needs exclusive cache line ownership, which is especially bad for reads.

Split off from #6048.

@pentp pentp requested a review from a team as a code owner January 8, 2025 10:07
@github-actions github-actions bot added pkg:OpenTelemetry.Exporter.OpenTelemetryProtocol Issues related to OpenTelemetry.Exporter.OpenTelemetryProtocol NuGet package pkg:OpenTelemetry Issues related to OpenTelemetry NuGet package labels Jan 8, 2025
@@ -394,7 +394,7 @@ internal void Update(long number)
case AggregationType.LongSumIncomingCumulative:
case AggregationType.LongGauge:
{
Interlocked.Exchange(ref this.runningValue.AsLong, number);
Volatile.Write(ref this.runningValue.AsLong, number);
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

curious, if this shows improvement in the metric stress tests?

@@ -135,7 +135,7 @@ internal void Update<T>(in ExemplarMeasurement<T> measurement)
this.StoreRawTags(measurement.Tags);
}

Interlocked.Exchange(ref this.isCriticalSectionOccupied, 0);
Volatile.Write(ref this.isCriticalSectionOccupied, 0);
Copy link
Contributor

@utpilla utpilla Jan 10, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We need to consider the memory ordering guarantees of Volatile.Write. With Interlocked methods, the read/writes would not be moved before or after a given Interlocked method.

With volatile writes, read/writes that happen after a given Volatile.Write method can be moved before that Volatile.Write method. We need to evaluate if that affects the correctness of our code. There are some write operations that we do after releasing the locks (for exemplar and MetricPoint updates):

  • Call OnCollected for Exemplars which resets the internal measurement state
  • Update MetricStatus to CollectPending when updating MetricPoints

Copy link
Contributor

This PR was marked stale due to lack of activity and will be closed in 7 days. Commenting or pushing will instruct the bot to automatically remove the label. This bot runs once per day.

@github-actions github-actions bot added the Stale Issues and pull requests which have been flagged for closing due to inactivity label Jan 18, 2025
Copy link

codecov bot commented Jan 18, 2025

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 86.39%. Comparing base (cd31c57) to head (f1645d1).
Report is 7 commits behind head on main.

Additional details and impacted files

Impacted file tree graph

@@            Coverage Diff             @@
##             main    #6051      +/-   ##
==========================================
- Coverage   86.39%   86.39%   -0.01%     
==========================================
  Files         257      257              
  Lines       11690    11668      -22     
==========================================
- Hits        10100    10080      -20     
+ Misses       1590     1588       -2     
Files with missing lines Coverage Δ
...Protocol/PersistentStorage/DirectorySizeTracker.cs 45.83% <ø> (+3.52%) ⬆️
src/OpenTelemetry/Internal/InterlockedHelper.cs 100.00% <ø> (ø)
src/OpenTelemetry/Metrics/Exemplar/Exemplar.cs 86.66% <ø> (-0.44%) ⬇️
...c/OpenTelemetry/Metrics/MetricPoint/MetricPoint.cs 94.08% <ø> (-0.16%) ⬇️
...trics/MetricPoint/MetricPointOptionalComponents.cs 100.00% <ø> (ø)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
pkg:OpenTelemetry.Exporter.OpenTelemetryProtocol Issues related to OpenTelemetry.Exporter.OpenTelemetryProtocol NuGet package pkg:OpenTelemetry Issues related to OpenTelemetry NuGet package Stale Issues and pull requests which have been flagged for closing due to inactivity
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants