Small fixes in TextureAssetLoader

The texture input tests in TransformerEndToEndTest were not passing on
Pixel 7. Implemented a fix and fixed other minor threading issues I
spotted while looking at the code.

PiperOrigin-RevId: 531141659

library/transformer/src/main/java/com/google/android/exoplayer2/transformer/TextureAssetLoader.java

@@ -28,6 +28,7 @@ import com.google.android.exoplayer2.Format;
 import com.google.android.exoplayer2.util.MimeTypes;
 import com.google.android.exoplayer2.util.MimeTypes;
 import com.google.android.exoplayer2.util.VideoFrameProcessor.OnInputFrameProcessedListener;
 import com.google.android.exoplayer2.util.VideoFrameProcessor.OnInputFrameProcessedListener;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableMap;
+import org.checkerframework.checker.nullness.qual.MonotonicNonNull;
 
 
 /**
 /**
  * An {@link AssetLoader} implementation that loads videos from {@linkplain
  * An {@link AssetLoader} implementation that loads videos from {@linkplain
@@ -44,11 +45,13 @@ public final class TextureAssetLoader implements AssetLoader {
   private final Format format;
   private final Format format;
   private final OnInputFrameProcessedListener frameProcessedListener;
   private final OnInputFrameProcessedListener frameProcessedListener;
 
 
-  @Nullable private SampleConsumer sampleConsumer;
+  private @MonotonicNonNull SampleConsumer sampleConsumer;
   private @Transformer.ProgressState int progressState;
   private @Transformer.ProgressState int progressState;
-  private long lastQueuedPresentationTimeUs;
   private boolean isTrackAdded;
   private boolean isTrackAdded;
 
 
+  private volatile boolean isStarted;
+  private volatile long lastQueuedPresentationTimeUs;
+
   /**
   /**
    * Creates an instance.
    * Creates an instance.
    *
    *
@@ -74,6 +77,7 @@ public final class TextureAssetLoader implements AssetLoader {
     progressState = PROGRESS_STATE_AVAILABLE;
     progressState = PROGRESS_STATE_AVAILABLE;
     assetLoaderListener.onDurationUs(editedMediaItem.durationUs);
     assetLoaderListener.onDurationUs(editedMediaItem.durationUs);
     assetLoaderListener.onTrackCount(1);
     assetLoaderListener.onTrackCount(1);
+    isStarted = true;
   }
   }
 
 
   @Override
   @Override
@@ -92,9 +96,7 @@ public final class TextureAssetLoader implements AssetLoader {
 
 
   @Override
   @Override
   public void release() {
   public void release() {
-    isTrackAdded = false;
     progressState = PROGRESS_STATE_NOT_STARTED;
     progressState = PROGRESS_STATE_NOT_STARTED;
-    sampleConsumer = null;
   }
   }
 
 
   /**
   /**
@@ -110,14 +112,18 @@ public final class TextureAssetLoader implements AssetLoader {
   public boolean queueInputTexture(int texId, long presentationTimeUs) {
   public boolean queueInputTexture(int texId, long presentationTimeUs) {
     try {
     try {
       if (!isTrackAdded) {
       if (!isTrackAdded) {
+        if (!isStarted) {
+          return false;
+        }
         assetLoaderListener.onTrackAdded(format, SUPPORTED_OUTPUT_TYPE_DECODED);
         assetLoaderListener.onTrackAdded(format, SUPPORTED_OUTPUT_TYPE_DECODED);
         isTrackAdded = true;
         isTrackAdded = true;
       }
       }
       if (sampleConsumer == null) {
       if (sampleConsumer == null) {
-        sampleConsumer = assetLoaderListener.onOutputFormat(format);
+        @Nullable SampleConsumer sampleConsumer = assetLoaderListener.onOutputFormat(format);
         if (sampleConsumer == null) {
         if (sampleConsumer == null) {
           return false;
           return false;
         } else {
         } else {
+          this.sampleConsumer = sampleConsumer;
           sampleConsumer.setOnInputFrameProcessedListener(frameProcessedListener);
           sampleConsumer.setOnInputFrameProcessedListener(frameProcessedListener);
         }
         }
       }
       }