mirror of
https://github.com/Pinball3D/Rabbit-R1.git
synced 2024-12-25 16:42:30 -06:00
631 lines
30 KiB
Java
631 lines
30 KiB
Java
|
package androidx.media3.exoplayer.drm;
|
||
|
|
|
||
|
|
import android.media.ResourceBusyException;
|
||
|
|
import android.os.Handler;
|
||
|
|
import android.os.Looper;
|
||
|
|
import android.os.Message;
|
||
|
|
import android.os.SystemClock;
|
||
|
|
import androidx.media3.common.C;
|
||
|
|
import androidx.media3.common.DrmInitData;
|
||
|
|
import androidx.media3.common.Format;
|
||
|
|
import androidx.media3.common.MimeTypes;
|
||
|
|
import androidx.media3.common.util.Assertions;
|
||
|
|
import androidx.media3.common.util.Log;
|
||
|
|
import androidx.media3.common.util.Util;
|
||
|
|
import androidx.media3.exoplayer.analytics.PlayerId;
|
||
|
|
import androidx.media3.exoplayer.drm.DefaultDrmSession;
|
||
|
|
import androidx.media3.exoplayer.drm.DefaultDrmSessionManager;
|
||
|
|
import androidx.media3.exoplayer.drm.DrmSession;
|
||
|
|
import androidx.media3.exoplayer.drm.DrmSessionEventListener;
|
||
|
|
import androidx.media3.exoplayer.drm.DrmSessionManager;
|
||
|
|
import androidx.media3.exoplayer.drm.ExoMediaDrm;
|
||
|
|
import androidx.media3.exoplayer.upstream.DefaultLoadErrorHandlingPolicy;
|
||
|
|
import androidx.media3.exoplayer.upstream.LoadErrorHandlingPolicy;
|
||
|
|
import com.google.common.collect.ImmutableList;
|
||
|
|
import com.google.common.collect.ImmutableSet;
|
||
|
|
import com.google.common.collect.Sets;
|
||
|
|
import com.google.common.collect.UnmodifiableIterator;
|
||
|
|
import java.lang.annotation.Documented;
|
||
|
|
import java.lang.annotation.ElementType;
|
||
|
|
import java.lang.annotation.Retention;
|
||
|
|
import java.lang.annotation.RetentionPolicy;
|
||
|
|
import java.lang.annotation.Target;
|
||
|
|
import java.util.ArrayList;
|
||
|
|
import java.util.Collection;
|
||
|
|
import java.util.HashMap;
|
||
|
|
import java.util.HashSet;
|
||
|
|
import java.util.Iterator;
|
||
|
|
import java.util.List;
|
||
|
|
import java.util.Map;
|
||
|
|
import java.util.Set;
|
||
|
|
import java.util.UUID;
|
||
|
|
import org.checkerframework.checker.nullness.qual.EnsuresNonNull;
|
||
|
|
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public class DefaultDrmSessionManager implements DrmSessionManager {
|
||
|
|
public static final long DEFAULT_SESSION_KEEPALIVE_MS = 300000;
|
||
|
|
public static final int INITIAL_DRM_REQUEST_RETRY_COUNT = 3;
|
||
|
|
public static final int MODE_DOWNLOAD = 2;
|
||
|
|
public static final int MODE_PLAYBACK = 0;
|
||
|
|
public static final int MODE_QUERY = 1;
|
||
|
|
public static final int MODE_RELEASE = 3;
|
||
|
|
public static final String PLAYREADY_CUSTOM_DATA_KEY = "PRCustomData";
|
||
|
|
private static final String TAG = "DefaultDrmSessionMgr";
|
||
|
|
private final MediaDrmCallback callback;
|
||
|
|
private ExoMediaDrm exoMediaDrm;
|
||
|
|
private final ExoMediaDrm.Provider exoMediaDrmProvider;
|
||
|
|
private final Set<DefaultDrmSession> keepaliveSessions;
|
||
|
|
private final HashMap<String, String> keyRequestParameters;
|
||
|
|
private final LoadErrorHandlingPolicy loadErrorHandlingPolicy;
|
||
|
|
volatile MediaDrmHandler mediaDrmHandler;
|
||
|
|
private int mode;
|
||
|
|
private final boolean multiSession;
|
||
|
|
private DefaultDrmSession noMultiSessionDrmSession;
|
||
|
|
private byte[] offlineLicenseKeySetId;
|
||
|
|
private DefaultDrmSession placeholderDrmSession;
|
||
|
|
private final boolean playClearSamplesWithoutKeys;
|
||
|
|
private Handler playbackHandler;
|
||
|
|
private Looper playbackLooper;
|
||
|
|
private PlayerId playerId;
|
||
|
|
private final Set<PreacquiredSessionReference> preacquiredSessionReferences;
|
||
|
|
private int prepareCallsCount;
|
||
|
|
private final ProvisioningManagerImpl provisioningManagerImpl;
|
||
|
|
private final ReferenceCountListenerImpl referenceCountListener;
|
||
|
|
private final long sessionKeepaliveMs;
|
||
|
|
private final List<DefaultDrmSession> sessions;
|
||
|
|
private final int[] useDrmSessionsForClearContentTrackTypes;
|
||
|
|
private final UUID uuid;
|
||
|
|
|
||
|
|
@Target({ElementType.TYPE_USE})
|
||
|
|
@Documented
|
||
|
|
@Retention(RetentionPolicy.SOURCE)
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public @interface Mode {
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private boolean multiSession;
|
||
|
|
private boolean playClearSamplesWithoutKeys;
|
||
|
|
private final HashMap<String, String> keyRequestParameters = new HashMap<>();
|
||
|
|
private UUID uuid = C.WIDEVINE_UUID;
|
||
|
|
private ExoMediaDrm.Provider exoMediaDrmProvider = FrameworkMediaDrm.DEFAULT_PROVIDER;
|
||
|
|
private LoadErrorHandlingPolicy loadErrorHandlingPolicy = new DefaultLoadErrorHandlingPolicy();
|
||
|
|
private int[] useDrmSessionsForClearContentTrackTypes = new int[0];
|
||
|
|
private long sessionKeepaliveMs = 300000;
|
||
|
|
|
||
|
|
public Builder setMultiSession(boolean z) {
|
||
|
|
this.multiSession = z;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Builder setPlayClearSamplesWithoutKeys(boolean z) {
|
||
|
|
this.playClearSamplesWithoutKeys = z;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Builder setKeyRequestParameters(Map<String, String> map) {
|
||
|
|
this.keyRequestParameters.clear();
|
||
|
|
if (map != null) {
|
||
|
|
this.keyRequestParameters.putAll(map);
|
||
|
|
}
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Builder setUuidAndExoMediaDrmProvider(UUID uuid, ExoMediaDrm.Provider provider) {
|
||
|
|
this.uuid = (UUID) Assertions.checkNotNull(uuid);
|
||
|
|
this.exoMediaDrmProvider = (ExoMediaDrm.Provider) Assertions.checkNotNull(provider);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Builder setUseDrmSessionsForClearContent(int... iArr) {
|
||
|
|
for (int i : iArr) {
|
||
|
|
boolean z = true;
|
||
|
|
if (i != 2 && i != 1) {
|
||
|
|
z = false;
|
||
|
|
}
|
||
|
|
Assertions.checkArgument(z);
|
||
|
|
}
|
||
|
|
this.useDrmSessionsForClearContentTrackTypes = (int[]) iArr.clone();
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Builder setLoadErrorHandlingPolicy(LoadErrorHandlingPolicy loadErrorHandlingPolicy) {
|
||
|
|
this.loadErrorHandlingPolicy = (LoadErrorHandlingPolicy) Assertions.checkNotNull(loadErrorHandlingPolicy);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Builder setSessionKeepaliveMs(long j) {
|
||
|
|
Assertions.checkArgument(j > 0 || j == -9223372036854775807L);
|
||
|
|
this.sessionKeepaliveMs = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public DefaultDrmSessionManager build(MediaDrmCallback mediaDrmCallback) {
|
||
|
|
return new DefaultDrmSessionManager(this.uuid, this.exoMediaDrmProvider, mediaDrmCallback, this.keyRequestParameters, this.multiSession, this.useDrmSessionsForClearContentTrackTypes, this.playClearSamplesWithoutKeys, this.loadErrorHandlingPolicy, this.sessionKeepaliveMs);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public static final class MissingSchemeDataException extends Exception {
|
||
|
|
private MissingSchemeDataException(UUID uuid) {
|
||
|
|
super("Media does not support uuid: " + uuid);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private DefaultDrmSessionManager(UUID uuid, ExoMediaDrm.Provider provider, MediaDrmCallback mediaDrmCallback, HashMap<String, String> hashMap, boolean z, int[] iArr, boolean z2, LoadErrorHandlingPolicy loadErrorHandlingPolicy, long j) {
|
||
|
|
Assertions.checkNotNull(uuid);
|
||
|
|
Assertions.checkArgument(!C.COMMON_PSSH_UUID.equals(uuid), "Use C.CLEARKEY_UUID instead");
|
||
|
|
this.uuid = uuid;
|
||
|
|
this.exoMediaDrmProvider = provider;
|
||
|
|
this.callback = mediaDrmCallback;
|
||
|
|
this.keyRequestParameters = hashMap;
|
||
|
|
this.multiSession = z;
|
||
|
|
this.useDrmSessionsForClearContentTrackTypes = iArr;
|
||
|
|
this.playClearSamplesWithoutKeys = z2;
|
||
|
|
this.loadErrorHandlingPolicy = loadErrorHandlingPolicy;
|
||
|
|
this.provisioningManagerImpl = new ProvisioningManagerImpl();
|
||
|
|
this.referenceCountListener = new ReferenceCountListenerImpl();
|
||
|
|
this.mode = 0;
|
||
|
|
this.sessions = new ArrayList();
|
||
|
|
this.preacquiredSessionReferences = Sets.newIdentityHashSet();
|
||
|
|
this.keepaliveSessions = Sets.newIdentityHashSet();
|
||
|
|
this.sessionKeepaliveMs = j;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void setMode(int i, byte[] bArr) {
|
||
|
|
Assertions.checkState(this.sessions.isEmpty());
|
||
|
|
if (i == 1 || i == 3) {
|
||
|
|
Assertions.checkNotNull(bArr);
|
||
|
|
}
|
||
|
|
this.mode = i;
|
||
|
|
this.offlineLicenseKeySetId = bArr;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager
|
||
|
|
public final void prepare() {
|
||
|
|
verifyPlaybackThread(true);
|
||
|
|
int i = this.prepareCallsCount;
|
||
|
|
this.prepareCallsCount = i + 1;
|
||
|
|
if (i != 0) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (this.exoMediaDrm == null) {
|
||
|
|
ExoMediaDrm acquireExoMediaDrm = this.exoMediaDrmProvider.acquireExoMediaDrm(this.uuid);
|
||
|
|
this.exoMediaDrm = acquireExoMediaDrm;
|
||
|
|
acquireExoMediaDrm.setOnEventListener(new MediaDrmEventListener());
|
||
|
|
} else if (this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
for (int i2 = 0; i2 < this.sessions.size(); i2++) {
|
||
|
|
this.sessions.get(i2).acquire(null);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager
|
||
|
|
public final void release() {
|
||
|
|
verifyPlaybackThread(true);
|
||
|
|
int i = this.prepareCallsCount - 1;
|
||
|
|
this.prepareCallsCount = i;
|
||
|
|
if (i != 0) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
ArrayList arrayList = new ArrayList(this.sessions);
|
||
|
|
for (int i2 = 0; i2 < arrayList.size(); i2++) {
|
||
|
|
((DefaultDrmSession) arrayList.get(i2)).release(null);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
releaseAllPreacquiredSessions();
|
||
|
|
maybeReleaseMediaDrm();
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager
|
||
|
|
public void setPlayer(Looper looper, PlayerId playerId) {
|
||
|
|
initPlaybackLooper(looper);
|
||
|
|
this.playerId = playerId;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager
|
||
|
|
public DrmSessionManager.DrmSessionReference preacquireSession(DrmSessionEventListener.EventDispatcher eventDispatcher, Format format) {
|
||
|
|
Assertions.checkState(this.prepareCallsCount > 0);
|
||
|
|
Assertions.checkStateNotNull(this.playbackLooper);
|
||
|
|
PreacquiredSessionReference preacquiredSessionReference = new PreacquiredSessionReference(eventDispatcher);
|
||
|
|
preacquiredSessionReference.acquire(format);
|
||
|
|
return preacquiredSessionReference;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager
|
||
|
|
public DrmSession acquireSession(DrmSessionEventListener.EventDispatcher eventDispatcher, Format format) {
|
||
|
|
verifyPlaybackThread(false);
|
||
|
|
Assertions.checkState(this.prepareCallsCount > 0);
|
||
|
|
Assertions.checkStateNotNull(this.playbackLooper);
|
||
|
|
return acquireSession(this.playbackLooper, eventDispatcher, format, true);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: private */
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
public DrmSession acquireSession(Looper looper, DrmSessionEventListener.EventDispatcher eventDispatcher, Format format, boolean z) {
|
||
|
|
List<DrmInitData.SchemeData> list;
|
||
|
|
maybeCreateMediaDrmHandler(looper);
|
||
|
|
if (format.drmInitData == null) {
|
||
|
|
return maybeAcquirePlaceholderSession(MimeTypes.getTrackType(format.sampleMimeType), z);
|
||
|
|
}
|
||
|
|
DefaultDrmSession defaultDrmSession = null;
|
||
|
|
Object[] objArr = 0;
|
||
|
|
if (this.offlineLicenseKeySetId == null) {
|
||
|
|
list = getSchemeDatas((DrmInitData) Assertions.checkNotNull(format.drmInitData), this.uuid, false);
|
||
|
|
if (list.isEmpty()) {
|
||
|
|
MissingSchemeDataException missingSchemeDataException = new MissingSchemeDataException(this.uuid);
|
||
|
|
Log.e(TAG, "DRM error", missingSchemeDataException);
|
||
|
|
if (eventDispatcher != null) {
|
||
|
|
eventDispatcher.drmSessionManagerError(missingSchemeDataException);
|
||
|
|
}
|
||
|
|
return new ErrorStateDrmSession(new DrmSession.DrmSessionException(missingSchemeDataException, 6003));
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
list = null;
|
||
|
|
}
|
||
|
|
if (this.multiSession) {
|
||
|
|
Iterator<DefaultDrmSession> it = this.sessions.iterator();
|
||
|
|
while (true) {
|
||
|
|
if (!it.hasNext()) {
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
DefaultDrmSession next = it.next();
|
||
|
|
if (Util.areEqual(next.schemeDatas, list)) {
|
||
|
|
defaultDrmSession = next;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
defaultDrmSession = this.noMultiSessionDrmSession;
|
||
|
|
}
|
||
|
|
if (defaultDrmSession == null) {
|
||
|
|
defaultDrmSession = createAndAcquireSessionWithRetry(list, false, eventDispatcher, z);
|
||
|
|
if (!this.multiSession) {
|
||
|
|
this.noMultiSessionDrmSession = defaultDrmSession;
|
||
|
|
}
|
||
|
|
this.sessions.add(defaultDrmSession);
|
||
|
|
} else {
|
||
|
|
defaultDrmSession.acquire(eventDispatcher);
|
||
|
|
}
|
||
|
|
return defaultDrmSession;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager
|
||
|
|
public int getCryptoType(Format format) {
|
||
|
|
verifyPlaybackThread(false);
|
||
|
|
int cryptoType = ((ExoMediaDrm) Assertions.checkNotNull(this.exoMediaDrm)).getCryptoType();
|
||
|
|
if (format.drmInitData == null) {
|
||
|
|
if (Util.linearSearch(this.useDrmSessionsForClearContentTrackTypes, MimeTypes.getTrackType(format.sampleMimeType)) != -1) {
|
||
|
|
return cryptoType;
|
||
|
|
}
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
if (canAcquireSession(format.drmInitData)) {
|
||
|
|
return cryptoType;
|
||
|
|
}
|
||
|
|
return 1;
|
||
|
|
}
|
||
|
|
|
||
|
|
private DrmSession maybeAcquirePlaceholderSession(int i, boolean z) {
|
||
|
|
ExoMediaDrm exoMediaDrm = (ExoMediaDrm) Assertions.checkNotNull(this.exoMediaDrm);
|
||
|
|
if ((exoMediaDrm.getCryptoType() == 2 && FrameworkCryptoConfig.WORKAROUND_DEVICE_NEEDS_KEYS_TO_CONFIGURE_CODEC) || Util.linearSearch(this.useDrmSessionsForClearContentTrackTypes, i) == -1 || exoMediaDrm.getCryptoType() == 1) {
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
DefaultDrmSession defaultDrmSession = this.placeholderDrmSession;
|
||
|
|
if (defaultDrmSession == null) {
|
||
|
|
DefaultDrmSession createAndAcquireSessionWithRetry = createAndAcquireSessionWithRetry(ImmutableList.of(), true, null, z);
|
||
|
|
this.sessions.add(createAndAcquireSessionWithRetry);
|
||
|
|
this.placeholderDrmSession = createAndAcquireSessionWithRetry;
|
||
|
|
} else {
|
||
|
|
defaultDrmSession.acquire(null);
|
||
|
|
}
|
||
|
|
return this.placeholderDrmSession;
|
||
|
|
}
|
||
|
|
|
||
|
|
private boolean canAcquireSession(DrmInitData drmInitData) {
|
||
|
|
if (this.offlineLicenseKeySetId != null) {
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
if (getSchemeDatas(drmInitData, this.uuid, true).isEmpty()) {
|
||
|
|
if (drmInitData.schemeDataCount != 1 || !drmInitData.get(0).matches(C.COMMON_PSSH_UUID)) {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
Log.w(TAG, "DrmInitData only contains common PSSH SchemeData. Assuming support for: " + this.uuid);
|
||
|
|
}
|
||
|
|
String str = drmInitData.schemeType;
|
||
|
|
if (str == null || "cenc".equals(str)) {
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
return "cbcs".equals(str) ? Util.SDK_INT >= 25 : ("cbc1".equals(str) || "cens".equals(str)) ? false : true;
|
||
|
|
}
|
||
|
|
|
||
|
|
@EnsuresNonNull({"this.playbackLooper", "this.playbackHandler"})
|
||
|
|
private synchronized void initPlaybackLooper(Looper looper) {
|
||
|
|
Looper looper2 = this.playbackLooper;
|
||
|
|
if (looper2 == null) {
|
||
|
|
this.playbackLooper = looper;
|
||
|
|
this.playbackHandler = new Handler(looper);
|
||
|
|
} else {
|
||
|
|
Assertions.checkState(looper2 == looper);
|
||
|
|
Assertions.checkNotNull(this.playbackHandler);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private void maybeCreateMediaDrmHandler(Looper looper) {
|
||
|
|
if (this.mediaDrmHandler == null) {
|
||
|
|
this.mediaDrmHandler = new MediaDrmHandler(looper);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private DefaultDrmSession createAndAcquireSessionWithRetry(List<DrmInitData.SchemeData> list, boolean z, DrmSessionEventListener.EventDispatcher eventDispatcher, boolean z2) {
|
||
|
|
DefaultDrmSession createAndAcquireSession = createAndAcquireSession(list, z, eventDispatcher);
|
||
|
|
if (acquisitionFailedIndicatingResourceShortage(createAndAcquireSession) && !this.keepaliveSessions.isEmpty()) {
|
||
|
|
releaseAllKeepaliveSessions();
|
||
|
|
undoAcquisition(createAndAcquireSession, eventDispatcher);
|
||
|
|
createAndAcquireSession = createAndAcquireSession(list, z, eventDispatcher);
|
||
|
|
}
|
||
|
|
if (!acquisitionFailedIndicatingResourceShortage(createAndAcquireSession) || !z2 || this.preacquiredSessionReferences.isEmpty()) {
|
||
|
|
return createAndAcquireSession;
|
||
|
|
}
|
||
|
|
releaseAllPreacquiredSessions();
|
||
|
|
if (!this.keepaliveSessions.isEmpty()) {
|
||
|
|
releaseAllKeepaliveSessions();
|
||
|
|
}
|
||
|
|
undoAcquisition(createAndAcquireSession, eventDispatcher);
|
||
|
|
return createAndAcquireSession(list, z, eventDispatcher);
|
||
|
|
}
|
||
|
|
|
||
|
|
private static boolean acquisitionFailedIndicatingResourceShortage(DrmSession drmSession) {
|
||
|
|
return drmSession.getState() == 1 && (Util.SDK_INT < 19 || (((DrmSession.DrmSessionException) Assertions.checkNotNull(drmSession.getError())).getCause() instanceof ResourceBusyException));
|
||
|
|
}
|
||
|
|
|
||
|
|
private void undoAcquisition(DrmSession drmSession, DrmSessionEventListener.EventDispatcher eventDispatcher) {
|
||
|
|
drmSession.release(eventDispatcher);
|
||
|
|
if (this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
drmSession.release(null);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private void releaseAllKeepaliveSessions() {
|
||
|
|
UnmodifiableIterator it = ImmutableSet.copyOf((Collection) this.keepaliveSessions).iterator();
|
||
|
|
while (it.hasNext()) {
|
||
|
|
((DrmSession) it.next()).release(null);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
private void releaseAllPreacquiredSessions() {
|
||
|
|
UnmodifiableIterator it = ImmutableSet.copyOf((Collection) this.preacquiredSessionReferences).iterator();
|
||
|
|
while (it.hasNext()) {
|
||
|
|
((PreacquiredSessionReference) it.next()).release();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private DefaultDrmSession createAndAcquireSession(List<DrmInitData.SchemeData> list, boolean z, DrmSessionEventListener.EventDispatcher eventDispatcher) {
|
||
|
|
Assertions.checkNotNull(this.exoMediaDrm);
|
||
|
|
DefaultDrmSession defaultDrmSession = new DefaultDrmSession(this.uuid, this.exoMediaDrm, this.provisioningManagerImpl, this.referenceCountListener, list, this.mode, this.playClearSamplesWithoutKeys | z, z, this.offlineLicenseKeySetId, this.keyRequestParameters, this.callback, (Looper) Assertions.checkNotNull(this.playbackLooper), this.loadErrorHandlingPolicy, (PlayerId) Assertions.checkNotNull(this.playerId));
|
||
|
|
defaultDrmSession.acquire(eventDispatcher);
|
||
|
|
if (this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
defaultDrmSession.acquire(null);
|
||
|
|
}
|
||
|
|
return defaultDrmSession;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: private */
|
||
|
|
public void maybeReleaseMediaDrm() {
|
||
|
|
if (this.exoMediaDrm != null && this.prepareCallsCount == 0 && this.sessions.isEmpty() && this.preacquiredSessionReferences.isEmpty()) {
|
||
|
|
((ExoMediaDrm) Assertions.checkNotNull(this.exoMediaDrm)).release();
|
||
|
|
this.exoMediaDrm = null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private void verifyPlaybackThread(boolean z) {
|
||
|
|
if (z && this.playbackLooper == null) {
|
||
|
|
Log.w(TAG, "DefaultDrmSessionManager accessed before setPlayer(), possibly on the wrong thread.", new IllegalStateException());
|
||
|
|
} else if (Thread.currentThread() != ((Looper) Assertions.checkNotNull(this.playbackLooper)).getThread()) {
|
||
|
|
Log.w(TAG, "DefaultDrmSessionManager accessed on the wrong thread.\nCurrent thread: " + Thread.currentThread().getName() + "\nExpected thread: " + this.playbackLooper.getThread().getName(), new IllegalStateException());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private static List<DrmInitData.SchemeData> getSchemeDatas(DrmInitData drmInitData, UUID uuid, boolean z) {
|
||
|
|
ArrayList arrayList = new ArrayList(drmInitData.schemeDataCount);
|
||
|
|
for (int i = 0; i < drmInitData.schemeDataCount; i++) {
|
||
|
|
DrmInitData.SchemeData schemeData = drmInitData.get(i);
|
||
|
|
if ((schemeData.matches(uuid) || (C.CLEARKEY_UUID.equals(uuid) && schemeData.matches(C.COMMON_PSSH_UUID))) && (schemeData.data != null || z)) {
|
||
|
|
arrayList.add(schemeData);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return arrayList;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: private */
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public class MediaDrmHandler extends Handler {
|
||
|
|
public MediaDrmHandler(Looper looper) {
|
||
|
|
super(looper);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // android.os.Handler
|
||
|
|
public void handleMessage(Message message) {
|
||
|
|
byte[] bArr = (byte[]) message.obj;
|
||
|
|
if (bArr == null) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
for (DefaultDrmSession defaultDrmSession : DefaultDrmSessionManager.this.sessions) {
|
||
|
|
if (defaultDrmSession.hasSessionId(bArr)) {
|
||
|
|
defaultDrmSession.onMediaDrmEvent(message.what);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: private */
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public class ProvisioningManagerImpl implements DefaultDrmSession.ProvisioningManager {
|
||
|
|
private DefaultDrmSession provisioningSession;
|
||
|
|
private final Set<DefaultDrmSession> sessionsAwaitingProvisioning = new HashSet();
|
||
|
|
|
||
|
|
public ProvisioningManagerImpl() {
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DefaultDrmSession.ProvisioningManager
|
||
|
|
public void provisionRequired(DefaultDrmSession defaultDrmSession) {
|
||
|
|
this.sessionsAwaitingProvisioning.add(defaultDrmSession);
|
||
|
|
if (this.provisioningSession != null) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.provisioningSession = defaultDrmSession;
|
||
|
|
defaultDrmSession.provision();
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DefaultDrmSession.ProvisioningManager
|
||
|
|
public void onProvisionCompleted() {
|
||
|
|
this.provisioningSession = null;
|
||
|
|
ImmutableList copyOf = ImmutableList.copyOf((Collection) this.sessionsAwaitingProvisioning);
|
||
|
|
this.sessionsAwaitingProvisioning.clear();
|
||
|
|
UnmodifiableIterator it = copyOf.iterator();
|
||
|
|
while (it.hasNext()) {
|
||
|
|
((DefaultDrmSession) it.next()).onProvisionCompleted();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DefaultDrmSession.ProvisioningManager
|
||
|
|
public void onProvisionError(Exception exc, boolean z) {
|
||
|
|
this.provisioningSession = null;
|
||
|
|
ImmutableList copyOf = ImmutableList.copyOf((Collection) this.sessionsAwaitingProvisioning);
|
||
|
|
this.sessionsAwaitingProvisioning.clear();
|
||
|
|
UnmodifiableIterator it = copyOf.iterator();
|
||
|
|
while (it.hasNext()) {
|
||
|
|
((DefaultDrmSession) it.next()).onProvisionError(exc, z);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void onSessionFullyReleased(DefaultDrmSession defaultDrmSession) {
|
||
|
|
this.sessionsAwaitingProvisioning.remove(defaultDrmSession);
|
||
|
|
if (this.provisioningSession == defaultDrmSession) {
|
||
|
|
this.provisioningSession = null;
|
||
|
|
if (this.sessionsAwaitingProvisioning.isEmpty()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
DefaultDrmSession next = this.sessionsAwaitingProvisioning.iterator().next();
|
||
|
|
this.provisioningSession = next;
|
||
|
|
next.provision();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: private */
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public class ReferenceCountListenerImpl implements DefaultDrmSession.ReferenceCountListener {
|
||
|
|
private ReferenceCountListenerImpl() {
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DefaultDrmSession.ReferenceCountListener
|
||
|
|
public void onReferenceCountIncremented(DefaultDrmSession defaultDrmSession, int i) {
|
||
|
|
if (DefaultDrmSessionManager.this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
DefaultDrmSessionManager.this.keepaliveSessions.remove(defaultDrmSession);
|
||
|
|
((Handler) Assertions.checkNotNull(DefaultDrmSessionManager.this.playbackHandler)).removeCallbacksAndMessages(defaultDrmSession);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DefaultDrmSession.ReferenceCountListener
|
||
|
|
public void onReferenceCountDecremented(final DefaultDrmSession defaultDrmSession, int i) {
|
||
|
|
if (i == 1 && DefaultDrmSessionManager.this.prepareCallsCount > 0 && DefaultDrmSessionManager.this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
DefaultDrmSessionManager.this.keepaliveSessions.add(defaultDrmSession);
|
||
|
|
((Handler) Assertions.checkNotNull(DefaultDrmSessionManager.this.playbackHandler)).postAtTime(new Runnable() { // from class: androidx.media3.exoplayer.drm.DefaultDrmSessionManager$ReferenceCountListenerImpl$$ExternalSyntheticLambda0
|
||
|
|
@Override // java.lang.Runnable
|
||
|
|
public final void run() {
|
||
|
|
DefaultDrmSession.this.release(null);
|
||
|
|
}
|
||
|
|
}, defaultDrmSession, SystemClock.uptimeMillis() + DefaultDrmSessionManager.this.sessionKeepaliveMs);
|
||
|
|
} else if (i == 0) {
|
||
|
|
DefaultDrmSessionManager.this.sessions.remove(defaultDrmSession);
|
||
|
|
if (DefaultDrmSessionManager.this.placeholderDrmSession == defaultDrmSession) {
|
||
|
|
DefaultDrmSessionManager.this.placeholderDrmSession = null;
|
||
|
|
}
|
||
|
|
if (DefaultDrmSessionManager.this.noMultiSessionDrmSession == defaultDrmSession) {
|
||
|
|
DefaultDrmSessionManager.this.noMultiSessionDrmSession = null;
|
||
|
|
}
|
||
|
|
DefaultDrmSessionManager.this.provisioningManagerImpl.onSessionFullyReleased(defaultDrmSession);
|
||
|
|
if (DefaultDrmSessionManager.this.sessionKeepaliveMs != -9223372036854775807L) {
|
||
|
|
((Handler) Assertions.checkNotNull(DefaultDrmSessionManager.this.playbackHandler)).removeCallbacksAndMessages(defaultDrmSession);
|
||
|
|
DefaultDrmSessionManager.this.keepaliveSessions.remove(defaultDrmSession);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
DefaultDrmSessionManager.this.maybeReleaseMediaDrm();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
private class MediaDrmEventListener implements ExoMediaDrm.OnEventListener {
|
||
|
|
private MediaDrmEventListener() {
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.ExoMediaDrm.OnEventListener
|
||
|
|
public void onEvent(ExoMediaDrm exoMediaDrm, byte[] bArr, int i, int i2, byte[] bArr2) {
|
||
|
|
((MediaDrmHandler) Assertions.checkNotNull(DefaultDrmSessionManager.this.mediaDrmHandler)).obtainMessage(i, bArr).sendToTarget();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: private */
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public class PreacquiredSessionReference implements DrmSessionManager.DrmSessionReference {
|
||
|
|
private final DrmSessionEventListener.EventDispatcher eventDispatcher;
|
||
|
|
private boolean isReleased;
|
||
|
|
private DrmSession session;
|
||
|
|
|
||
|
|
public PreacquiredSessionReference(DrmSessionEventListener.EventDispatcher eventDispatcher) {
|
||
|
|
this.eventDispatcher = eventDispatcher;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void acquire(final Format format) {
|
||
|
|
((Handler) Assertions.checkNotNull(DefaultDrmSessionManager.this.playbackHandler)).post(new Runnable() { // from class: androidx.media3.exoplayer.drm.DefaultDrmSessionManager$PreacquiredSessionReference$$ExternalSyntheticLambda1
|
||
|
|
@Override // java.lang.Runnable
|
||
|
|
public final void run() {
|
||
|
|
DefaultDrmSessionManager.PreacquiredSessionReference.this.m5232x937f548e(format);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* renamed from: lambda$acquire$0$androidx-media3-exoplayer-drm-DefaultDrmSessionManager$PreacquiredSessionReference, reason: not valid java name */
|
||
|
|
public /* synthetic */ void m5232x937f548e(Format format) {
|
||
|
|
if (DefaultDrmSessionManager.this.prepareCallsCount == 0 || this.isReleased) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
DefaultDrmSessionManager defaultDrmSessionManager = DefaultDrmSessionManager.this;
|
||
|
|
this.session = defaultDrmSessionManager.acquireSession((Looper) Assertions.checkNotNull(defaultDrmSessionManager.playbackLooper), this.eventDispatcher, format, false);
|
||
|
|
DefaultDrmSessionManager.this.preacquiredSessionReferences.add(this);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // androidx.media3.exoplayer.drm.DrmSessionManager.DrmSessionReference
|
||
|
|
public void release() {
|
||
|
|
Util.postOrRun((Handler) Assertions.checkNotNull(DefaultDrmSessionManager.this.playbackHandler), new Runnable() { // from class: androidx.media3.exoplayer.drm.DefaultDrmSessionManager$PreacquiredSessionReference$$ExternalSyntheticLambda0
|
||
|
|
@Override // java.lang.Runnable
|
||
|
|
public final void run() {
|
||
|
|
DefaultDrmSessionManager.PreacquiredSessionReference.this.m5233xce10c5c();
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* renamed from: lambda$release$1$androidx-media3-exoplayer-drm-DefaultDrmSessionManager$PreacquiredSessionReference, reason: not valid java name */
|
||
|
|
public /* synthetic */ void m5233xce10c5c() {
|
||
|
|
if (this.isReleased) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
DrmSession drmSession = this.session;
|
||
|
|
if (drmSession != null) {
|
||
|
|
drmSession.release(this.eventDispatcher);
|
||
|
|
}
|
||
|
|
DefaultDrmSessionManager.this.preacquiredSessionReferences.remove(this);
|
||
|
|
this.isReleased = true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|