Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(78)

Unified Diff: components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/SessionDependencyFactoryNative.java

Issue 1142463003: Remove devtools_bridge component (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/SessionDependencyFactoryNative.java
diff --git a/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/SessionDependencyFactoryNative.java b/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/SessionDependencyFactoryNative.java
deleted file mode 100644
index cac78a5e2a4b7b8a32986e96e6d4b450ceb35aff..0000000000000000000000000000000000000000
--- a/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/SessionDependencyFactoryNative.java
+++ /dev/null
@@ -1,283 +0,0 @@
-// Copyright 2014 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-package org.chromium.components.devtools_bridge;
-
-import org.chromium.base.CalledByNative;
-import org.chromium.base.JNINamespace;
-
-import java.nio.ByteBuffer;
-
-/**
- * Native implementation of session dependency factory on top of C++
- * libjingle API.
- */
-@JNINamespace("devtools_bridge::android")
-public class SessionDependencyFactoryNative extends SessionDependencyFactory {
- private final long mFactoryPtr;
-
- public SessionDependencyFactoryNative() {
- mFactoryPtr = nativeCreateFactory();
- assert mFactoryPtr != 0;
- }
-
- @Override
- public AbstractPeerConnection createPeerConnection(
- RTCConfiguration config, AbstractPeerConnection.Observer observer) {
- assert config != null;
- assert observer != null;
-
- long configPtr = nativeCreateConfig();
- for (RTCConfiguration.IceServer server : config.iceServers) {
- nativeAddIceServer(configPtr, server.uri, server.username, server.credential);
- }
-
- return new PeerConnectionImpl(mFactoryPtr, configPtr, observer);
- }
-
- @Override
- public SocketTunnel newSocketTunnelServer(String socketBase) {
- return new SocketTunnelServerImpl(mFactoryPtr, socketBase);
- }
-
- @Override
- public void dispose() {
- nativeDestroyFactory(mFactoryPtr);
- }
-
- private static final class PeerConnectionImpl extends AbstractPeerConnection {
- private final long mConnectionPtr;
-
- // Takes ownership on |configPtr|.
- public PeerConnectionImpl(
- long factoryPtr, long configPtr,
- AbstractPeerConnection.Observer observer) {
- mConnectionPtr = nativeCreatePeerConnection(factoryPtr, configPtr, observer);
- assert mConnectionPtr != 0;
- }
-
- @Override
- public void createAndSetLocalDescription(SessionDescriptionType type) {
- switch (type) {
- case OFFER:
- nativeCreateAndSetLocalOffer(mConnectionPtr);
- break;
-
- case ANSWER:
- nativeCreateAndSetLocalAnswer(mConnectionPtr);
- break;
- }
- }
-
- @Override
- public void setRemoteDescription(SessionDescriptionType type, String description) {
- switch (type) {
- case OFFER:
- nativeSetRemoteOffer(mConnectionPtr, description);
- break;
-
- case ANSWER:
- nativeSetRemoteAnswer(mConnectionPtr, description);
- break;
- }
- }
-
- @Override
- public void addIceCandidate(String candidate) {
- // TODO(serya): Handle IllegalArgumentException exception.
- IceCandidate parsed = IceCandidate.fromString(candidate);
- nativeAddIceCandidate(mConnectionPtr, parsed.sdpMid, parsed.sdpMLineIndex, parsed.sdp);
- }
-
- @Override
- public void dispose() {
- nativeDestroyPeerConnection(mConnectionPtr);
- }
-
- @Override
- public AbstractDataChannel createDataChannel(int channelId) {
- return new DataChannelImpl(nativeCreateDataChannel(mConnectionPtr, channelId));
- }
- }
-
- private static final class DataChannelImpl extends AbstractDataChannel {
- private final long mChannelPtr;
-
- public DataChannelImpl(long ptr) {
- assert ptr != 0;
- mChannelPtr = ptr;
- }
-
- long nativePtr() {
- return mChannelPtr;
- }
-
- @Override
- public void registerObserver(Observer observer) {
- nativeRegisterDataChannelObserver(mChannelPtr, observer);
- }
-
- @Override
- public void unregisterObserver() {
- nativeUnregisterDataChannelObserver(mChannelPtr);
- }
-
- @Override
- public void send(ByteBuffer message, MessageType type) {
- assert message.position() == 0;
- int length = message.limit();
- assert length > 0;
-
- switch (type) {
- case BINARY:
- nativeSendBinaryMessage(mChannelPtr, message, length);
- break;
-
- case TEXT:
- nativeSendTextMessage(mChannelPtr, message, length);
- break;
- }
- }
-
- @Override
- public void close() {
- nativeCloseDataChannel(mChannelPtr);
- }
-
- @Override
- public void dispose() {
- nativeDestroyDataChannel(mChannelPtr);
- }
- }
-
- private static class SocketTunnelServerImpl implements SocketTunnel {
- private final String mSocketName;
- private final long mFactoryPtr;
- private DataChannelImpl mDataChannel;
- private long mTunnelPtr;
-
- public SocketTunnelServerImpl(long factoryPtr, String socketName) {
- mFactoryPtr = factoryPtr;
- mSocketName = socketName;
- }
-
- @Override
- public void bind(AbstractDataChannel dataChannel) {
- mDataChannel = (DataChannelImpl) dataChannel;
- mTunnelPtr = nativeCreateSocketTunnelServer(
- mFactoryPtr, mDataChannel.nativePtr(), mSocketName);
- }
-
- @Override
- public AbstractDataChannel unbind() {
- AbstractDataChannel result = mDataChannel;
- nativeDestroySocketTunnelServer(mTunnelPtr);
- mTunnelPtr = 0;
- mDataChannel = null;
- return result;
- }
-
- @Override
- public boolean isBound() {
- return mDataChannel != null;
- }
-
- @Override
- public void dispose() {
- assert !isBound();
- }
- }
-
- // Peer connection callbacks.
-
- @CalledByNative
- private static void notifyLocalOfferCreatedAndSetSet(Object observer, String description) {
- ((AbstractPeerConnection.Observer) observer).onLocalDescriptionCreatedAndSet(
- AbstractPeerConnection.SessionDescriptionType.OFFER, description);
- }
-
- @CalledByNative
- private static void notifyLocalAnswerCreatedAndSetSet(Object observer, String description) {
- ((AbstractPeerConnection.Observer) observer).onLocalDescriptionCreatedAndSet(
- AbstractPeerConnection.SessionDescriptionType.ANSWER, description);
- }
-
- @CalledByNative
- private static void notifyRemoteDescriptionSet(Object observer) {
- ((AbstractPeerConnection.Observer) observer).onRemoteDescriptionSet();
- }
-
- @CalledByNative
- private static void notifyConnectionFailure(Object observer, String description) {
- ((AbstractPeerConnection.Observer) observer).onFailure(description);
- }
-
- @CalledByNative
- private static void notifyIceCandidate(
- Object observer, String sdpMid, int sdpMLineIndex, String sdp) {
- ((AbstractPeerConnection.Observer) observer)
- .onIceCandidate(new AbstractPeerConnection.IceCandidate(
- sdpMid, sdpMLineIndex, sdp).toString());
- }
-
- @CalledByNative
- private static void notifyIceConnectionChange(Object observer, boolean connected) {
- ((AbstractPeerConnection.Observer) observer)
- .onIceConnectionChange(connected);
- }
-
- // Data channel callbacks.
-
- @CalledByNative
- private static void notifyChannelOpen(Object observer) {
- ((AbstractDataChannel.Observer) observer)
- .onStateChange(AbstractDataChannel.State.OPEN);
- }
-
- @CalledByNative
- private static void notifyChannelClose(Object observer) {
- ((AbstractDataChannel.Observer) observer)
- .onStateChange(AbstractDataChannel.State.CLOSED);
- }
-
- @CalledByNative
- private static void notifyMessage(Object observer, ByteBuffer message) {
- ((AbstractDataChannel.Observer) observer)
- .onMessage(message);
- }
-
- private static native long nativeCreateFactory();
- private static native void nativeDestroyFactory(long factoryPtr);
-
- private static native long nativeCreateConfig();
- private static native void nativeAddIceServer(
- long configPtr, String uri, String username, String credential);
-
- // Takes ownership on |configPtr|.
- private static native long nativeCreatePeerConnection(
- long factoryPtr, long configPtr, Object observer);
- private static native void nativeDestroyPeerConnection(long connectionPtr);
-
- private static native void nativeCreateAndSetLocalOffer(long connectionPtr);
- private static native void nativeCreateAndSetLocalAnswer(long connectionPtr);
- private static native void nativeSetRemoteOffer(long connectionPtr, String description);
- private static native void nativeSetRemoteAnswer(long connectionPtr, String description);
- private static native void nativeAddIceCandidate(
- long peerConnectionPtr, String sdpMid, int sdpMLineIndex, String sdp);
-
- private static native long nativeCreateDataChannel(long connectionPtr, int channelId);
- private static native void nativeDestroyDataChannel(long channelPtr);
-
- private static native void nativeRegisterDataChannelObserver(
- long channelPtr, Object observer);
- private static native void nativeUnregisterDataChannelObserver(long channelPtr);
- private static native void nativeSendBinaryMessage(
- long channelPtr, ByteBuffer message, int size);
- private static native void nativeSendTextMessage(long channelPtr, ByteBuffer message, int size);
- private static native void nativeCloseDataChannel(long channelPtr);
-
- private static native long nativeCreateSocketTunnelServer(
- long factoryPtr, long channelPtr, String socketName);
- private static native void nativeDestroySocketTunnelServer(long tunnelPtr);
-}

Powered by Google App Engine
This is Rietveld 408576698