Create intermediate storage for samples for formats without sync fram…

…e guarantee

libraries/exoplayer/src/main/java/androidx/media3/exoplayer/source/SampleMetadata.java

@@ -0,0 +1,27 @@
+package androidx.media3.exoplayer.source;
+
+import androidx.annotation.Nullable;
+import androidx.media3.common.C;
+import androidx.media3.extractor.TrackOutput;
+
+/* package */ final class SampleMetadata {
+  final long timeUs;
+
+  @C.BufferFlags
+  final int flags;
+
+  final int size;
+
+  final long absoluteOffset;
+
+  @Nullable
+  final TrackOutput.CryptoData cryptoData;
+
+  SampleMetadata(long timeUs, @C.BufferFlags int flags, int size, long absoluteOffset, @Nullable TrackOutput.CryptoData cryptoData) {
+    this.timeUs = timeUs;
+    this.flags = flags;
+    this.size = size;
+    this.absoluteOffset = absoluteOffset;
+    this.cryptoData = cryptoData;
+  }
+}

libraries/exoplayer/src/main/java/androidx/media3/exoplayer/source/SampleQueue.java

@@ -50,6 +50,8 @@
 import androidx.media3.exoplayer.upstream.Allocator;
 import androidx.media3.extractor.TrackOutput;
 import java.io.IOException;
+import java.util.LinkedList;
+import java.util.Queue;
 import org.checkerframework.checker.nullness.compatqual.NullableType;
 
 /** A queue of media samples. */
@@ -109,6 +111,8 @@ public interface UpstreamFormatChangedListener {
   private long sampleOffsetUs;
   private boolean pendingSplice;
 
+  private final Queue<SampleMetadata> metadataQueue;
+
   /**
    * Creates a sample queue without DRM resource management.
    *
@@ -181,6 +185,8 @@ protected SampleQueue(
     largestQueuedTimestampUs = Long.MIN_VALUE;
     upstreamFormatRequired = true;
     upstreamKeyframeRequired = true;
+
+    metadataQueue = new LinkedList<>();
   }
 
   // Called by the consuming thread when there is no loading thread.
@@ -642,7 +648,25 @@ public void sampleMetadata(
     }
 
     long absoluteOffset = sampleDataQueue.getTotalBytesWritten() - size - offset;
-    commitSample(timeUs, flags, absoluteOffset, size, cryptoData);
+    if (timeUs < startTimeUs) {
+      if (isKeyframe) {
+        // encountered sync frame before playback began - clear waiting frames
+        metadataQueue.clear();
+      }
+
+      SampleMetadata metadata = new SampleMetadata(timeUs, flags, size, absoluteOffset, cryptoData);
+
+      metadataQueue.add(metadata);
+    } else {
+      // encountered start time, flush all waiting commits
+      while (!metadataQueue.isEmpty()) {
+        SampleMetadata metadata = metadataQueue.poll();
+        Assertions.checkNotNull(metadata);
+        commitSample(metadata.timeUs, metadata.flags, metadata.absoluteOffset, metadata.size, metadata.cryptoData);
+      }
+
+      commitSample(timeUs, flags, absoluteOffset, size, cryptoData);
+    }
   }
 
   /**