Skip to content

Commit

Permalink
[repo] remove incorrect null suppressions (#6075)
Browse files Browse the repository at this point in the history
Co-authored-by: Piotr Kiełkowicz <[email protected]>
  • Loading branch information
SimonCropp and Kielek authored Feb 14, 2025
1 parent 62af9ad commit c643b7f
Show file tree
Hide file tree
Showing 8 changed files with 30 additions and 18 deletions.
12 changes: 6 additions & 6 deletions examples/AspNetCore/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -13,16 +13,16 @@
var appBuilder = WebApplication.CreateBuilder(args);

// Note: Switch between Zipkin/OTLP/Console by setting UseTracingExporter in appsettings.json.
var tracingExporter = appBuilder.Configuration.GetValue("UseTracingExporter", defaultValue: "console")!.ToLowerInvariant();
var tracingExporter = appBuilder.Configuration.GetValue("UseTracingExporter", defaultValue: "console").ToLowerInvariant();

// Note: Switch between Prometheus/OTLP/Console by setting UseMetricsExporter in appsettings.json.
var metricsExporter = appBuilder.Configuration.GetValue("UseMetricsExporter", defaultValue: "console")!.ToLowerInvariant();
var metricsExporter = appBuilder.Configuration.GetValue("UseMetricsExporter", defaultValue: "console").ToLowerInvariant();

// Note: Switch between Console/OTLP by setting UseLogExporter in appsettings.json.
var logExporter = appBuilder.Configuration.GetValue("UseLogExporter", defaultValue: "console")!.ToLowerInvariant();
var logExporter = appBuilder.Configuration.GetValue("UseLogExporter", defaultValue: "console").ToLowerInvariant();

// Note: Switch between Explicit/Exponential by setting HistogramAggregation in appsettings.json
var histogramAggregation = appBuilder.Configuration.GetValue("HistogramAggregation", defaultValue: "explicit")!.ToLowerInvariant();
var histogramAggregation = appBuilder.Configuration.GetValue("HistogramAggregation", defaultValue: "explicit").ToLowerInvariant();

// Create a service to expose ActivitySource, and Metric Instruments
// for manual instrumentation
Expand Down Expand Up @@ -69,7 +69,7 @@
builder.AddOtlpExporter(otlpOptions =>
{
// Use IConfiguration directly for Otlp exporter endpoint option.
otlpOptions.Endpoint = new Uri(appBuilder.Configuration.GetValue("Otlp:Endpoint", defaultValue: "http://localhost:4317")!);
otlpOptions.Endpoint = new Uri(appBuilder.Configuration.GetValue("Otlp:Endpoint", defaultValue: "http://localhost:4317"));
});
break;

Expand Down Expand Up @@ -133,7 +133,7 @@
builder.AddOtlpExporter(otlpOptions =>
{
// Use IConfiguration directly for Otlp exporter endpoint option.
otlpOptions.Endpoint = new Uri(appBuilder.Configuration.GetValue("Otlp:Endpoint", defaultValue: "http://localhost:4317")!);
otlpOptions.Endpoint = new Uri(appBuilder.Configuration.GetValue("Otlp:Endpoint", defaultValue: "http://localhost:4317"));
});
break;
default:
Expand Down
8 changes: 4 additions & 4 deletions examples/GrpcService/Startup.cs
Original file line number Diff line number Diff line change
Expand Up @@ -23,23 +23,23 @@ public void ConfigureServices(IServiceCollection services)
.WithTracing(builder =>
{
builder
.ConfigureResource(r => r.AddService(this.Configuration.GetValue("ServiceName", defaultValue: "otel-test")!))
.ConfigureResource(r => r.AddService(this.Configuration.GetValue("ServiceName", defaultValue: "otel-test")))
.AddAspNetCoreInstrumentation();

// Switch between Otlp/Zipkin/Console by setting UseExporter in appsettings.json.
var exporter = this.Configuration.GetValue("UseExporter", defaultValue: "console")!.ToLowerInvariant();
var exporter = this.Configuration.GetValue("UseExporter", defaultValue: "console").ToLowerInvariant();
switch (exporter)
{
case "otlp":
builder.AddOtlpExporter(otlpOptions =>
{
otlpOptions.Endpoint = new Uri(this.Configuration.GetValue("Otlp:Endpoint", defaultValue: "http://localhost:4317")!);
otlpOptions.Endpoint = new Uri(this.Configuration.GetValue("Otlp:Endpoint", defaultValue: "http://localhost:4317"));
});
break;
case "zipkin":
builder.AddZipkinExporter(zipkinOptions =>
{
zipkinOptions.Endpoint = new Uri(this.Configuration.GetValue("Zipkin:Endpoint", defaultValue: "http://localhost:9411/api/v2/spans")!);
zipkinOptions.Endpoint = new Uri(this.Configuration.GetValue("Zipkin:Endpoint", defaultValue: "http://localhost:9411/api/v2/spans"));
});
break;
default:
Expand Down
11 changes: 9 additions & 2 deletions src/OpenTelemetry.Extensions.Propagators/B3Propagator.cs
Original file line number Diff line number Diff line change
Expand Up @@ -193,13 +193,20 @@ private static PropagationContext ExtractFromSingleHeader<T>(PropagationContext
{
try
{
var header = getter(carrier, XB3Combined)?.FirstOrDefault();
var headers = getter(carrier, XB3Combined);
if (headers == null)
{
return context;
}

var header = headers.FirstOrDefault();

if (string.IsNullOrWhiteSpace(header))
{
return context;
}

var parts = header!.Split(XB3CombinedDelimiter);
var parts = header.Split(XB3CombinedDelimiter);
if (parts.Length < 2 || parts.Length > 4)
{
return context;
Expand Down
9 changes: 7 additions & 2 deletions src/OpenTelemetry.Extensions.Propagators/JaegerPropagator.cs
Original file line number Diff line number Diff line change
Expand Up @@ -49,14 +49,19 @@ public override PropagationContext Extract<T>(PropagationContext context, T carr
try
{
var jaegerHeaderCollection = getter(carrier, JaegerHeader);
var jaegerHeader = jaegerHeaderCollection?.First();
if (jaegerHeaderCollection == null)
{
return context;
}

var jaegerHeader = jaegerHeaderCollection.First();

if (string.IsNullOrWhiteSpace(jaegerHeader))
{
return context;
}

var jaegerHeaderParsed = TryExtractTraceContext(jaegerHeader!, out var traceId, out var spanId, out var traceOptions);
var jaegerHeaderParsed = TryExtractTraceContext(jaegerHeader, out var traceId, out var spanId, out var traceOptions);

if (!jaegerHeaderParsed)
{
Expand Down
2 changes: 1 addition & 1 deletion src/Shared/TagWriter/TagWriter.cs
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ private void WriteArrayTagInternal(ref TTagState state, string key, Array array,
key,
"TRUNCATED".AsSpan());

this.LogUnsupportedTagTypeAndReturnFalse(key, array!.GetType().ToString());
this.LogUnsupportedTagTypeAndReturnFalse(key, array.GetType().ToString());
return;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,5 +66,5 @@ public void Setup()
}

[Benchmark(Baseline = true)]
public void Extract() => _ = TraceContextPropagator!.Extract(default, this.Headers!, Getter);
public void Extract() => _ = TraceContextPropagator.Extract(default, this.Headers!, Getter);
}
Original file line number Diff line number Diff line change
Expand Up @@ -393,7 +393,7 @@ public async Task HttpPersistentStorageRetryTests(bool usePersistentStorageTrans
Assert.NotNull(mockProvider);
if (exportResult == ExportResult.Success)
{
Assert.Single(mockProvider!.TryGetBlobs());
Assert.Single(mockProvider.TryGetBlobs());

// Force Retry
Assert.True((transmissionHandler as OtlpExporterPersistentStorageTransmissionHandler)?.InitiateAndWaitForRetryProcess(-1));
Expand Down
2 changes: 1 addition & 1 deletion test/OpenTelemetry.Tests/Shared/EventSourceTestHelper.cs
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ private static void VerifyEventMessage(MethodInfo eventMethod, EventWrittenEvent
{
string expectedMessage = eventArguments.Length == 0
? GetEventAttribute(eventMethod).Message!
: string.Format(CultureInfo.InvariantCulture, GetEventAttribute(eventMethod).Message!, eventArguments)!;
: string.Format(CultureInfo.InvariantCulture, GetEventAttribute(eventMethod).Message!, eventArguments);
string actualMessage = string.Format(CultureInfo.InvariantCulture, actualEvent.Message!, actualEvent.Payload!.ToArray());
AssertEqual(nameof(VerifyEventMessage), expectedMessage, actualMessage);
}
Expand Down

0 comments on commit c643b7f

Please sign in to comment.