webrtc源码

/* * Copyright 2013 The WebRTC project authors. All Rights Reserved. * * Use of this source code is governed by a BSD-style license * that can be found in the LICENSE file in the root of the source * tree. An additional intellectual property rights grant can be found * in the file PATENTS. All contributing project authors may * be found in the AUTHORS file in the root of the source tree. */ package org.webrtc; import static com.google.common.truth.Truth.assertThat; import static java.util.Collections.singletonList; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotEquals; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNull; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; import android.support.annotation.Nullable; import android.support.test.InstrumentationRegistry; import android.support.test.filters.MediumTest; import android.support.test.filters.SmallTest; import java.io.File; import java.lang.ref.WeakReference; import java.nio.ByteBuffer; import java.nio.charset.Charset; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.HashSet; import java.util.IdentityHashMap; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.TreeSet; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import org.chromium.base.test.BaseJUnit4ClassRunner; import org.chromium.base.test.util.DisabledTest; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.webrtc.Metrics.HistogramInfo; import org.webrtc.PeerConnection.IceConnectionState; import org.webrtc.PeerConnection.IceGatheringState; import org.webrtc.PeerConnection.PeerConnectionState; import org.webrtc.PeerConnection.SignalingState; import org.webrtc.PeerConnection.TlsCertPolicy; import org.webrtc.RtpParameters; import org.webrtc.RtpParameters.Encoding; import org.webrtc.RtpTransceiver; import org.webrtc.RtpTransceiver.RtpTransceiverInit; /** End-to-end tests for PeerConnection.java. */ @RunWith(BaseJUnit4ClassRunner.class) public class PeerConnectionTest { private static final int TIMEOUT_SECONDS = 20; private @Nullable TreeSet<String> threadsBeforeTest; @Before public void setUp() { PeerConnectionFactory.initialize(PeerConnectionFactory.InitializationOptions .builder(InstrumentationRegistry.getTargetContext()) .setNativeLibraryName(TestConstants.NATIVE_LIBRARY) .createInitializationOptions()); } private static class ObserverExpectations implements PeerConnection.Observer, VideoSink, DataChannel.Observer, StatsObserver, RTCStatsCollectorCallback, RtpReceiver.Observer { private final String name; private int expectedIceCandidates; private int expectedErrors; private int expectedRenegotiations; private int expectedWidth; private int expectedHeight; private int expectedFramesDelivered; private int expectedTracksAdded; private Queue<SignalingState> expectedSignalingChanges = new ArrayDeque<>(); private Queue<IceConnectionState> expectedIceConnectionChanges = new ArrayDeque<>(); private Queue<PeerConnectionState> expectedConnectionChanges = new ArrayDeque<>(); private Queue<IceGatheringState> expectedIceGatheringChanges = new ArrayDeque<>(); private Queue<String> expectedAddStreamLabels = new ArrayDeque<>(); private Queue<String> expectedRemoveStreamLabels = new ArrayDeque<>(); private final List<IceCandidate> gotIceCandidates = new ArrayList<>(); private Map<MediaStream, WeakReference<VideoSink>> videoSinks = new IdentityHashMap<>(); private DataChannel dataChannel; private Queue<DataChannel.Buffer> expectedBuffers = new ArrayDeque<>(); private Queue<DataChannel.State> expectedStateChanges = new ArrayDeque<>(); private Queue<String> expectedRemoteDataChannelLabels = new ArrayDeque<>(); private int expectedOldStatsCallbacks; private int expectedNewStatsCallbacks; private List<StatsReport[]> gotStatsReports = new ArrayList<>(); private final HashSet<MediaStream> gotRemoteStreams = new HashSet<>(); private int expectedFirstAudioPacket; private int expectedFirstVideoPacket; public ObserverExpectations(String name) { this.name = name; } // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void setDataChannel(DataChannel dataChannel) { assertNull(this.dataChannel); this.dataChannel = dataChannel; this.dataChannel.registerObserver(this); assertNotNull(this.dataChannel); } // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void expectIceCandidates(int count) { expectedIceCandidates += count; } @Override // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void onIceCandidate(IceCandidate candidate) { --expectedIceCandidates; // We don't assert expectedIceCandidates >= 0 because it's hard to know // how many to expect, in general. We only use expectIceCandidates to // assert a minimal count. synchronized (gotIceCandidates) { gotIceCandidates.add(candidate); gotIceCandidates.notifyAll(); } } @Override public void onIceCandidatesRemoved(IceCandidate[] candidates) {} // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void setExpectedResolution(int width, int height) { expectedWidth = width; expectedHeight = height; } // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void expectFramesDelivered(int count) { expectedFramesDelivered += count; } @Override // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void onFrame(VideoFrame frame) { if (expectedFramesDelivered <= 0) { return; } assertTrue(expectedWidth > 0); assertTrue(expectedHeight > 0); assertEquals(expectedWidth, frame.getRotatedWidth()); assertEquals(expectedHeight, frame.getRotatedHeight()); --expectedFramesDelivered; } // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void expectSignalingChange(SignalingState newState) { expectedSignalingChanges.add(newState); } @Override // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void onSignalingChange(SignalingState newState) { assertEquals(expectedSignalingChanges.remove(), newState); } // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void expectIceConnectionChange(IceConnectionState newState) { expectedIceConnectionChanges.add(newState); } @Override // TODO(bugs.webrtc.org/8491): Remove NoSynchronizedMethodCheck suppression. @SuppressWarnings("NoSynchronizedMethodCheck") public synchronized void onIceConnectionChange(IceConnectionState newState) { // TODO(bemasc): remove once delivery of ICECompleted is reliable // (https://cod