[disk-buffering] Ensure no sign propagation for flags byte (#1166)

Author: breedx-splk

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/serialization/mapping/logs/LogRecordDataMapper.java

@@ -6,6 +6,7 @@
 package io.opentelemetry.contrib.disk.buffering.internal.serialization.mapping.logs;
 
 import static io.opentelemetry.contrib.disk.buffering.internal.serialization.mapping.spans.SpanDataMapper.flagsFromInt;
+import static io.opentelemetry.contrib.disk.buffering.internal.utils.ProtobufTools.toUnsignedInt;
 
 import io.opentelemetry.api.common.Attributes;
 import io.opentelemetry.api.logs.Severity;
@@ -45,7 +46,8 @@ public LogRecord mapToProto(LogRecordData source) {
  logRecord.body(bodyToAnyValue(source.getBody()));
  }
 
- logRecord.flags(source.getSpanContext().getTraceFlags().asByte());
+ byte flags = source.getSpanContext().getTraceFlags().asByte();
+ logRecord.flags(toUnsignedInt(flags));
 
  addExtrasToProtoBuilder(source, logRecord);
 

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/serialization/mapping/spans/SpanDataMapper.java

@@ -5,6 +5,8 @@
 
 package io.opentelemetry.contrib.disk.buffering.internal.serialization.mapping.spans;
 
+import static io.opentelemetry.contrib.disk.buffering.internal.utils.ProtobufTools.toUnsignedInt;
+
 import io.opentelemetry.api.common.Attributes;
 import io.opentelemetry.api.trace.SpanContext;
 import io.opentelemetry.api.trace.SpanKind;
@@ -309,7 +311,7 @@ private static Span.Link linkDataToProto(LinkData source) {
  SpanContext spanContext = source.getSpanContext();
  builder.trace_id(ByteStringMapper.getInstance().stringToProto(spanContext.getTraceId()));
  builder.span_id(ByteStringMapper.getInstance().stringToProto(spanContext.getSpanId()));
- builder.flags = spanContext.getTraceFlags().asByte();
+ builder.flags = toUnsignedInt(spanContext.getTraceFlags().asByte());
  builder.attributes.addAll(attributesToProto(source.getAttributes()));
  builder.dropped_attributes_count(
  source.getTotalAttributeCount() - source.getAttributes().size());

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/utils/ProtobufTools.java

@@ -48,4 +48,12 @@ public static int readRawVarint32(int firstByte, InputStream input) throws IOExc
  }
  throw new IllegalStateException();
  }
+
+ /**
+ * Vendored {@link Byte#toUnsignedInt(byte)} to support Android. Also helps with accidental sign
+ * propagation.
+ */
+ public static int toUnsignedInt(byte x) {
+ return ((int) x) & 0xff;
+ }
 }