sjs/media
1
0
Fork 0
mirror of https://github.com/samsonjs/media.git synced 2026-04-21 13:55:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Avoid using unneeded double ended queue.

Browse source 
These usages have no need for the double ended input functionality. All
other usages across media3 are ConcurrentLinkedQueue.

PiperOrigin-RevId: 584841104
This commit is contained in:
samrobinson 2023-11-23 02:48:54 -08:00 committed by Copybara-Service
parent 0f040e6c6e
commit 1524d12634
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
libraries/transformer/src/main/java/androidx/media3/transformer/AudioGraphInput.java
View file

@ -42,7 +42,7 @@ import com.google.common.collect.ImmutableList;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedDeque;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicReference;
/**
@ -72,14 +72,14 @@ import java.util.concurrent.atomic.AtomicReference;
AudioFormat inputAudioFormat = new AudioFormat(inputFormat);
checkArgument(isInputAudioFormatValid(inputAudioFormat), /* errorMessage= */ inputAudioFormat);
availableInputBuffers = new ConcurrentLinkedDeque<>();
availableInputBuffers = new ConcurrentLinkedQueue<>();
ByteBuffer emptyBuffer = ByteBuffer.allocateDirect(0).order(ByteOrder.nativeOrder());
for (int i = 0; i < MAX_INPUT_BUFFER_COUNT; i++) {
DecoderInputBuffer inputBuffer = new DecoderInputBuffer(BUFFER_REPLACEMENT_MODE_DIRECT);
inputBuffer.data = emptyBuffer;
availableInputBuffers.add(inputBuffer);
}
pendingInputBuffers = new ConcurrentLinkedDeque<>();
pendingInputBuffers = new ConcurrentLinkedQueue<>();
pendingMediaItemChange = new AtomicReference<>();
silentAudioGenerator = new SilentAudioGenerator(inputAudioFormat);
audioProcessingPipeline =

6
libraries/transformer/src/main/java/androidx/media3/transformer/EncodedSampleExporter.java
View file

@ -26,7 +26,7 @@ import androidx.media3.decoder.DecoderInputBuffer;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedDeque;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicLong;
/** Muxes encoded samples without any transcoding or transformation. */
@ -73,8 +73,8 @@ import java.util.concurrent.atomic.AtomicLong;
this.format = format;
this.initialTimestampOffsetUs = initialTimestampOffsetUs;
nextMediaItemOffsetUs = new AtomicLong();
availableInputBuffers = new ConcurrentLinkedDeque<>();
pendingInputBuffers = new ConcurrentLinkedDeque<>();
availableInputBuffers = new ConcurrentLinkedQueue<>();
pendingInputBuffers = new ConcurrentLinkedQueue<>();
fallbackListener.onTransformationRequestFinalized(transformationRequest);
}