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

Unified Diff: components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/ServerSession.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/ServerSession.java
diff --git a/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/ServerSession.java b/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/ServerSession.java
deleted file mode 100644
index 4dadcb9d86b2e885d5784553b12cae9213bf7430..0000000000000000000000000000000000000000
--- a/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/ServerSession.java
+++ /dev/null
@@ -1,178 +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 java.util.List;
-
-/**
- * DevTools Bridge server session. Handles connection with a ClientSession.
- * See SessionBase description for more detais.
- */
-public class ServerSession extends SessionBase implements SessionBase.ServerSessionInterface {
- private NegotiationCallback mNegotiationCallback;
- private IceExchangeCallback mIceExchangeCallback;
- private boolean mIceEchangeRequested = false;
-
- protected int mGatheringDelayMs = 200;
-
- public ServerSession(SessionDependencyFactory factory,
- Executor executor,
- String defaultSocketName) {
- super(factory, executor, factory.newSocketTunnelServer(defaultSocketName));
- }
-
- @Override
- public void stop() {
- super.stop();
- if (mNegotiationCallback != null) {
- mNegotiationCallback.onFailure("Session stopped");
- mNegotiationCallback = null;
- }
- if (mIceExchangeCallback != null) {
- mIceExchangeCallback.onFailure("Session stopped");
- mIceExchangeCallback = null;
- }
- }
-
- @Override
- public void startSession(RTCConfiguration config,
- String offer,
- NegotiationCallback callback) {
- checkCalledOnSessionThread();
- if (isStarted()) {
- callback.onFailure("Session already started");
- return;
- }
-
- ClientMessageHandler handler = new ClientMessageHandler();
- start(config, handler);
-
- negotiate(offer, callback);
- }
-
- @Override
- public void renegotiate(String offer, NegotiationCallback callback) {
- checkCalledOnSessionThread();
- if (!isStarted()) {
- callback.onFailure("Session is not started");
- return;
- }
-
- callback.onFailure("Not implemented");
- }
-
- private void negotiate(String offer, NegotiationCallback callback) {
- if (mNegotiationCallback != null) {
- callback.onFailure("Negotiation already in progress");
- return;
- }
-
- mNegotiationCallback = callback;
- // If success will call onRemoteDescriptionSet.
- connection().setRemoteDescription(
- AbstractPeerConnection.SessionDescriptionType.OFFER, offer);
- }
-
- protected void onRemoteDescriptionSet() {
- // If success will call onLocalDescriptionCreatedAndSet.
- connection().createAndSetLocalDescription(
- AbstractPeerConnection.SessionDescriptionType.ANSWER);
- }
-
- @Override
- protected void onLocalDescriptionCreatedAndSet(
- AbstractPeerConnection.SessionDescriptionType type, String description) {
- assert type == AbstractPeerConnection.SessionDescriptionType.ANSWER;
-
- mNegotiationCallback.onSuccess(description);
- mNegotiationCallback = null;
- onSessionNegotiated();
- }
-
- protected void onSessionNegotiated() {
- if (!isControlChannelOpened())
- startAutoCloseTimer();
- }
-
- @Override
- public void iceExchange(List<String> clientCandidates,
- IceExchangeCallback callback) {
- checkCalledOnSessionThread();
- if (!isStarted()) {
- callback.onFailure("Session disposed");
- return;
- }
-
- if (mNegotiationCallback != null || mIceExchangeCallback != null) {
- callback.onFailure("Concurrent requests detected");
- return;
- }
-
- mIceExchangeCallback = callback;
- addIceCandidates(clientCandidates);
-
- // Give libjingle some time for gathering ice candidates.
- postOnSessionThread(mGatheringDelayMs, new Runnable() {
- @Override
- public void run() {
- if (isStarted())
- sendIceCandidatesBack();
- }
- });
- }
-
- private void sendIceCandidatesBack() {
- mIceExchangeCallback.onSuccess(takeIceCandidates());
- mIceExchangeCallback = null;
- mIceEchangeRequested = false;
- }
-
- @Override
- protected void onControlChannelOpened() {
- stopAutoCloseTimer();
- }
-
- @Override
- protected void onFailure(String message) {
- if (mNegotiationCallback != null) {
- mNegotiationCallback.onFailure(message);
- mNegotiationCallback = null;
- }
- super.onFailure(message);
- }
-
- @Override
- protected void onIceCandidate(String candidate) {
- super.onIceCandidate(candidate);
- if (isControlChannelOpened() && !mIceEchangeRequested) {
- // New ICE candidate may improve connection even if control channel operable.
- // If control channel closed client will exchange candidates anyway.
- sendControlMessage(new SessionControlMessages.IceExchangeMessage());
- mIceEchangeRequested = true;
- }
- }
-
- protected SocketTunnel newSocketTunnelServer(String serverSocketName) {
- return mFactory.newSocketTunnelServer(serverSocketName);
- }
-
- private final class ClientMessageHandler extends SessionControlMessages.ClientMessageHandler {
- @Override
- protected void onMessage(SessionControlMessages.ClientMessage message) {
- switch (message.type) {
- case UNKNOWN_REQUEST:
- sendControlMessage(((SessionControlMessages.UnknownRequestMessage) message)
- .createResponse());
- break;
- }
- }
- }
-
- @Override
- protected void sendControlMessage(SessionControlMessages.Message<?> message) {
- assert message instanceof SessionControlMessages.ServerMessage;
- super.sendControlMessage(message);
- }
-}

Powered by Google App Engine
This is Rietveld 408576698