package androidx.media3.exoplayer.source; import android.net.Uri; import android.os.Handler; import androidx.media3.common.C; import androidx.media3.common.DataReader; import androidx.media3.common.Format; import androidx.media3.common.Metadata; import androidx.media3.common.MimeTypes; import androidx.media3.common.ParserException; import androidx.media3.common.TrackGroup; import androidx.media3.common.util.Assertions; import androidx.media3.common.util.ConditionVariable; import androidx.media3.common.util.Log; import androidx.media3.common.util.ParsableByteArray; import androidx.media3.common.util.Util; import androidx.media3.datasource.DataSource; import androidx.media3.datasource.DataSourceUtil; import androidx.media3.datasource.DataSpec; import androidx.media3.datasource.StatsDataSource; import androidx.media3.decoder.DecoderInputBuffer; import androidx.media3.exoplayer.FormatHolder; import androidx.media3.exoplayer.LoadingInfo; import androidx.media3.exoplayer.SeekParameters; import androidx.media3.exoplayer.drm.DrmSessionEventListener; import androidx.media3.exoplayer.drm.DrmSessionManager; import androidx.media3.exoplayer.source.IcyDataSource; import androidx.media3.exoplayer.source.MediaPeriod; import androidx.media3.exoplayer.source.MediaSourceEventListener; import androidx.media3.exoplayer.source.SampleQueue; import androidx.media3.exoplayer.trackselection.ExoTrackSelection; import androidx.media3.exoplayer.upstream.Allocator; import androidx.media3.exoplayer.upstream.LoadErrorHandlingPolicy; import androidx.media3.exoplayer.upstream.Loader; import androidx.media3.extractor.DiscardingTrackOutput; import androidx.media3.extractor.ExtractorOutput; import androidx.media3.extractor.ForwardingSeekMap; import androidx.media3.extractor.PositionHolder; import androidx.media3.extractor.SeekMap; import androidx.media3.extractor.TrackOutput; import androidx.media3.extractor.metadata.icy.IcyHeaders; import java.io.IOException; import java.io.InterruptedIOException; import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.Map; /* JADX INFO: loaded from: classes.dex */ final class ProgressiveMediaPeriod implements MediaPeriod, ExtractorOutput, Loader.Callback, Loader.ReleaseCallback, SampleQueue.UpstreamFormatChangedListener { private static final long DEFAULT_LAST_SAMPLE_DURATION_US = 10000; private static final String TAG = "ProgressiveMediaPeriod"; private final Allocator allocator; private MediaPeriod.Callback callback; private final long continueLoadingCheckIntervalBytes; private final String customCacheKey; private final DataSource dataSource; private final DrmSessionEventListener.EventDispatcher drmEventDispatcher; private final DrmSessionManager drmSessionManager; private long durationUs; private int enabledTrackCount; private int extractedSamplesCountAtStartOfLoad; private boolean haveAudioVideoTracks; private IcyHeaders icyHeaders; private boolean isLengthKnown; private boolean isLive; private boolean isSingleSample; private long lastSeekPositionUs; private final Listener listener; private final LoadErrorHandlingPolicy loadErrorHandlingPolicy; private boolean loadingFinished; private final MediaSourceEventListener.EventDispatcher mediaSourceEventDispatcher; private boolean notifyDiscontinuity; private boolean pendingDeferredRetry; private boolean prepared; private final ProgressiveMediaExtractor progressiveMediaExtractor; private boolean released; private boolean sampleQueuesBuilt; private SeekMap seekMap; private boolean seenFirstTrackSelection; private final long singleSampleDurationUs; private TrackState trackState; private final Uri uri; private static final Map ICY_METADATA_HEADERS = createIcyMetadataHeaders(); private static final Format ICY_FORMAT = new Format.Builder().setId("icy").setSampleMimeType(MimeTypes.APPLICATION_ICY).build(); private final Loader loader = new Loader(TAG); private final ConditionVariable loadCondition = new ConditionVariable(); private final Runnable maybeFinishPrepareRunnable = new j(this, 1); private final Runnable onContinueLoadingRequestedRunnable = new j(this, 2); private final Handler handler = Util.createHandlerForCurrentLooper(); private TrackId[] sampleQueueTrackIds = new TrackId[0]; private SampleQueue[] sampleQueues = new SampleQueue[0]; private long pendingResetPositionUs = C.TIME_UNSET; private int dataType = 1; public final class ExtractingLoadable implements Loader.Loadable, IcyDataSource.Listener { private final StatsDataSource dataSource; private final ExtractorOutput extractorOutput; private TrackOutput icyTrackOutput; private volatile boolean loadCanceled; private final ConditionVariable loadCondition; private final ProgressiveMediaExtractor progressiveMediaExtractor; private long seekTimeUs; private boolean seenIcyMetadata; private final Uri uri; private final PositionHolder positionHolder = new PositionHolder(); private boolean pendingExtractorSeek = true; private final long loadTaskId = LoadEventInfo.getNewId(); private DataSpec dataSpec = buildDataSpec(0); public ExtractingLoadable(Uri uri, DataSource dataSource, ProgressiveMediaExtractor progressiveMediaExtractor, ExtractorOutput extractorOutput, ConditionVariable conditionVariable) { this.uri = uri; this.dataSource = new StatsDataSource(dataSource); this.progressiveMediaExtractor = progressiveMediaExtractor; this.extractorOutput = extractorOutput; this.loadCondition = conditionVariable; } private DataSpec buildDataSpec(long j4) { return new DataSpec.Builder().setUri(this.uri).setPosition(j4).setKey(ProgressiveMediaPeriod.this.customCacheKey).setFlags(6).setHttpRequestHeaders(ProgressiveMediaPeriod.ICY_METADATA_HEADERS).build(); } /* JADX INFO: Access modifiers changed from: private */ public void setLoadPosition(long j4, long j6) { this.positionHolder.position = j4; this.seekTimeUs = j6; this.pendingExtractorSeek = true; this.seenIcyMetadata = false; } @Override // androidx.media3.exoplayer.upstream.Loader.Loadable public void cancelLoad() { this.loadCanceled = true; } @Override // androidx.media3.exoplayer.upstream.Loader.Loadable public void load() { int i6 = 0; while (i6 == 0 && !this.loadCanceled) { try { long j4 = this.positionHolder.position; DataSpec dataSpecBuildDataSpec = buildDataSpec(j4); this.dataSpec = dataSpecBuildDataSpec; long jOpen = this.dataSource.open(dataSpecBuildDataSpec); if (this.loadCanceled) { if (i6 != 1 && this.progressiveMediaExtractor.getCurrentInputPosition() != -1) { this.positionHolder.position = this.progressiveMediaExtractor.getCurrentInputPosition(); } DataSourceUtil.closeQuietly(this.dataSource); return; } if (jOpen != -1) { jOpen += j4; ProgressiveMediaPeriod.this.onLengthKnown(); } long j6 = jOpen; ProgressiveMediaPeriod.this.icyHeaders = IcyHeaders.parse(this.dataSource.getResponseHeaders()); DataReader icyDataSource = this.dataSource; if (ProgressiveMediaPeriod.this.icyHeaders != null && ProgressiveMediaPeriod.this.icyHeaders.metadataInterval != -1) { icyDataSource = new IcyDataSource(this.dataSource, ProgressiveMediaPeriod.this.icyHeaders.metadataInterval, this); TrackOutput trackOutputIcyTrack = ProgressiveMediaPeriod.this.icyTrack(); this.icyTrackOutput = trackOutputIcyTrack; trackOutputIcyTrack.format(ProgressiveMediaPeriod.ICY_FORMAT); } this.progressiveMediaExtractor.init(icyDataSource, this.uri, this.dataSource.getResponseHeaders(), j4, j6, this.extractorOutput); if (ProgressiveMediaPeriod.this.icyHeaders != null) { this.progressiveMediaExtractor.disableSeekingOnMp3Streams(); } if (this.pendingExtractorSeek) { this.progressiveMediaExtractor.seek(j4, this.seekTimeUs); this.pendingExtractorSeek = false; } while (i6 == 0 && !this.loadCanceled) { try { this.loadCondition.block(); i6 = this.progressiveMediaExtractor.read(this.positionHolder); long currentInputPosition = this.progressiveMediaExtractor.getCurrentInputPosition(); if (currentInputPosition > ProgressiveMediaPeriod.this.continueLoadingCheckIntervalBytes + j4) { this.loadCondition.close(); ProgressiveMediaPeriod.this.handler.post(ProgressiveMediaPeriod.this.onContinueLoadingRequestedRunnable); j4 = currentInputPosition; } } catch (InterruptedException unused) { throw new InterruptedIOException(); } } if (i6 == 1) { i6 = 0; } else if (this.progressiveMediaExtractor.getCurrentInputPosition() != -1) { this.positionHolder.position = this.progressiveMediaExtractor.getCurrentInputPosition(); } DataSourceUtil.closeQuietly(this.dataSource); } catch (Throwable th) { if (i6 != 1 && this.progressiveMediaExtractor.getCurrentInputPosition() != -1) { this.positionHolder.position = this.progressiveMediaExtractor.getCurrentInputPosition(); } DataSourceUtil.closeQuietly(this.dataSource); throw th; } } } @Override // androidx.media3.exoplayer.source.IcyDataSource.Listener public void onIcyMetadata(ParsableByteArray parsableByteArray) { long jMax = !this.seenIcyMetadata ? this.seekTimeUs : Math.max(ProgressiveMediaPeriod.this.getLargestQueuedTimestampUs(true), this.seekTimeUs); int iBytesLeft = parsableByteArray.bytesLeft(); TrackOutput trackOutput = (TrackOutput) Assertions.checkNotNull(this.icyTrackOutput); trackOutput.sampleData(parsableByteArray, iBytesLeft); trackOutput.sampleMetadata(jMax, 1, iBytesLeft, 0, null); this.seenIcyMetadata = true; } } public interface Listener { void onSourceInfoRefreshed(long j4, boolean z6, boolean z7); } public final class SampleStreamImpl implements SampleStream { private final int track; public SampleStreamImpl(int i6) { this.track = i6; } @Override // androidx.media3.exoplayer.source.SampleStream public boolean isReady() { return ProgressiveMediaPeriod.this.isReady(this.track); } @Override // androidx.media3.exoplayer.source.SampleStream public void maybeThrowError() { ProgressiveMediaPeriod.this.maybeThrowError(this.track); } @Override // androidx.media3.exoplayer.source.SampleStream public int readData(FormatHolder formatHolder, DecoderInputBuffer decoderInputBuffer, int i6) { return ProgressiveMediaPeriod.this.readData(this.track, formatHolder, decoderInputBuffer, i6); } @Override // androidx.media3.exoplayer.source.SampleStream public int skipData(long j4) { return ProgressiveMediaPeriod.this.skipData(this.track, j4); } } public static final class TrackId { public final int id; public final boolean isIcyTrack; public TrackId(int i6, boolean z6) { this.id = i6; this.isIcyTrack = z6; } public boolean equals(Object obj) { if (this == obj) { return true; } if (obj != null && TrackId.class == obj.getClass()) { TrackId trackId = (TrackId) obj; if (this.id == trackId.id && this.isIcyTrack == trackId.isIcyTrack) { return true; } } return false; } public int hashCode() { return (this.id * 31) + (this.isIcyTrack ? 1 : 0); } } public static final class TrackState { public final boolean[] trackEnabledStates; public final boolean[] trackIsAudioVideoFlags; public final boolean[] trackNotifiedDownstreamFormats; public final TrackGroupArray tracks; public TrackState(TrackGroupArray trackGroupArray, boolean[] zArr) { this.tracks = trackGroupArray; this.trackIsAudioVideoFlags = zArr; int i6 = trackGroupArray.length; this.trackEnabledStates = new boolean[i6]; this.trackNotifiedDownstreamFormats = new boolean[i6]; } } public ProgressiveMediaPeriod(Uri uri, DataSource dataSource, ProgressiveMediaExtractor progressiveMediaExtractor, DrmSessionManager drmSessionManager, DrmSessionEventListener.EventDispatcher eventDispatcher, LoadErrorHandlingPolicy loadErrorHandlingPolicy, MediaSourceEventListener.EventDispatcher eventDispatcher2, Listener listener, Allocator allocator, String str, int i6, long j4) { this.uri = uri; this.dataSource = dataSource; this.drmSessionManager = drmSessionManager; this.drmEventDispatcher = eventDispatcher; this.loadErrorHandlingPolicy = loadErrorHandlingPolicy; this.mediaSourceEventDispatcher = eventDispatcher2; this.listener = listener; this.allocator = allocator; this.customCacheKey = str; this.continueLoadingCheckIntervalBytes = i6; this.progressiveMediaExtractor = progressiveMediaExtractor; this.singleSampleDurationUs = j4; } private void assertPrepared() { Assertions.checkState(this.prepared); Assertions.checkNotNull(this.trackState); Assertions.checkNotNull(this.seekMap); } private boolean configureRetry(ExtractingLoadable extractingLoadable, int i6) { SeekMap seekMap; if (this.isLengthKnown || !((seekMap = this.seekMap) == null || seekMap.getDurationUs() == C.TIME_UNSET)) { this.extractedSamplesCountAtStartOfLoad = i6; return true; } if (this.prepared && !suppressRead()) { this.pendingDeferredRetry = true; return false; } this.notifyDiscontinuity = this.prepared; this.lastSeekPositionUs = 0L; this.extractedSamplesCountAtStartOfLoad = 0; for (SampleQueue sampleQueue : this.sampleQueues) { sampleQueue.reset(); } extractingLoadable.setLoadPosition(0L, 0L); return true; } private static Map createIcyMetadataHeaders() { HashMap map = new HashMap(); map.put(IcyHeaders.REQUEST_HEADER_ENABLE_METADATA_NAME, "1"); return Collections.unmodifiableMap(map); } private int getExtractedSamplesCount() { int writeIndex = 0; for (SampleQueue sampleQueue : this.sampleQueues) { writeIndex += sampleQueue.getWriteIndex(); } return writeIndex; } /* JADX INFO: Access modifiers changed from: private */ public long getLargestQueuedTimestampUs(boolean z6) { long jMax = Long.MIN_VALUE; for (int i6 = 0; i6 < this.sampleQueues.length; i6++) { if (z6 || ((TrackState) Assertions.checkNotNull(this.trackState)).trackEnabledStates[i6]) { jMax = Math.max(jMax, this.sampleQueues[i6].getLargestQueuedTimestampUs()); } } return jMax; } private boolean isPendingReset() { return this.pendingResetPositionUs != C.TIME_UNSET; } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$new$0() { if (this.released) { return; } ((MediaPeriod.Callback) Assertions.checkNotNull(this.callback)).onContinueLoadingRequested(this); } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$onLengthKnown$2() { this.isLengthKnown = true; } /* JADX INFO: Access modifiers changed from: private */ public void maybeFinishPrepare() { if (this.released || this.prepared || !this.sampleQueuesBuilt || this.seekMap == null) { return; } for (SampleQueue sampleQueue : this.sampleQueues) { if (sampleQueue.getUpstreamFormat() == null) { return; } } this.loadCondition.close(); int length = this.sampleQueues.length; TrackGroup[] trackGroupArr = new TrackGroup[length]; boolean[] zArr = new boolean[length]; for (int i6 = 0; i6 < length; i6++) { Format formatBuild = (Format) Assertions.checkNotNull(this.sampleQueues[i6].getUpstreamFormat()); String str = formatBuild.sampleMimeType; boolean zIsAudio = MimeTypes.isAudio(str); boolean z6 = zIsAudio || MimeTypes.isVideo(str); zArr[i6] = z6; this.haveAudioVideoTracks = z6 | this.haveAudioVideoTracks; this.isSingleSample = this.singleSampleDurationUs != C.TIME_UNSET && length == 1 && MimeTypes.isImage(str); IcyHeaders icyHeaders = this.icyHeaders; if (icyHeaders != null) { if (zIsAudio || this.sampleQueueTrackIds[i6].isIcyTrack) { Metadata metadata = formatBuild.metadata; formatBuild = formatBuild.buildUpon().setMetadata(metadata == null ? new Metadata(icyHeaders) : metadata.copyWithAppendedEntries(icyHeaders)).build(); } if (zIsAudio && formatBuild.averageBitrate == -1 && formatBuild.peakBitrate == -1 && icyHeaders.bitrate != -1) { formatBuild = formatBuild.buildUpon().setAverageBitrate(icyHeaders.bitrate).build(); } } trackGroupArr[i6] = new TrackGroup(Integer.toString(i6), formatBuild.copyWithCryptoType(this.drmSessionManager.getCryptoType(formatBuild))); } this.trackState = new TrackState(new TrackGroupArray(trackGroupArr), zArr); if (this.isSingleSample && this.durationUs == C.TIME_UNSET) { this.durationUs = this.singleSampleDurationUs; this.seekMap = new ForwardingSeekMap(this.seekMap) { // from class: androidx.media3.exoplayer.source.ProgressiveMediaPeriod.1 @Override // androidx.media3.extractor.ForwardingSeekMap, androidx.media3.extractor.SeekMap public long getDurationUs() { return ProgressiveMediaPeriod.this.durationUs; } }; } this.listener.onSourceInfoRefreshed(this.durationUs, this.seekMap.isSeekable(), this.isLive); this.prepared = true; ((MediaPeriod.Callback) Assertions.checkNotNull(this.callback)).onPrepared(this); } private void maybeNotifyDownstreamFormat(int i6) { assertPrepared(); TrackState trackState = this.trackState; boolean[] zArr = trackState.trackNotifiedDownstreamFormats; if (zArr[i6]) { return; } Format format = trackState.tracks.get(i6).getFormat(0); this.mediaSourceEventDispatcher.downstreamFormatChanged(MimeTypes.getTrackType(format.sampleMimeType), format, 0, null, this.lastSeekPositionUs); zArr[i6] = true; } private void maybeStartDeferredRetry(int i6) { assertPrepared(); boolean[] zArr = this.trackState.trackIsAudioVideoFlags; if (this.pendingDeferredRetry && zArr[i6]) { if (this.sampleQueues[i6].isReady(false)) { return; } this.pendingResetPositionUs = 0L; this.pendingDeferredRetry = false; this.notifyDiscontinuity = true; this.lastSeekPositionUs = 0L; this.extractedSamplesCountAtStartOfLoad = 0; for (SampleQueue sampleQueue : this.sampleQueues) { sampleQueue.reset(); } ((MediaPeriod.Callback) Assertions.checkNotNull(this.callback)).onContinueLoadingRequested(this); } } /* JADX INFO: Access modifiers changed from: private */ public void onLengthKnown() { this.handler.post(new j(this, 0)); } private TrackOutput prepareTrackOutput(TrackId trackId) { int length = this.sampleQueues.length; for (int i6 = 0; i6 < length; i6++) { if (trackId.equals(this.sampleQueueTrackIds[i6])) { return this.sampleQueues[i6]; } } if (this.sampleQueuesBuilt) { Log.w(TAG, "Extractor added new track (id=" + trackId.id + ") after finishing tracks."); return new DiscardingTrackOutput(); } SampleQueue sampleQueueCreateWithDrm = SampleQueue.createWithDrm(this.allocator, this.drmSessionManager, this.drmEventDispatcher); sampleQueueCreateWithDrm.setUpstreamFormatChangeListener(this); int i7 = length + 1; TrackId[] trackIdArr = (TrackId[]) Arrays.copyOf(this.sampleQueueTrackIds, i7); trackIdArr[length] = trackId; this.sampleQueueTrackIds = (TrackId[]) Util.castNonNullTypeArray(trackIdArr); SampleQueue[] sampleQueueArr = (SampleQueue[]) Arrays.copyOf(this.sampleQueues, i7); sampleQueueArr[length] = sampleQueueCreateWithDrm; this.sampleQueues = (SampleQueue[]) Util.castNonNullTypeArray(sampleQueueArr); return sampleQueueCreateWithDrm; } private boolean seekInsideBufferUs(boolean[] zArr, long j4) { int length = this.sampleQueues.length; for (int i6 = 0; i6 < length; i6++) { SampleQueue sampleQueue = this.sampleQueues[i6]; if (!(this.isSingleSample ? sampleQueue.seekTo(sampleQueue.getFirstIndex()) : sampleQueue.seekTo(j4, false)) && (zArr[i6] || !this.haveAudioVideoTracks)) { return false; } } return true; } /* JADX INFO: Access modifiers changed from: private */ /* JADX INFO: renamed from: setSeekMap, reason: merged with bridge method [inline-methods] */ public void lambda$seekMap$1(SeekMap seekMap) { this.seekMap = this.icyHeaders == null ? seekMap : new SeekMap.Unseekable(C.TIME_UNSET); this.durationUs = seekMap.getDurationUs(); boolean z6 = !this.isLengthKnown && seekMap.getDurationUs() == C.TIME_UNSET; this.isLive = z6; this.dataType = z6 ? 7 : 1; if (this.prepared) { this.listener.onSourceInfoRefreshed(this.durationUs, seekMap.isSeekable(), this.isLive); } else { maybeFinishPrepare(); } } private void startLoading() { ExtractingLoadable extractingLoadable = new ExtractingLoadable(this.uri, this.dataSource, this.progressiveMediaExtractor, this, this.loadCondition); if (this.prepared) { Assertions.checkState(isPendingReset()); long j4 = this.durationUs; if (j4 != C.TIME_UNSET && this.pendingResetPositionUs > j4) { this.loadingFinished = true; this.pendingResetPositionUs = C.TIME_UNSET; return; } extractingLoadable.setLoadPosition(((SeekMap) Assertions.checkNotNull(this.seekMap)).getSeekPoints(this.pendingResetPositionUs).first.position, this.pendingResetPositionUs); for (SampleQueue sampleQueue : this.sampleQueues) { sampleQueue.setStartTimeUs(this.pendingResetPositionUs); } this.pendingResetPositionUs = C.TIME_UNSET; } this.extractedSamplesCountAtStartOfLoad = getExtractedSamplesCount(); this.mediaSourceEventDispatcher.loadStarted(new LoadEventInfo(extractingLoadable.loadTaskId, extractingLoadable.dataSpec, this.loader.startLoading(extractingLoadable, this, this.loadErrorHandlingPolicy.getMinimumLoadableRetryCount(this.dataType))), 1, -1, null, 0, null, extractingLoadable.seekTimeUs, this.durationUs); } private boolean suppressRead() { return this.notifyDiscontinuity || isPendingReset(); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public boolean continueLoading(LoadingInfo loadingInfo) { if (this.loadingFinished || this.loader.hasFatalError() || this.pendingDeferredRetry) { return false; } if (this.prepared && this.enabledTrackCount == 0) { return false; } boolean zOpen = this.loadCondition.open(); if (this.loader.isLoading()) { return zOpen; } startLoading(); return true; } @Override // androidx.media3.exoplayer.source.MediaPeriod public void discardBuffer(long j4, boolean z6) { if (this.isSingleSample) { return; } assertPrepared(); if (isPendingReset()) { return; } boolean[] zArr = this.trackState.trackEnabledStates; int length = this.sampleQueues.length; for (int i6 = 0; i6 < length; i6++) { this.sampleQueues[i6].discardTo(j4, z6, zArr[i6]); } } @Override // androidx.media3.extractor.ExtractorOutput public void endTracks() { this.sampleQueuesBuilt = true; this.handler.post(this.maybeFinishPrepareRunnable); } @Override // androidx.media3.exoplayer.source.MediaPeriod public long getAdjustedSeekPositionUs(long j4, SeekParameters seekParameters) { assertPrepared(); if (!this.seekMap.isSeekable()) { return 0L; } SeekMap.SeekPoints seekPoints = this.seekMap.getSeekPoints(j4); return seekParameters.resolveSeekPositionUs(j4, seekPoints.first.timeUs, seekPoints.second.timeUs); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public long getBufferedPositionUs() { long largestQueuedTimestampUs; assertPrepared(); if (this.loadingFinished || this.enabledTrackCount == 0) { return Long.MIN_VALUE; } if (isPendingReset()) { return this.pendingResetPositionUs; } if (this.haveAudioVideoTracks) { int length = this.sampleQueues.length; largestQueuedTimestampUs = Long.MAX_VALUE; for (int i6 = 0; i6 < length; i6++) { TrackState trackState = this.trackState; if (trackState.trackIsAudioVideoFlags[i6] && trackState.trackEnabledStates[i6] && !this.sampleQueues[i6].isLastSampleQueued()) { largestQueuedTimestampUs = Math.min(largestQueuedTimestampUs, this.sampleQueues[i6].getLargestQueuedTimestampUs()); } } } else { largestQueuedTimestampUs = Long.MAX_VALUE; } if (largestQueuedTimestampUs == Long.MAX_VALUE) { largestQueuedTimestampUs = getLargestQueuedTimestampUs(false); } return largestQueuedTimestampUs == Long.MIN_VALUE ? this.lastSeekPositionUs : largestQueuedTimestampUs; } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public long getNextLoadPositionUs() { return getBufferedPositionUs(); } @Override // androidx.media3.exoplayer.source.MediaPeriod public TrackGroupArray getTrackGroups() { assertPrepared(); return this.trackState.tracks; } public TrackOutput icyTrack() { return prepareTrackOutput(new TrackId(0, true)); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public boolean isLoading() { return this.loader.isLoading() && this.loadCondition.isOpen(); } public boolean isReady(int i6) { return !suppressRead() && this.sampleQueues[i6].isReady(this.loadingFinished); } public void maybeThrowError(int i6) { this.sampleQueues[i6].maybeThrowError(); maybeThrowError(); } @Override // androidx.media3.exoplayer.source.MediaPeriod public void maybeThrowPrepareError() throws ParserException { maybeThrowError(); if (this.loadingFinished && !this.prepared) { throw ParserException.createForMalformedContainer("Loading finished before preparation is complete.", null); } } @Override // androidx.media3.exoplayer.upstream.Loader.ReleaseCallback public void onLoaderReleased() { for (SampleQueue sampleQueue : this.sampleQueues) { sampleQueue.release(); } this.progressiveMediaExtractor.release(); } @Override // androidx.media3.exoplayer.source.SampleQueue.UpstreamFormatChangedListener public void onUpstreamFormatChanged(Format format) { this.handler.post(this.maybeFinishPrepareRunnable); } @Override // androidx.media3.exoplayer.source.MediaPeriod public void prepare(MediaPeriod.Callback callback, long j4) { this.callback = callback; this.loadCondition.open(); startLoading(); } public int readData(int i6, FormatHolder formatHolder, DecoderInputBuffer decoderInputBuffer, int i7) { if (suppressRead()) { return -3; } maybeNotifyDownstreamFormat(i6); int i8 = this.sampleQueues[i6].read(formatHolder, decoderInputBuffer, i7, this.loadingFinished); if (i8 == -3) { maybeStartDeferredRetry(i6); } return i8; } @Override // androidx.media3.exoplayer.source.MediaPeriod public long readDiscontinuity() { if (!this.notifyDiscontinuity) { return C.TIME_UNSET; } if (!this.loadingFinished && getExtractedSamplesCount() <= this.extractedSamplesCountAtStartOfLoad) { return C.TIME_UNSET; } this.notifyDiscontinuity = false; return this.lastSeekPositionUs; } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public void reevaluateBuffer(long j4) { } public void release() { if (this.prepared) { for (SampleQueue sampleQueue : this.sampleQueues) { sampleQueue.preRelease(); } } this.loader.release(this); this.handler.removeCallbacksAndMessages(null); this.callback = null; this.released = true; } @Override // androidx.media3.extractor.ExtractorOutput public void seekMap(final SeekMap seekMap) { this.handler.post(new Runnable() { // from class: androidx.media3.exoplayer.source.k @Override // java.lang.Runnable public final void run() { this.f12531a.lambda$seekMap$1(seekMap); } }); } @Override // androidx.media3.exoplayer.source.MediaPeriod public long seekToUs(long j4) { assertPrepared(); boolean[] zArr = this.trackState.trackIsAudioVideoFlags; if (!this.seekMap.isSeekable()) { j4 = 0; } int i6 = 0; this.notifyDiscontinuity = false; this.lastSeekPositionUs = j4; if (isPendingReset()) { this.pendingResetPositionUs = j4; return j4; } if (this.dataType == 7 || ((!this.loadingFinished && !this.loader.isLoading()) || !seekInsideBufferUs(zArr, j4))) { this.pendingDeferredRetry = false; this.pendingResetPositionUs = j4; this.loadingFinished = false; if (this.loader.isLoading()) { SampleQueue[] sampleQueueArr = this.sampleQueues; int length = sampleQueueArr.length; while (i6 < length) { sampleQueueArr[i6].discardToEnd(); i6++; } this.loader.cancelLoading(); return j4; } this.loader.clearFatalError(); SampleQueue[] sampleQueueArr2 = this.sampleQueues; int length2 = sampleQueueArr2.length; while (i6 < length2) { sampleQueueArr2[i6].reset(); i6++; } } return j4; } @Override // androidx.media3.exoplayer.source.MediaPeriod public long selectTracks(ExoTrackSelection[] exoTrackSelectionArr, boolean[] zArr, SampleStream[] sampleStreamArr, boolean[] zArr2, long j4) { ExoTrackSelection exoTrackSelection; assertPrepared(); TrackState trackState = this.trackState; TrackGroupArray trackGroupArray = trackState.tracks; boolean[] zArr3 = trackState.trackEnabledStates; int i6 = this.enabledTrackCount; int i7 = 0; for (int i8 = 0; i8 < exoTrackSelectionArr.length; i8++) { SampleStream sampleStream = sampleStreamArr[i8]; if (sampleStream != null && (exoTrackSelectionArr[i8] == null || !zArr[i8])) { int i9 = ((SampleStreamImpl) sampleStream).track; Assertions.checkState(zArr3[i9]); this.enabledTrackCount--; zArr3[i9] = false; sampleStreamArr[i8] = null; } } boolean z6 = !this.seenFirstTrackSelection ? j4 == 0 || this.isSingleSample : i6 != 0; for (int i10 = 0; i10 < exoTrackSelectionArr.length; i10++) { if (sampleStreamArr[i10] == null && (exoTrackSelection = exoTrackSelectionArr[i10]) != null) { Assertions.checkState(exoTrackSelection.length() == 1); Assertions.checkState(exoTrackSelection.getIndexInTrackGroup(0) == 0); int iIndexOf = trackGroupArray.indexOf(exoTrackSelection.getTrackGroup()); Assertions.checkState(!zArr3[iIndexOf]); this.enabledTrackCount++; zArr3[iIndexOf] = true; sampleStreamArr[i10] = new SampleStreamImpl(iIndexOf); zArr2[i10] = true; if (!z6) { SampleQueue sampleQueue = this.sampleQueues[iIndexOf]; z6 = (sampleQueue.getReadIndex() == 0 || sampleQueue.seekTo(j4, true)) ? false : true; } } } if (this.enabledTrackCount == 0) { this.pendingDeferredRetry = false; this.notifyDiscontinuity = false; if (this.loader.isLoading()) { SampleQueue[] sampleQueueArr = this.sampleQueues; int length = sampleQueueArr.length; while (i7 < length) { sampleQueueArr[i7].discardToEnd(); i7++; } this.loader.cancelLoading(); } else { this.loadingFinished = false; SampleQueue[] sampleQueueArr2 = this.sampleQueues; int length2 = sampleQueueArr2.length; while (i7 < length2) { sampleQueueArr2[i7].reset(); i7++; } } } else if (z6) { j4 = seekToUs(j4); while (i7 < sampleStreamArr.length) { if (sampleStreamArr[i7] != null) { zArr2[i7] = true; } i7++; } } this.seenFirstTrackSelection = true; return j4; } public int skipData(int i6, long j4) { if (suppressRead()) { return 0; } maybeNotifyDownstreamFormat(i6); SampleQueue sampleQueue = this.sampleQueues[i6]; int skipCount = sampleQueue.getSkipCount(j4, this.loadingFinished); sampleQueue.skip(skipCount); if (skipCount == 0) { maybeStartDeferredRetry(i6); } return skipCount; } @Override // androidx.media3.extractor.ExtractorOutput public TrackOutput track(int i6, int i7) { return prepareTrackOutput(new TrackId(i6, false)); } @Override // androidx.media3.exoplayer.upstream.Loader.Callback public void onLoadCanceled(ExtractingLoadable extractingLoadable, long j4, long j6, boolean z6) { StatsDataSource statsDataSource = extractingLoadable.dataSource; LoadEventInfo loadEventInfo = new LoadEventInfo(extractingLoadable.loadTaskId, extractingLoadable.dataSpec, statsDataSource.getLastOpenedUri(), statsDataSource.getLastResponseHeaders(), j4, j6, statsDataSource.getBytesRead()); this.loadErrorHandlingPolicy.onLoadTaskConcluded(extractingLoadable.loadTaskId); this.mediaSourceEventDispatcher.loadCanceled(loadEventInfo, 1, -1, null, 0, null, extractingLoadable.seekTimeUs, this.durationUs); if (z6) { return; } for (SampleQueue sampleQueue : this.sampleQueues) { sampleQueue.reset(); } if (this.enabledTrackCount > 0) { ((MediaPeriod.Callback) Assertions.checkNotNull(this.callback)).onContinueLoadingRequested(this); } } @Override // androidx.media3.exoplayer.upstream.Loader.Callback public void onLoadCompleted(ExtractingLoadable extractingLoadable, long j4, long j6) { SeekMap seekMap; if (this.durationUs == C.TIME_UNSET && (seekMap = this.seekMap) != null) { boolean zIsSeekable = seekMap.isSeekable(); long largestQueuedTimestampUs = getLargestQueuedTimestampUs(true); long j7 = largestQueuedTimestampUs == Long.MIN_VALUE ? 0L : largestQueuedTimestampUs + 10000; this.durationUs = j7; this.listener.onSourceInfoRefreshed(j7, zIsSeekable, this.isLive); } StatsDataSource statsDataSource = extractingLoadable.dataSource; LoadEventInfo loadEventInfo = new LoadEventInfo(extractingLoadable.loadTaskId, extractingLoadable.dataSpec, statsDataSource.getLastOpenedUri(), statsDataSource.getLastResponseHeaders(), j4, j6, statsDataSource.getBytesRead()); this.loadErrorHandlingPolicy.onLoadTaskConcluded(extractingLoadable.loadTaskId); this.mediaSourceEventDispatcher.loadCompleted(loadEventInfo, 1, -1, null, 0, null, extractingLoadable.seekTimeUs, this.durationUs); this.loadingFinished = true; ((MediaPeriod.Callback) Assertions.checkNotNull(this.callback)).onContinueLoadingRequested(this); } @Override // androidx.media3.exoplayer.upstream.Loader.Callback public Loader.LoadErrorAction onLoadError(ExtractingLoadable extractingLoadable, long j4, long j6, IOException iOException, int i6) { ExtractingLoadable extractingLoadable2; Loader.LoadErrorAction loadErrorActionCreateRetryAction; StatsDataSource statsDataSource = extractingLoadable.dataSource; LoadEventInfo loadEventInfo = new LoadEventInfo(extractingLoadable.loadTaskId, extractingLoadable.dataSpec, statsDataSource.getLastOpenedUri(), statsDataSource.getLastResponseHeaders(), j4, j6, statsDataSource.getBytesRead()); long retryDelayMsFor = this.loadErrorHandlingPolicy.getRetryDelayMsFor(new LoadErrorHandlingPolicy.LoadErrorInfo(loadEventInfo, new MediaLoadData(1, -1, null, 0, null, Util.usToMs(extractingLoadable.seekTimeUs), Util.usToMs(this.durationUs)), iOException, i6)); if (retryDelayMsFor == C.TIME_UNSET) { loadErrorActionCreateRetryAction = Loader.DONT_RETRY_FATAL; extractingLoadable2 = extractingLoadable; } else { int extractedSamplesCount = getExtractedSamplesCount(); extractingLoadable2 = extractingLoadable; loadErrorActionCreateRetryAction = configureRetry(extractingLoadable2, extractedSamplesCount) ? Loader.createRetryAction(extractedSamplesCount > this.extractedSamplesCountAtStartOfLoad, retryDelayMsFor) : Loader.DONT_RETRY; } boolean zIsRetry = loadErrorActionCreateRetryAction.isRetry(); this.mediaSourceEventDispatcher.loadError(loadEventInfo, 1, -1, null, 0, null, extractingLoadable2.seekTimeUs, this.durationUs, iOException, !zIsRetry); if (!zIsRetry) { this.loadErrorHandlingPolicy.onLoadTaskConcluded(extractingLoadable2.loadTaskId); } return loadErrorActionCreateRetryAction; } public void maybeThrowError() { this.loader.maybeThrowError(this.loadErrorHandlingPolicy.getMinimumLoadableRetryCount(this.dataType)); } }