Source code
Revision control
Copy as Markdown
Other Tools
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
package org.mozilla.gecko.media;
import android.media.MediaCrypto;
import android.util.Log;
final class RemoteMediaDrmBridge implements GeckoMediaDrm {
private static final String LOGTAG = "RemoteMediaDrmBridge";
private static final boolean DEBUG = false;
private CallbacksForwarder mCallbacksFwd;
private IMediaDrmBridge mRemote;
// Forward callbacks from remote bridge stub to MediaDrmProxy.
private static class CallbacksForwarder extends IMediaDrmBridgeCallbacks.Stub {
private final GeckoMediaDrm.Callbacks mProxyCallbacks;
CallbacksForwarder(final Callbacks callbacks) {
assertTrue(callbacks != null);
mProxyCallbacks = callbacks;
}
@Override
public void onSessionCreated(
final int createSessionToken,
final int promiseId,
final byte[] sessionId,
final byte[] request) {
mProxyCallbacks.onSessionCreated(createSessionToken, promiseId, sessionId, request);
}
@Override
public void onSessionUpdated(final int promiseId, final byte[] sessionId) {
mProxyCallbacks.onSessionUpdated(promiseId, sessionId);
}
@Override
public void onSessionClosed(final int promiseId, final byte[] sessionId) {
mProxyCallbacks.onSessionClosed(promiseId, sessionId);
}
@Override
public void onSessionMessage(
final byte[] sessionId, final int sessionMessageType, final byte[] request) {
mProxyCallbacks.onSessionMessage(sessionId, sessionMessageType, request);
}
@Override
public void onSessionError(final byte[] sessionId, final String message) {
mProxyCallbacks.onSessionError(sessionId, message);
}
@Override
public void onSessionBatchedKeyChanged(
final byte[] sessionId, final SessionKeyInfo[] keyInfos) {
mProxyCallbacks.onSessionBatchedKeyChanged(sessionId, keyInfos);
}
@Override
public void onRejectPromise(final int promiseId, final String message) {
mProxyCallbacks.onRejectPromise(promiseId, message);
}
} // CallbacksForwarder
/* package-private */ static void assertTrue(final boolean condition) {
if (DEBUG && !condition) {
throw new AssertionError("Expected condition to be true");
}
}
public RemoteMediaDrmBridge(final IMediaDrmBridge remoteBridge) {
assertTrue(remoteBridge != null);
mRemote = remoteBridge;
}
@Override
public synchronized void setCallbacks(final Callbacks callbacks) {
if (DEBUG) Log.d(LOGTAG, "setCallbacks()");
assertTrue(callbacks != null);
assertTrue(mRemote != null);
mCallbacksFwd = new CallbacksForwarder(callbacks);
try {
mRemote.setCallbacks(mCallbacksFwd);
} catch (final Exception e) {
Log.e(LOGTAG, "Got exception during setCallbacks", e);
}
}
@Override
public synchronized void createSession(
final int createSessionToken,
final int promiseId,
final String initDataType,
final byte[] initData) {
if (DEBUG) Log.d(LOGTAG, "createSession()");
try {
mRemote.createSession(createSessionToken, promiseId, initDataType, initData);
} catch (final Exception e) {
Log.e(LOGTAG, "Got exception while creating remote session.", e);
mCallbacksFwd.onRejectPromise(promiseId, "Failed to create session.");
}
}
@Override
public synchronized void updateSession(
final int promiseId, final String sessionId, final byte[] response) {
if (DEBUG) Log.d(LOGTAG, "updateSession()");
try {
mRemote.updateSession(promiseId, sessionId, response);
} catch (final Exception e) {
Log.e(LOGTAG, "Got exception while updating remote session.", e);
mCallbacksFwd.onRejectPromise(promiseId, "Failed to update session.");
}
}
@Override
public synchronized void closeSession(final int promiseId, final String sessionId) {
if (DEBUG) Log.d(LOGTAG, "closeSession()");
try {
mRemote.closeSession(promiseId, sessionId);
} catch (final Exception e) {
Log.e(LOGTAG, "Got exception while closing remote session.", e);
mCallbacksFwd.onRejectPromise(promiseId, "Failed to close session.");
}
}
@Override
public synchronized void release() {
if (DEBUG) Log.d(LOGTAG, "release()");
try {
mRemote.release();
} catch (final Exception e) {
Log.e(LOGTAG, "Got exception while releasing RemoteDrmBridge.", e);
}
RemoteManager.getInstance().onRemoteMediaDrmBridgeReleased(mRemote);
mRemote = null;
mCallbacksFwd = null;
}
@Override
public synchronized MediaCrypto getMediaCrypto() {
if (DEBUG) Log.d(LOGTAG, "getMediaCrypto(), should not enter here!");
assertTrue(false);
return null;
}
@Override
public synchronized void setServerCertificate(final byte[] cert) {
try {
mRemote.setServerCertificate(cert);
} catch (final Exception e) {
Log.e(LOGTAG, "Got exception while setting server certificate.", e);
throw new RuntimeException(e);
}
}
}