Skip to content

SDK / exoplayer

Go to a project
Commit 12559bbc by olly Committed by Oliver Woodman
Options

DefaultAudioSink: Make PCM vs non-PCM code paths clearer 

This change replaces a lot of individual isInputPcm branching with a single,
larger branch.

PiperOrigin-RevId: 321763040
parent bcf218da
Inline Side-by-side
Showing with 84 additions and 63 deletions
library/core/src/main/java/com/google/android/exoplayer2/audio/DefaultAudioSink.java
...@@ -470,14 +470,27 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -470,14 +470,27 @@ public final class DefaultAudioSink implements AudioSink {
public void configure(Format inputFormat, int specifiedBufferSize, @Nullable int[] outputChannels) public void configure(Format inputFormat, int specifiedBufferSize, @Nullable int[] outputChannels)
throws ConfigurationException { throws ConfigurationException {
boolean isInputPcm = Util.isEncodingLinearPcm(inputFormat.encoding); boolean isInputPcm = Util.isEncodingLinearPcm(inputFormat.encoding);
int sampleRate = inputFormat.sampleRate;
int channelCount = inputFormat.channelCount; int inputPcmFrameSize;
@C.Encoding int encoding = inputFormat.encoding; @Nullable AudioProcessor[] availableAudioProcessors;
boolean canApplyPlaybackParameters;
boolean useOffload;
@C.Encoding int outputEncoding;
int outputSampleRate;
int outputChannelCount;
int outputChannelConfig;
int outputPcmFrameSize;
if (isInputPcm) {
inputPcmFrameSize = Util.getPcmFrameSize(inputFormat.encoding, inputFormat.channelCount);
boolean useFloatOutput = boolean useFloatOutput =
enableFloatOutput && Util.isEncodingHighResolutionPcm(inputFormat.encoding); enableFloatOutput && Util.isEncodingHighResolutionPcm(inputFormat.encoding);
AudioProcessor[] availableAudioProcessors = availableAudioProcessors =
useFloatOutput ? toFloatPcmAvailableAudioProcessors : toIntPcmAvailableAudioProcessors; useFloatOutput ? toFloatPcmAvailableAudioProcessors : toIntPcmAvailableAudioProcessors;
if (isInputPcm) { canApplyPlaybackParameters = !useFloatOutput;
trimmingAudioProcessor.setTrimFrameCount( trimmingAudioProcessor.setTrimFrameCount(
inputFormat.encoderDelay, inputFormat.encoderPadding); inputFormat.encoderDelay, inputFormat.encoderPadding);
...@@ -492,7 +505,8 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -492,7 +505,8 @@ public final class DefaultAudioSink implements AudioSink {
channelMappingAudioProcessor.setChannelMap(outputChannels); channelMappingAudioProcessor.setChannelMap(outputChannels);
AudioProcessor.AudioFormat outputFormat = AudioProcessor.AudioFormat outputFormat =
new AudioProcessor.AudioFormat(sampleRate, channelCount, encoding); new AudioProcessor.AudioFormat(
inputFormat.sampleRate, inputFormat.channelCount, inputFormat.encoding);
for (AudioProcessor audioProcessor : availableAudioProcessors) { for (AudioProcessor audioProcessor : availableAudioProcessors) {
try { try {
AudioProcessor.AudioFormat nextFormat = audioProcessor.configure(outputFormat); AudioProcessor.AudioFormat nextFormat = audioProcessor.configure(outputFormat);
...@@ -503,33 +517,40 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -503,33 +517,40 @@ public final class DefaultAudioSink implements AudioSink {
throw new ConfigurationException(e); throw new ConfigurationException(e);
} }
} }
sampleRate = outputFormat.sampleRate;
channelCount = outputFormat.channelCount;
encoding = outputFormat.encoding;
}
int outputChannelConfig = getChannelConfig(channelCount, isInputPcm);
if (outputChannelConfig == AudioFormat.CHANNEL_INVALID) {
throw new ConfigurationException("Unsupported channel count: " + channelCount);
}
int inputPcmFrameSize = useOffload = false;
isInputPcm outputEncoding = outputFormat.encoding;
? Util.getPcmFrameSize(inputFormat.encoding, inputFormat.channelCount) outputSampleRate = outputFormat.sampleRate;
: C.LENGTH_UNSET; outputChannelCount = outputFormat.channelCount;
int outputPcmFrameSize = outputChannelConfig = Util.getAudioTrackChannelConfig(outputChannelCount);
isInputPcm ? Util.getPcmFrameSize(encoding, channelCount) : C.LENGTH_UNSET; outputPcmFrameSize = Util.getPcmFrameSize(outputEncoding, outputChannelCount);
boolean canApplyPlaybackParameters = isInputPcm && !useFloatOutput; } else {
boolean useOffload = // We're configuring for either passthrough or offload.
useOffload =
enableOffload enableOffload
&& !isInputPcm
&& isOffloadedPlaybackSupported( && isOffloadedPlaybackSupported(
channelCount, inputFormat.channelCount,
sampleRate, inputFormat.sampleRate,
encoding, inputFormat.encoding,
audioAttributes, audioAttributes,
inputFormat.encoderDelay, inputFormat.encoderDelay,
inputFormat.encoderPadding); inputFormat.encoderPadding);
inputPcmFrameSize = C.LENGTH_UNSET;
availableAudioProcessors = new AudioProcessor[0];
canApplyPlaybackParameters = false;
outputEncoding = inputFormat.encoding;
outputSampleRate = inputFormat.sampleRate;
outputChannelCount = inputFormat.channelCount;
outputPcmFrameSize = C.LENGTH_UNSET;
outputChannelConfig =
useOffload
? Util.getAudioTrackChannelConfig(outputChannelCount)
: getChannelConfigForPassthrough(inputFormat.channelCount);
}
if (outputChannelConfig == AudioFormat.CHANNEL_INVALID) {
throw new ConfigurationException("Unsupported channel count: " + outputChannelCount);
}
Configuration pendingConfiguration = Configuration pendingConfiguration =
new Configuration( new Configuration(
...@@ -537,9 +558,9 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -537,9 +558,9 @@ public final class DefaultAudioSink implements AudioSink {
inputPcmFrameSize, inputPcmFrameSize,
inputFormat.sampleRate, inputFormat.sampleRate,
outputPcmFrameSize, outputPcmFrameSize,
sampleRate, outputSampleRate,
outputChannelConfig, outputChannelConfig,
encoding, outputEncoding,
specifiedBufferSize, specifiedBufferSize,
canApplyPlaybackParameters, canApplyPlaybackParameters,
availableAudioProcessors, availableAudioProcessors,
...@@ -900,7 +921,7 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -900,7 +921,7 @@ public final class DefaultAudioSink implements AudioSink {
private boolean drainToEndOfStream() throws WriteException { private boolean drainToEndOfStream() throws WriteException {
boolean audioProcessorNeedsEndOfStream = false; boolean audioProcessorNeedsEndOfStream = false;
if (drainingAudioProcessorIndex == C.INDEX_UNSET) { if (drainingAudioProcessorIndex == C.INDEX_UNSET) {
drainingAudioProcessorIndex = configuration.isInputPcm ? 0 : activeAudioProcessors.length; drainingAudioProcessorIndex = 0;
audioProcessorNeedsEndOfStream = true; audioProcessorNeedsEndOfStream = true;
} }
while (drainingAudioProcessorIndex < activeAudioProcessors.length) { while (drainingAudioProcessorIndex < activeAudioProcessors.length) {
...@@ -1285,8 +1306,8 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -1285,8 +1306,8 @@ public final class DefaultAudioSink implements AudioSink {
if (Util.SDK_INT < 29) { if (Util.SDK_INT < 29) {
return false; return false;
} }
int channelMask = getChannelConfig(channelCount, /* isInputPcm= */ false); int channelConfig = Util.getAudioTrackChannelConfig(channelCount);
AudioFormat audioFormat = getAudioFormat(sampleRateHz, channelMask, encoding); AudioFormat audioFormat = getAudioFormat(sampleRateHz, channelConfig, encoding);
if (!AudioManager.isOffloadedPlaybackSupported( if (!AudioManager.isOffloadedPlaybackSupported(
audioFormat, audioAttributes.getAudioAttributesV21())) { audioFormat, audioAttributes.getAudioAttributesV21())) {
return false; return false;
...@@ -1310,32 +1331,6 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -1310,32 +1331,6 @@ public final class DefaultAudioSink implements AudioSink {
return Util.SDK_INT >= 29 && audioTrack.isOffloadedPlayback(); return Util.SDK_INT >= 29 && audioTrack.isOffloadedPlayback();
} }
@RequiresApi(29)
private final class StreamEventCallbackV29 extends AudioTrack.StreamEventCallback {
private final Handler handler;
public StreamEventCallbackV29() {
handler = new Handler();
}
@Override
public void onDataRequest(AudioTrack track, int size) {
Assertions.checkState(track == DefaultAudioSink.this.audioTrack);
if (listener != null) {
listener.onOffloadBufferEmptying();
}
}
public void register(AudioTrack audioTrack) {
audioTrack.registerStreamEventCallback(handler::post, this);
}
public void unregister(AudioTrack audioTrack) {
audioTrack.unregisterStreamEventCallback(this);
handler.removeCallbacksAndMessages(/* token= */ null);
}
}
private static AudioTrack initializeKeepSessionIdAudioTrack(int audioSessionId) { private static AudioTrack initializeKeepSessionIdAudioTrack(int audioSessionId) {
int sampleRate = 4000; // Equal to private AudioTrack.MIN_SAMPLE_RATE. int sampleRate = 4000; // Equal to private AudioTrack.MIN_SAMPLE_RATE.
int channelConfig = AudioFormat.CHANNEL_OUT_MONO; int channelConfig = AudioFormat.CHANNEL_OUT_MONO;
...@@ -1345,8 +1340,8 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -1345,8 +1340,8 @@ public final class DefaultAudioSink implements AudioSink {
MODE_STATIC, audioSessionId); MODE_STATIC, audioSessionId);
} }
private static int getChannelConfig(int channelCount, boolean isInputPcm) { private static int getChannelConfigForPassthrough(int channelCount) {
if (Util.SDK_INT <= 28 && !isInputPcm) { if (Util.SDK_INT <= 28) {
// In passthrough mode the channel count used to configure the audio track doesn't affect how // In passthrough mode the channel count used to configure the audio track doesn't affect how
// the stream is handled, except that some devices do overly-strict channel configuration // the stream is handled, except that some devices do overly-strict channel configuration
// checks. Therefore we override the channel count so that a known-working channel // checks. Therefore we override the channel count so that a known-working channel
...@@ -1358,9 +1353,9 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -1358,9 +1353,9 @@ public final class DefaultAudioSink implements AudioSink {
} }
} }
// Workaround for Nexus Player not reporting support for mono passthrough. // Workaround for Nexus Player not reporting support for mono passthrough. See
// (See [Internal: b/34268671].) // [Internal: b/34268671].
if (Util.SDK_INT <= 26 && "fugu".equals(Util.DEVICE) && !isInputPcm && channelCount == 1) { if (Util.SDK_INT <= 26 && "fugu".equals(Util.DEVICE) && channelCount == 1) {
channelCount = 2; channelCount = 2;
} }
...@@ -1514,6 +1509,32 @@ public final class DefaultAudioSink implements AudioSink { ...@@ -1514,6 +1509,32 @@ public final class DefaultAudioSink implements AudioSink {
} }
} }
@RequiresApi(29)
private final class StreamEventCallbackV29 extends AudioTrack.StreamEventCallback {
private final Handler handler;
public StreamEventCallbackV29() {
handler = new Handler();
}
@Override
public void onDataRequest(AudioTrack track, int size) {
Assertions.checkState(track == DefaultAudioSink.this.audioTrack);
if (listener != null) {
listener.onOffloadBufferEmptying();
}
}
public void register(AudioTrack audioTrack) {
audioTrack.registerStreamEventCallback(handler::post, this);
}
public void unregister(AudioTrack audioTrack) {
audioTrack.unregisterStreamEventCallback(this);
handler.removeCallbacksAndMessages(/* token= */ null);
}
}
/** Stores parameters used to calculate the current media position. */ /** Stores parameters used to calculate the current media position. */
private static final class MediaPositionParameters { private static final class MediaPositionParameters {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment