package androidx.media3.exoplayer.source.ads; import F3.AbstractC0217q; import F3.AbstractC0220u; import F3.D0; import F3.O; import F3.T; import F3.e0; import F3.r; import F3.u0; import android.os.Handler; import android.util.Pair; import androidx.media3.common.AdPlaybackState; import androidx.media3.common.C; import androidx.media3.common.Format; import androidx.media3.common.MediaItem; import androidx.media3.common.StreamKey; import androidx.media3.common.Timeline; import androidx.media3.common.TrackGroup; import androidx.media3.common.util.Assertions; import androidx.media3.common.util.UnstableApi; import androidx.media3.common.util.Util; import androidx.media3.datasource.TransferListener; 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.source.BaseMediaSource; import androidx.media3.exoplayer.source.EmptySampleStream; import androidx.media3.exoplayer.source.ForwardingTimeline; import androidx.media3.exoplayer.source.LoadEventInfo; import androidx.media3.exoplayer.source.MediaLoadData; import androidx.media3.exoplayer.source.MediaPeriod; import androidx.media3.exoplayer.source.MediaSource; import androidx.media3.exoplayer.source.MediaSourceEventListener; import androidx.media3.exoplayer.source.SampleStream; import androidx.media3.exoplayer.source.TrackGroupArray; import androidx.media3.exoplayer.trackselection.ExoTrackSelection; import androidx.media3.exoplayer.upstream.Allocator; import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; /* JADX INFO: loaded from: classes.dex */ @UnstableApi public final class ServerSideAdInsertionMediaSource extends BaseMediaSource implements MediaSource.MediaSourceCaller, MediaSourceEventListener, DrmSessionEventListener { private final AdPlaybackStateUpdater adPlaybackStateUpdater; private SharedMediaPeriod lastUsedMediaPeriod; private final MediaSource mediaSource; private Handler playbackHandler; private final e0 mediaPeriods = new r(); private T adPlaybackStates = u0.f1605j; private final MediaSourceEventListener.EventDispatcher mediaSourceEventDispatcherWithoutId = createEventDispatcher(null); private final DrmSessionEventListener.EventDispatcher drmEventDispatcherWithoutId = createDrmEventDispatcher(null); public interface AdPlaybackStateUpdater { boolean onAdPlaybackStateUpdateRequested(Timeline timeline); } public static final class MediaPeriodImpl implements MediaPeriod { public MediaPeriod.Callback callback; public final DrmSessionEventListener.EventDispatcher drmEventDispatcher; public boolean[] hasNotifiedDownstreamFormatChange = new boolean[0]; public boolean isPrepared; public long lastStartPositionUs; public final MediaSource.MediaPeriodId mediaPeriodId; public final MediaSourceEventListener.EventDispatcher mediaSourceEventDispatcher; public final SharedMediaPeriod sharedPeriod; public MediaPeriodImpl(SharedMediaPeriod sharedMediaPeriod, MediaSource.MediaPeriodId mediaPeriodId, MediaSourceEventListener.EventDispatcher eventDispatcher, DrmSessionEventListener.EventDispatcher eventDispatcher2) { this.sharedPeriod = sharedMediaPeriod; this.mediaPeriodId = mediaPeriodId; this.mediaSourceEventDispatcher = eventDispatcher; this.drmEventDispatcher = eventDispatcher2; } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public boolean continueLoading(LoadingInfo loadingInfo) { return this.sharedPeriod.continueLoading(this, loadingInfo); } @Override // androidx.media3.exoplayer.source.MediaPeriod public void discardBuffer(long j4, boolean z6) { this.sharedPeriod.discardBuffer(this, j4, z6); } @Override // androidx.media3.exoplayer.source.MediaPeriod public long getAdjustedSeekPositionUs(long j4, SeekParameters seekParameters) { return this.sharedPeriod.getAdjustedSeekPositionUs(this, j4, seekParameters); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public long getBufferedPositionUs() { return this.sharedPeriod.getBufferedPositionUs(this); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public long getNextLoadPositionUs() { return this.sharedPeriod.getNextLoadPositionUs(this); } @Override // androidx.media3.exoplayer.source.MediaPeriod public List getStreamKeys(List list) { return this.sharedPeriod.getStreamKeys(list); } @Override // androidx.media3.exoplayer.source.MediaPeriod public TrackGroupArray getTrackGroups() { return this.sharedPeriod.getTrackGroups(); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public boolean isLoading() { return this.sharedPeriod.isLoading(this); } @Override // androidx.media3.exoplayer.source.MediaPeriod public void maybeThrowPrepareError() { this.sharedPeriod.maybeThrowPrepareError(); } public void onPrepared() { MediaPeriod.Callback callback = this.callback; if (callback != null) { callback.onPrepared(this); } this.isPrepared = true; } @Override // androidx.media3.exoplayer.source.MediaPeriod public void prepare(MediaPeriod.Callback callback, long j4) { this.callback = callback; this.sharedPeriod.prepare(this, j4); } @Override // androidx.media3.exoplayer.source.MediaPeriod public long readDiscontinuity() { return this.sharedPeriod.readDiscontinuity(this); } @Override // androidx.media3.exoplayer.source.MediaPeriod, androidx.media3.exoplayer.source.SequenceableLoader public void reevaluateBuffer(long j4) { this.sharedPeriod.reevaluateBuffer(this, j4); } @Override // androidx.media3.exoplayer.source.MediaPeriod public long seekToUs(long j4) { return this.sharedPeriod.seekToUs(this, j4); } @Override // androidx.media3.exoplayer.source.MediaPeriod public long selectTracks(ExoTrackSelection[] exoTrackSelectionArr, boolean[] zArr, SampleStream[] sampleStreamArr, boolean[] zArr2, long j4) { if (this.hasNotifiedDownstreamFormatChange.length == 0) { this.hasNotifiedDownstreamFormatChange = new boolean[sampleStreamArr.length]; } return this.sharedPeriod.selectTracks(this, exoTrackSelectionArr, zArr, sampleStreamArr, zArr2, j4); } } public static final class SampleStreamImpl implements SampleStream { private final MediaPeriodImpl mediaPeriod; private final int streamIndex; public SampleStreamImpl(MediaPeriodImpl mediaPeriodImpl, int i6) { this.mediaPeriod = mediaPeriodImpl; this.streamIndex = i6; } @Override // androidx.media3.exoplayer.source.SampleStream public boolean isReady() { return this.mediaPeriod.sharedPeriod.isReady(this.streamIndex); } @Override // androidx.media3.exoplayer.source.SampleStream public void maybeThrowError() { this.mediaPeriod.sharedPeriod.maybeThrowError(this.streamIndex); } @Override // androidx.media3.exoplayer.source.SampleStream public int readData(FormatHolder formatHolder, DecoderInputBuffer decoderInputBuffer, int i6) { MediaPeriodImpl mediaPeriodImpl = this.mediaPeriod; return mediaPeriodImpl.sharedPeriod.readData(mediaPeriodImpl, this.streamIndex, formatHolder, decoderInputBuffer, i6); } @Override // androidx.media3.exoplayer.source.SampleStream public int skipData(long j4) { MediaPeriodImpl mediaPeriodImpl = this.mediaPeriod; return mediaPeriodImpl.sharedPeriod.skipData(mediaPeriodImpl, this.streamIndex, j4); } } public static final class ServerSideAdInsertionTimeline extends ForwardingTimeline { private final T adPlaybackStates; public ServerSideAdInsertionTimeline(Timeline timeline, T t6) { super(timeline); Assertions.checkState(timeline.getWindowCount() == 1); Timeline.Period period = new Timeline.Period(); for (int i6 = 0; i6 < timeline.getPeriodCount(); i6++) { timeline.getPeriod(i6, period, true); Assertions.checkState(t6.containsKey(Assertions.checkNotNull(period.uid))); } this.adPlaybackStates = t6; } @Override // androidx.media3.exoplayer.source.ForwardingTimeline, androidx.media3.common.Timeline public Timeline.Period getPeriod(int i6, Timeline.Period period, boolean z6) { super.getPeriod(i6, period, true); AdPlaybackState adPlaybackState = (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(period.uid)); long j4 = period.durationUs; long mediaPeriodPositionUsForContent = j4 == C.TIME_UNSET ? adPlaybackState.contentDurationUs : ServerSideAdInsertionUtil.getMediaPeriodPositionUsForContent(j4, -1, adPlaybackState); Timeline.Period period2 = new Timeline.Period(); long mediaPeriodPositionUsForContent2 = 0; for (int i7 = 0; i7 < i6 + 1; i7++) { this.timeline.getPeriod(i7, period2, true); AdPlaybackState adPlaybackState2 = (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(period2.uid)); if (i7 == 0) { mediaPeriodPositionUsForContent2 = -ServerSideAdInsertionUtil.getMediaPeriodPositionUsForContent(-period2.getPositionInWindowUs(), -1, adPlaybackState2); } if (i7 != i6) { mediaPeriodPositionUsForContent2 = ServerSideAdInsertionUtil.getMediaPeriodPositionUsForContent(period2.durationUs, -1, adPlaybackState2) + mediaPeriodPositionUsForContent2; } } period.set(period.id, period.uid, period.windowIndex, mediaPeriodPositionUsForContent, mediaPeriodPositionUsForContent2, adPlaybackState, period.isPlaceholder); return period; } @Override // androidx.media3.exoplayer.source.ForwardingTimeline, androidx.media3.common.Timeline public Timeline.Window getWindow(int i6, Timeline.Window window, long j4) { super.getWindow(i6, window, j4); Timeline.Period period = new Timeline.Period(); AdPlaybackState adPlaybackState = (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(Assertions.checkNotNull(getPeriod(window.firstPeriodIndex, period, true).uid))); long mediaPeriodPositionUsForContent = ServerSideAdInsertionUtil.getMediaPeriodPositionUsForContent(window.positionInFirstPeriodUs, -1, adPlaybackState); if (window.durationUs == C.TIME_UNSET) { long j6 = adPlaybackState.contentDurationUs; if (j6 != C.TIME_UNSET) { window.durationUs = j6 - mediaPeriodPositionUsForContent; } } else { Timeline.Period period2 = super.getPeriod(window.lastPeriodIndex, period, true); long j7 = period2.positionInWindowUs; AdPlaybackState adPlaybackState2 = (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(period2.uid)); Timeline.Period period3 = getPeriod(window.lastPeriodIndex, period); window.durationUs = period3.positionInWindowUs + ServerSideAdInsertionUtil.getMediaPeriodPositionUsForContent(window.durationUs - j7, -1, adPlaybackState2); } window.positionInFirstPeriodUs = mediaPeriodPositionUsForContent; return window; } } public static final class SharedMediaPeriod implements MediaPeriod.Callback { private final MediaPeriod actualMediaPeriod; private AdPlaybackState adPlaybackState; private boolean hasStartedPreparing; private boolean isPrepared; private MediaPeriodImpl loadingPeriod; private final Object periodUid; private final List mediaPeriods = new ArrayList(); private final Map> activeLoads = new HashMap(); public ExoTrackSelection[] trackSelections = new ExoTrackSelection[0]; public SampleStream[] sampleStreams = new SampleStream[0]; public MediaLoadData[] lastDownstreamFormatChangeData = new MediaLoadData[0]; public SharedMediaPeriod(MediaPeriod mediaPeriod, Object obj, AdPlaybackState adPlaybackState) { this.actualMediaPeriod = mediaPeriod; this.periodUid = obj; this.adPlaybackState = adPlaybackState; } private int findMatchingStreamIndex(MediaLoadData mediaLoadData) { String str; if (mediaLoadData.trackFormat == null) { return -1; } int i6 = 0; loop0: while (true) { ExoTrackSelection[] exoTrackSelectionArr = this.trackSelections; if (i6 >= exoTrackSelectionArr.length) { return -1; } ExoTrackSelection exoTrackSelection = exoTrackSelectionArr[i6]; if (exoTrackSelection != null) { TrackGroup trackGroup = exoTrackSelection.getTrackGroup(); boolean z6 = mediaLoadData.trackType == 0 && trackGroup.equals(getTrackGroups().get(0)); for (int i7 = 0; i7 < trackGroup.length; i7++) { Format format = trackGroup.getFormat(i7); if (format.equals(mediaLoadData.trackFormat) || (z6 && (str = format.id) != null && str.equals(mediaLoadData.trackFormat.id))) { break loop0; } } } i6++; } return i6; } private long getMediaPeriodPositionUsWithEndOfSourceHandling(MediaPeriodImpl mediaPeriodImpl, long j4) { if (j4 == Long.MIN_VALUE) { return Long.MIN_VALUE; } long mediaPeriodPositionUs = ServerSideAdInsertionUtil.getMediaPeriodPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); if (mediaPeriodPositionUs >= ServerSideAdInsertionMediaSource.getMediaPeriodEndPositionUs(mediaPeriodImpl, this.adPlaybackState)) { return Long.MIN_VALUE; } return mediaPeriodPositionUs; } private long getStreamPositionUsWithNotYetStartedHandling(MediaPeriodImpl mediaPeriodImpl, long j4) { long j6 = mediaPeriodImpl.lastStartPositionUs; return j4 < j6 ? ServerSideAdInsertionUtil.getStreamPositionUs(j6, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState) - (mediaPeriodImpl.lastStartPositionUs - j4) : ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); } private void maybeNotifyDownstreamFormatChanged(MediaPeriodImpl mediaPeriodImpl, int i6) { MediaLoadData mediaLoadData; boolean[] zArr = mediaPeriodImpl.hasNotifiedDownstreamFormatChange; if (zArr[i6] || (mediaLoadData = this.lastDownstreamFormatChangeData[i6]) == null) { return; } zArr[i6] = true; mediaPeriodImpl.mediaSourceEventDispatcher.downstreamFormatChanged(ServerSideAdInsertionMediaSource.correctMediaLoadData(mediaPeriodImpl, mediaLoadData, this.adPlaybackState)); } public void add(MediaPeriodImpl mediaPeriodImpl) { this.mediaPeriods.add(mediaPeriodImpl); } public boolean canReuseMediaPeriod(MediaSource.MediaPeriodId mediaPeriodId, long j4) { MediaPeriodImpl mediaPeriodImpl = (MediaPeriodImpl) AbstractC0220u.k(this.mediaPeriods); return ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodId, this.adPlaybackState) == ServerSideAdInsertionUtil.getStreamPositionUs(ServerSideAdInsertionMediaSource.getMediaPeriodEndPositionUs(mediaPeriodImpl, this.adPlaybackState), mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); } public boolean continueLoading(MediaPeriodImpl mediaPeriodImpl, LoadingInfo loadingInfo) { MediaPeriodImpl mediaPeriodImpl2 = this.loadingPeriod; if (mediaPeriodImpl2 != null && !mediaPeriodImpl.equals(mediaPeriodImpl2)) { for (Pair pair : this.activeLoads.values()) { mediaPeriodImpl2.mediaSourceEventDispatcher.loadCompleted((LoadEventInfo) pair.first, ServerSideAdInsertionMediaSource.correctMediaLoadData(mediaPeriodImpl2, (MediaLoadData) pair.second, this.adPlaybackState)); mediaPeriodImpl.mediaSourceEventDispatcher.loadStarted((LoadEventInfo) pair.first, ServerSideAdInsertionMediaSource.correctMediaLoadData(mediaPeriodImpl, (MediaLoadData) pair.second, this.adPlaybackState)); } } this.loadingPeriod = mediaPeriodImpl; return this.actualMediaPeriod.continueLoading(loadingInfo.buildUpon().setPlaybackPositionUs(getStreamPositionUsWithNotYetStartedHandling(mediaPeriodImpl, loadingInfo.playbackPositionUs)).build()); } public void discardBuffer(MediaPeriodImpl mediaPeriodImpl, long j4, boolean z6) { this.actualMediaPeriod.discardBuffer(ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState), z6); } public long getAdjustedSeekPositionUs(MediaPeriodImpl mediaPeriodImpl, long j4, SeekParameters seekParameters) { return ServerSideAdInsertionUtil.getMediaPeriodPositionUs(this.actualMediaPeriod.getAdjustedSeekPositionUs(ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState), seekParameters), mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); } public long getBufferedPositionUs(MediaPeriodImpl mediaPeriodImpl) { return getMediaPeriodPositionUsWithEndOfSourceHandling(mediaPeriodImpl, this.actualMediaPeriod.getBufferedPositionUs()); } public MediaPeriodImpl getMediaPeriodForEvent(MediaLoadData mediaLoadData) { if (mediaLoadData == null || mediaLoadData.mediaStartTimeMs == C.TIME_UNSET) { return null; } for (int i6 = 0; i6 < this.mediaPeriods.size(); i6++) { MediaPeriodImpl mediaPeriodImpl = this.mediaPeriods.get(i6); if (mediaPeriodImpl.isPrepared) { long mediaPeriodPositionUs = ServerSideAdInsertionUtil.getMediaPeriodPositionUs(Util.msToUs(mediaLoadData.mediaStartTimeMs), mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); long mediaPeriodEndPositionUs = ServerSideAdInsertionMediaSource.getMediaPeriodEndPositionUs(mediaPeriodImpl, this.adPlaybackState); if (mediaPeriodPositionUs >= 0 && mediaPeriodPositionUs < mediaPeriodEndPositionUs) { return mediaPeriodImpl; } } } return null; } public long getNextLoadPositionUs(MediaPeriodImpl mediaPeriodImpl) { return getMediaPeriodPositionUsWithEndOfSourceHandling(mediaPeriodImpl, this.actualMediaPeriod.getNextLoadPositionUs()); } public List getStreamKeys(List list) { return this.actualMediaPeriod.getStreamKeys(list); } public TrackGroupArray getTrackGroups() { return this.actualMediaPeriod.getTrackGroups(); } public boolean isLoading(MediaPeriodImpl mediaPeriodImpl) { return mediaPeriodImpl.equals(this.loadingPeriod) && this.actualMediaPeriod.isLoading(); } public boolean isReady(int i6) { return ((SampleStream) Util.castNonNull(this.sampleStreams[i6])).isReady(); } public boolean isUnused() { return this.mediaPeriods.isEmpty(); } public void maybeThrowError(int i6) { ((SampleStream) Util.castNonNull(this.sampleStreams[i6])).maybeThrowError(); } public void maybeThrowPrepareError() { this.actualMediaPeriod.maybeThrowPrepareError(); } public void onDownstreamFormatChanged(MediaPeriodImpl mediaPeriodImpl, MediaLoadData mediaLoadData) { int iFindMatchingStreamIndex = findMatchingStreamIndex(mediaLoadData); if (iFindMatchingStreamIndex != -1) { this.lastDownstreamFormatChangeData[iFindMatchingStreamIndex] = mediaLoadData; mediaPeriodImpl.hasNotifiedDownstreamFormatChange[iFindMatchingStreamIndex] = true; } } public void onLoadFinished(LoadEventInfo loadEventInfo) { this.activeLoads.remove(Long.valueOf(loadEventInfo.loadTaskId)); } public void onLoadStarted(LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData) { this.activeLoads.put(Long.valueOf(loadEventInfo.loadTaskId), Pair.create(loadEventInfo, mediaLoadData)); } @Override // androidx.media3.exoplayer.source.MediaPeriod.Callback public void onPrepared(MediaPeriod mediaPeriod) { this.isPrepared = true; for (int i6 = 0; i6 < this.mediaPeriods.size(); i6++) { this.mediaPeriods.get(i6).onPrepared(); } } public void prepare(MediaPeriodImpl mediaPeriodImpl, long j4) { mediaPeriodImpl.lastStartPositionUs = j4; if (this.hasStartedPreparing) { if (this.isPrepared) { mediaPeriodImpl.onPrepared(); } } else { this.hasStartedPreparing = true; this.actualMediaPeriod.prepare(this, ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState)); } } public int readData(MediaPeriodImpl mediaPeriodImpl, int i6, FormatHolder formatHolder, DecoderInputBuffer decoderInputBuffer, int i7) { long bufferedPositionUs = getBufferedPositionUs(mediaPeriodImpl); int data = ((SampleStream) Util.castNonNull(this.sampleStreams[i6])).readData(formatHolder, decoderInputBuffer, i7 | 5); long mediaPeriodPositionUsWithEndOfSourceHandling = getMediaPeriodPositionUsWithEndOfSourceHandling(mediaPeriodImpl, decoderInputBuffer.timeUs); if ((data == -4 && mediaPeriodPositionUsWithEndOfSourceHandling == Long.MIN_VALUE) || (data == -3 && bufferedPositionUs == Long.MIN_VALUE && !decoderInputBuffer.waitingForKeys)) { maybeNotifyDownstreamFormatChanged(mediaPeriodImpl, i6); decoderInputBuffer.clear(); decoderInputBuffer.addFlag(4); return -4; } if (data == -4) { maybeNotifyDownstreamFormatChanged(mediaPeriodImpl, i6); ((SampleStream) Util.castNonNull(this.sampleStreams[i6])).readData(formatHolder, decoderInputBuffer, i7); decoderInputBuffer.timeUs = mediaPeriodPositionUsWithEndOfSourceHandling; } return data; } public long readDiscontinuity(MediaPeriodImpl mediaPeriodImpl) { if (!mediaPeriodImpl.equals(this.mediaPeriods.get(0))) { return C.TIME_UNSET; } long discontinuity = this.actualMediaPeriod.readDiscontinuity(); return discontinuity == C.TIME_UNSET ? C.TIME_UNSET : ServerSideAdInsertionUtil.getMediaPeriodPositionUs(discontinuity, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); } public void reevaluateBuffer(MediaPeriodImpl mediaPeriodImpl, long j4) { this.actualMediaPeriod.reevaluateBuffer(getStreamPositionUsWithNotYetStartedHandling(mediaPeriodImpl, j4)); } public void release(MediaSource mediaSource) { mediaSource.releasePeriod(this.actualMediaPeriod); } public void remove(MediaPeriodImpl mediaPeriodImpl) { if (mediaPeriodImpl.equals(this.loadingPeriod)) { this.loadingPeriod = null; this.activeLoads.clear(); } this.mediaPeriods.remove(mediaPeriodImpl); } public long seekToUs(MediaPeriodImpl mediaPeriodImpl, long j4) { return ServerSideAdInsertionUtil.getMediaPeriodPositionUs(this.actualMediaPeriod.seekToUs(ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState)), mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); } public long selectTracks(MediaPeriodImpl mediaPeriodImpl, ExoTrackSelection[] exoTrackSelectionArr, boolean[] zArr, SampleStream[] sampleStreamArr, boolean[] zArr2, long j4) { mediaPeriodImpl.lastStartPositionUs = j4; if (!mediaPeriodImpl.equals(this.mediaPeriods.get(0))) { for (int i6 = 0; i6 < exoTrackSelectionArr.length; i6++) { ExoTrackSelection exoTrackSelection = exoTrackSelectionArr[i6]; boolean z6 = true; if (exoTrackSelection != null) { if (zArr[i6] && sampleStreamArr[i6] != null) { z6 = false; } zArr2[i6] = z6; if (z6) { sampleStreamArr[i6] = Util.areEqual(this.trackSelections[i6], exoTrackSelection) ? new SampleStreamImpl(mediaPeriodImpl, i6) : new EmptySampleStream(); } } else { sampleStreamArr[i6] = null; zArr2[i6] = true; } } return j4; } this.trackSelections = (ExoTrackSelection[]) Arrays.copyOf(exoTrackSelectionArr, exoTrackSelectionArr.length); long streamPositionUs = ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); SampleStream[] sampleStreamArr2 = this.sampleStreams; SampleStream[] sampleStreamArr3 = sampleStreamArr2.length == 0 ? new SampleStream[exoTrackSelectionArr.length] : (SampleStream[]) Arrays.copyOf(sampleStreamArr2, sampleStreamArr2.length); long jSelectTracks = this.actualMediaPeriod.selectTracks(exoTrackSelectionArr, zArr, sampleStreamArr3, zArr2, streamPositionUs); this.sampleStreams = (SampleStream[]) Arrays.copyOf(sampleStreamArr3, sampleStreamArr3.length); this.lastDownstreamFormatChangeData = (MediaLoadData[]) Arrays.copyOf(this.lastDownstreamFormatChangeData, sampleStreamArr3.length); for (int i7 = 0; i7 < sampleStreamArr3.length; i7++) { if (sampleStreamArr3[i7] == null) { sampleStreamArr[i7] = null; this.lastDownstreamFormatChangeData[i7] = null; } else if (sampleStreamArr[i7] == null || zArr2[i7]) { sampleStreamArr[i7] = new SampleStreamImpl(mediaPeriodImpl, i7); this.lastDownstreamFormatChangeData[i7] = null; } } return ServerSideAdInsertionUtil.getMediaPeriodPositionUs(jSelectTracks, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState); } public int skipData(MediaPeriodImpl mediaPeriodImpl, int i6, long j4) { return ((SampleStream) Util.castNonNull(this.sampleStreams[i6])).skipData(ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodImpl.mediaPeriodId, this.adPlaybackState)); } public void updateAdPlaybackState(AdPlaybackState adPlaybackState) { this.adPlaybackState = adPlaybackState; } @Override // androidx.media3.exoplayer.source.SequenceableLoader.Callback public void onContinueLoadingRequested(MediaPeriod mediaPeriod) { MediaPeriodImpl mediaPeriodImpl = this.loadingPeriod; if (mediaPeriodImpl == null) { return; } ((MediaPeriod.Callback) Assertions.checkNotNull(mediaPeriodImpl.callback)).onContinueLoadingRequested(this.loadingPeriod); } } public ServerSideAdInsertionMediaSource(MediaSource mediaSource, AdPlaybackStateUpdater adPlaybackStateUpdater) { this.mediaSource = mediaSource; this.adPlaybackStateUpdater = adPlaybackStateUpdater; } /* JADX INFO: Access modifiers changed from: private */ public static MediaLoadData correctMediaLoadData(MediaPeriodImpl mediaPeriodImpl, MediaLoadData mediaLoadData, AdPlaybackState adPlaybackState) { return new MediaLoadData(mediaLoadData.dataType, mediaLoadData.trackType, mediaLoadData.trackFormat, mediaLoadData.trackSelectionReason, mediaLoadData.trackSelectionData, correctMediaLoadDataPositionMs(mediaLoadData.mediaStartTimeMs, mediaPeriodImpl, adPlaybackState), correctMediaLoadDataPositionMs(mediaLoadData.mediaEndTimeMs, mediaPeriodImpl, adPlaybackState)); } private static long correctMediaLoadDataPositionMs(long j4, MediaPeriodImpl mediaPeriodImpl, AdPlaybackState adPlaybackState) { if (j4 == C.TIME_UNSET) { return C.TIME_UNSET; } long jMsToUs = Util.msToUs(j4); MediaSource.MediaPeriodId mediaPeriodId = mediaPeriodImpl.mediaPeriodId; return Util.usToMs(mediaPeriodId.isAd() ? ServerSideAdInsertionUtil.getMediaPeriodPositionUsForAd(jMsToUs, mediaPeriodId.adGroupIndex, mediaPeriodId.adIndexInAdGroup, adPlaybackState) : ServerSideAdInsertionUtil.getMediaPeriodPositionUsForContent(jMsToUs, -1, adPlaybackState)); } /* JADX INFO: Access modifiers changed from: private */ public static long getMediaPeriodEndPositionUs(MediaPeriodImpl mediaPeriodImpl, AdPlaybackState adPlaybackState) { MediaSource.MediaPeriodId mediaPeriodId = mediaPeriodImpl.mediaPeriodId; if (mediaPeriodId.isAd()) { AdPlaybackState.AdGroup adGroup = adPlaybackState.getAdGroup(mediaPeriodId.adGroupIndex); if (adGroup.count == -1) { return 0L; } return adGroup.durationsUs[mediaPeriodId.adIndexInAdGroup]; } int i6 = mediaPeriodId.nextAdGroupIndex; if (i6 == -1) { return Long.MAX_VALUE; } long j4 = adPlaybackState.getAdGroup(i6).timeUs; if (j4 == Long.MIN_VALUE) { return Long.MAX_VALUE; } return j4; } private MediaPeriodImpl getMediaPeriodForEvent(MediaSource.MediaPeriodId mediaPeriodId, MediaLoadData mediaLoadData, boolean z6) { if (mediaPeriodId == null) { return null; } List list = this.mediaPeriods.get((Object) new Pair(Long.valueOf(mediaPeriodId.windowSequenceNumber), mediaPeriodId.periodUid)); if (list.isEmpty()) { return null; } if (z6) { SharedMediaPeriod sharedMediaPeriod = (SharedMediaPeriod) AbstractC0220u.k(list); return sharedMediaPeriod.loadingPeriod != null ? sharedMediaPeriod.loadingPeriod : (MediaPeriodImpl) AbstractC0220u.k(sharedMediaPeriod.mediaPeriods); } for (int i6 = 0; i6 < list.size(); i6++) { MediaPeriodImpl mediaPeriodForEvent = ((SharedMediaPeriod) list.get(i6)).getMediaPeriodForEvent(mediaLoadData); if (mediaPeriodForEvent != null) { return mediaPeriodForEvent; } } return (MediaPeriodImpl) ((SharedMediaPeriod) list.get(0)).mediaPeriods.get(0); } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$setAdPlaybackStates$0(T t6, Timeline timeline) { AdPlaybackState adPlaybackState; for (SharedMediaPeriod sharedMediaPeriod : this.mediaPeriods.values()) { AdPlaybackState adPlaybackState2 = (AdPlaybackState) t6.get(sharedMediaPeriod.periodUid); if (adPlaybackState2 != null) { sharedMediaPeriod.updateAdPlaybackState(adPlaybackState2); } } SharedMediaPeriod sharedMediaPeriod2 = this.lastUsedMediaPeriod; if (sharedMediaPeriod2 != null && (adPlaybackState = (AdPlaybackState) t6.get(sharedMediaPeriod2.periodUid)) != null) { this.lastUsedMediaPeriod.updateAdPlaybackState(adPlaybackState); } this.adPlaybackStates = t6; refreshSourceInfo(new ServerSideAdInsertionTimeline(timeline, t6)); } private void releaseLastUsedMediaPeriod() { SharedMediaPeriod sharedMediaPeriod = this.lastUsedMediaPeriod; if (sharedMediaPeriod != null) { sharedMediaPeriod.release(this.mediaSource); this.lastUsedMediaPeriod = null; } } @Override // androidx.media3.exoplayer.source.MediaSource public boolean canUpdateMediaItem(MediaItem mediaItem) { return this.mediaSource.canUpdateMediaItem(mediaItem); } @Override // androidx.media3.exoplayer.source.MediaSource public MediaPeriod createPeriod(MediaSource.MediaPeriodId mediaPeriodId, Allocator allocator, long j4) { SharedMediaPeriod sharedMediaPeriod; Pair pair = new Pair(Long.valueOf(mediaPeriodId.windowSequenceNumber), mediaPeriodId.periodUid); SharedMediaPeriod sharedMediaPeriod2 = this.lastUsedMediaPeriod; SharedMediaPeriod sharedMediaPeriod3 = null; boolean z6 = false; if (sharedMediaPeriod2 != null) { if (sharedMediaPeriod2.periodUid.equals(mediaPeriodId.periodUid)) { sharedMediaPeriod = this.lastUsedMediaPeriod; this.mediaPeriods.put(pair, sharedMediaPeriod); z6 = true; } else { this.lastUsedMediaPeriod.release(this.mediaSource); sharedMediaPeriod = null; } this.lastUsedMediaPeriod = null; sharedMediaPeriod3 = sharedMediaPeriod; } if (sharedMediaPeriod3 == null && ((sharedMediaPeriod3 = (SharedMediaPeriod) AbstractC0220u.l(this.mediaPeriods.get((Object) pair))) == null || !sharedMediaPeriod3.canReuseMediaPeriod(mediaPeriodId, j4))) { AdPlaybackState adPlaybackState = (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodId.periodUid)); sharedMediaPeriod3 = new SharedMediaPeriod(this.mediaSource.createPeriod(new MediaSource.MediaPeriodId(mediaPeriodId.periodUid, mediaPeriodId.windowSequenceNumber), allocator, ServerSideAdInsertionUtil.getStreamPositionUs(j4, mediaPeriodId, adPlaybackState)), mediaPeriodId.periodUid, adPlaybackState); this.mediaPeriods.put(pair, sharedMediaPeriod3); } MediaPeriodImpl mediaPeriodImpl = new MediaPeriodImpl(sharedMediaPeriod3, mediaPeriodId, createEventDispatcher(mediaPeriodId), createDrmEventDispatcher(mediaPeriodId)); sharedMediaPeriod3.add(mediaPeriodImpl); if (z6 && sharedMediaPeriod3.trackSelections.length > 0) { mediaPeriodImpl.seekToUs(j4); } return mediaPeriodImpl; } @Override // androidx.media3.exoplayer.source.BaseMediaSource public void disableInternal() { releaseLastUsedMediaPeriod(); this.mediaSource.disable(this); } @Override // androidx.media3.exoplayer.source.BaseMediaSource public void enableInternal() { this.mediaSource.enable(this); } @Override // androidx.media3.exoplayer.source.MediaSource public MediaItem getMediaItem() { return this.mediaSource.getMediaItem(); } @Override // androidx.media3.exoplayer.source.MediaSource public void maybeThrowSourceInfoRefreshError() { this.mediaSource.maybeThrowSourceInfoRefreshError(); } @Override // androidx.media3.exoplayer.source.MediaSourceEventListener public void onDownstreamFormatChanged(int i6, MediaSource.MediaPeriodId mediaPeriodId, MediaLoadData mediaLoadData) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, mediaLoadData, false); if (mediaPeriodForEvent == null) { this.mediaSourceEventDispatcherWithoutId.downstreamFormatChanged(mediaLoadData); } else { mediaPeriodForEvent.sharedPeriod.onDownstreamFormatChanged(mediaPeriodForEvent, mediaLoadData); mediaPeriodForEvent.mediaSourceEventDispatcher.downstreamFormatChanged(correctMediaLoadData(mediaPeriodForEvent, mediaLoadData, (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodForEvent.mediaPeriodId.periodUid)))); } } @Override // androidx.media3.exoplayer.drm.DrmSessionEventListener public void onDrmKeysLoaded(int i6, MediaSource.MediaPeriodId mediaPeriodId) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, null, false); if (mediaPeriodForEvent == null) { this.drmEventDispatcherWithoutId.drmKeysLoaded(); } else { mediaPeriodForEvent.drmEventDispatcher.drmKeysLoaded(); } } @Override // androidx.media3.exoplayer.drm.DrmSessionEventListener public void onDrmKeysRemoved(int i6, MediaSource.MediaPeriodId mediaPeriodId) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, null, false); if (mediaPeriodForEvent == null) { this.drmEventDispatcherWithoutId.drmKeysRemoved(); } else { mediaPeriodForEvent.drmEventDispatcher.drmKeysRemoved(); } } @Override // androidx.media3.exoplayer.drm.DrmSessionEventListener public void onDrmKeysRestored(int i6, MediaSource.MediaPeriodId mediaPeriodId) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, null, false); if (mediaPeriodForEvent == null) { this.drmEventDispatcherWithoutId.drmKeysRestored(); } else { mediaPeriodForEvent.drmEventDispatcher.drmKeysRestored(); } } @Override // androidx.media3.exoplayer.drm.DrmSessionEventListener public void onDrmSessionAcquired(int i6, MediaSource.MediaPeriodId mediaPeriodId, int i7) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, null, true); if (mediaPeriodForEvent == null) { this.drmEventDispatcherWithoutId.drmSessionAcquired(i7); } else { mediaPeriodForEvent.drmEventDispatcher.drmSessionAcquired(i7); } } @Override // androidx.media3.exoplayer.drm.DrmSessionEventListener public void onDrmSessionManagerError(int i6, MediaSource.MediaPeriodId mediaPeriodId, Exception exc) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, null, false); if (mediaPeriodForEvent == null) { this.drmEventDispatcherWithoutId.drmSessionManagerError(exc); } else { mediaPeriodForEvent.drmEventDispatcher.drmSessionManagerError(exc); } } @Override // androidx.media3.exoplayer.drm.DrmSessionEventListener public void onDrmSessionReleased(int i6, MediaSource.MediaPeriodId mediaPeriodId) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, null, false); if (mediaPeriodForEvent == null) { this.drmEventDispatcherWithoutId.drmSessionReleased(); } else { mediaPeriodForEvent.drmEventDispatcher.drmSessionReleased(); } } @Override // androidx.media3.exoplayer.source.MediaSourceEventListener public void onLoadCanceled(int i6, MediaSource.MediaPeriodId mediaPeriodId, LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, mediaLoadData, true); if (mediaPeriodForEvent == null) { this.mediaSourceEventDispatcherWithoutId.loadCanceled(loadEventInfo, mediaLoadData); } else { mediaPeriodForEvent.sharedPeriod.onLoadFinished(loadEventInfo); mediaPeriodForEvent.mediaSourceEventDispatcher.loadCanceled(loadEventInfo, correctMediaLoadData(mediaPeriodForEvent, mediaLoadData, (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodForEvent.mediaPeriodId.periodUid)))); } } @Override // androidx.media3.exoplayer.source.MediaSourceEventListener public void onLoadCompleted(int i6, MediaSource.MediaPeriodId mediaPeriodId, LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, mediaLoadData, true); if (mediaPeriodForEvent == null) { this.mediaSourceEventDispatcherWithoutId.loadCompleted(loadEventInfo, mediaLoadData); } else { mediaPeriodForEvent.sharedPeriod.onLoadFinished(loadEventInfo); mediaPeriodForEvent.mediaSourceEventDispatcher.loadCompleted(loadEventInfo, correctMediaLoadData(mediaPeriodForEvent, mediaLoadData, (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodForEvent.mediaPeriodId.periodUid)))); } } @Override // androidx.media3.exoplayer.source.MediaSourceEventListener public void onLoadError(int i6, MediaSource.MediaPeriodId mediaPeriodId, LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData, IOException iOException, boolean z6) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, mediaLoadData, true); if (mediaPeriodForEvent == null) { this.mediaSourceEventDispatcherWithoutId.loadError(loadEventInfo, mediaLoadData, iOException, z6); return; } if (z6) { mediaPeriodForEvent.sharedPeriod.onLoadFinished(loadEventInfo); } mediaPeriodForEvent.mediaSourceEventDispatcher.loadError(loadEventInfo, correctMediaLoadData(mediaPeriodForEvent, mediaLoadData, (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodForEvent.mediaPeriodId.periodUid))), iOException, z6); } @Override // androidx.media3.exoplayer.source.MediaSourceEventListener public void onLoadStarted(int i6, MediaSource.MediaPeriodId mediaPeriodId, LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, mediaLoadData, true); if (mediaPeriodForEvent == null) { this.mediaSourceEventDispatcherWithoutId.loadStarted(loadEventInfo, mediaLoadData); } else { mediaPeriodForEvent.sharedPeriod.onLoadStarted(loadEventInfo, mediaLoadData); mediaPeriodForEvent.mediaSourceEventDispatcher.loadStarted(loadEventInfo, correctMediaLoadData(mediaPeriodForEvent, mediaLoadData, (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodForEvent.mediaPeriodId.periodUid)))); } } @Override // androidx.media3.exoplayer.source.MediaSource.MediaSourceCaller public void onSourceInfoRefreshed(MediaSource mediaSource, Timeline timeline) { AdPlaybackStateUpdater adPlaybackStateUpdater = this.adPlaybackStateUpdater; if ((adPlaybackStateUpdater == null || !adPlaybackStateUpdater.onAdPlaybackStateUpdateRequested(timeline)) && !this.adPlaybackStates.isEmpty()) { refreshSourceInfo(new ServerSideAdInsertionTimeline(timeline, this.adPlaybackStates)); } } @Override // androidx.media3.exoplayer.source.MediaSourceEventListener public void onUpstreamDiscarded(int i6, MediaSource.MediaPeriodId mediaPeriodId, MediaLoadData mediaLoadData) { MediaPeriodImpl mediaPeriodForEvent = getMediaPeriodForEvent(mediaPeriodId, mediaLoadData, false); if (mediaPeriodForEvent == null) { this.mediaSourceEventDispatcherWithoutId.upstreamDiscarded(mediaLoadData); } else { mediaPeriodForEvent.mediaSourceEventDispatcher.upstreamDiscarded(correctMediaLoadData(mediaPeriodForEvent, mediaLoadData, (AdPlaybackState) Assertions.checkNotNull((AdPlaybackState) this.adPlaybackStates.get(mediaPeriodForEvent.mediaPeriodId.periodUid)))); } } @Override // androidx.media3.exoplayer.source.BaseMediaSource public void prepareSourceInternal(TransferListener transferListener) { Handler handlerCreateHandlerForCurrentLooper = Util.createHandlerForCurrentLooper(); synchronized (this) { this.playbackHandler = handlerCreateHandlerForCurrentLooper; } this.mediaSource.addEventListener(handlerCreateHandlerForCurrentLooper, this); this.mediaSource.addDrmEventListener(handlerCreateHandlerForCurrentLooper, this); this.mediaSource.prepareSource(this, transferListener, getPlayerId()); } @Override // androidx.media3.exoplayer.source.MediaSource public void releasePeriod(MediaPeriod mediaPeriod) { MediaPeriodImpl mediaPeriodImpl = (MediaPeriodImpl) mediaPeriod; mediaPeriodImpl.sharedPeriod.remove(mediaPeriodImpl); if (mediaPeriodImpl.sharedPeriod.isUnused()) { this.mediaPeriods.remove(new Pair(Long.valueOf(mediaPeriodImpl.mediaPeriodId.windowSequenceNumber), mediaPeriodImpl.mediaPeriodId.periodUid), mediaPeriodImpl.sharedPeriod); if (((AbstractC0217q) this.mediaPeriods).size() == 0) { this.lastUsedMediaPeriod = mediaPeriodImpl.sharedPeriod; } else { mediaPeriodImpl.sharedPeriod.release(this.mediaSource); } } } @Override // androidx.media3.exoplayer.source.BaseMediaSource public void releaseSourceInternal() { releaseLastUsedMediaPeriod(); synchronized (this) { this.playbackHandler = null; } this.mediaSource.releaseSource(this); this.mediaSource.removeEventListener(this); this.mediaSource.removeDrmEventListener(this); } public void setAdPlaybackStates(T t6, Timeline timeline) { Assertions.checkArgument(!t6.isEmpty()); Object objCheckNotNull = Assertions.checkNotNull(((AdPlaybackState) ((O) t6.values()).get(0)).adsId); D0 it = t6.entrySet().iterator(); while (it.hasNext()) { Map.Entry entry = (Map.Entry) it.next(); Object key = entry.getKey(); AdPlaybackState adPlaybackState = (AdPlaybackState) entry.getValue(); Assertions.checkArgument(Util.areEqual(objCheckNotNull, adPlaybackState.adsId)); AdPlaybackState adPlaybackState2 = (AdPlaybackState) this.adPlaybackStates.get(key); if (adPlaybackState2 != null) { for (int i6 = adPlaybackState.removedAdGroupCount; i6 < adPlaybackState.adGroupCount; i6++) { AdPlaybackState.AdGroup adGroup = adPlaybackState.getAdGroup(i6); Assertions.checkArgument(adGroup.isServerSideInserted); if (i6 < adPlaybackState2.adGroupCount && ServerSideAdInsertionUtil.getAdCountInGroup(adPlaybackState, i6) < ServerSideAdInsertionUtil.getAdCountInGroup(adPlaybackState2, i6)) { AdPlaybackState.AdGroup adGroup2 = adPlaybackState.getAdGroup(i6 + 1); Assertions.checkArgument(adGroup.contentResumeOffsetUs + adGroup2.contentResumeOffsetUs == adPlaybackState2.getAdGroup(i6).contentResumeOffsetUs); Assertions.checkArgument(adGroup.timeUs + adGroup.contentResumeOffsetUs == adGroup2.timeUs); } if (adGroup.timeUs == Long.MIN_VALUE) { Assertions.checkArgument(ServerSideAdInsertionUtil.getAdCountInGroup(adPlaybackState, i6) == 0); } } } } synchronized (this) { try { Handler handler = this.playbackHandler; if (handler == null) { this.adPlaybackStates = t6; } else { handler.post(new b(this, t6, timeline, 1)); } } catch (Throwable th) { throw th; } } } @Override // androidx.media3.exoplayer.source.MediaSource public void updateMediaItem(MediaItem mediaItem) { this.mediaSource.updateMediaItem(mediaItem); } }