| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2012 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 1771 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1782 MAYBE_SKIP_TEST(rtc::SSLStreamAdapter::HaveDtlsSrtp); | 1782 MAYBE_SKIP_TEST(rtc::SSLStreamAdapter::HaveDtlsSrtp); |
| 1783 FakeConstraints setup_constraints; | 1783 FakeConstraints setup_constraints; |
| 1784 setup_constraints.AddMandatory(MediaConstraintsInterface::kEnableDtlsSrtp, | 1784 setup_constraints.AddMandatory(MediaConstraintsInterface::kEnableDtlsSrtp, |
| 1785 true); | 1785 true); |
| 1786 ASSERT_TRUE(CreateTestClients(&setup_constraints, &setup_constraints)); | 1786 ASSERT_TRUE(CreateTestClients(&setup_constraints, &setup_constraints)); |
| 1787 receiving_client()->RemoveSdesCryptoFromReceivedSdp(true); | 1787 receiving_client()->RemoveSdesCryptoFromReceivedSdp(true); |
| 1788 LocalP2PTest(); | 1788 LocalP2PTest(); |
| 1789 VerifyRenderedAspectRatio(640, 480); | 1789 VerifyRenderedAspectRatio(640, 480); |
| 1790 } | 1790 } |
| 1791 | 1791 |
| 1792 #ifdef HAVE_SCTP |
| 1792 // This test verifies that the negotiation will succeed with data channel only | 1793 // This test verifies that the negotiation will succeed with data channel only |
| 1793 // in max-bundle mode. | 1794 // in max-bundle mode. |
| 1794 TEST_F(P2PTestConductor, LocalP2PTestOfferDataChannelOnly) { | 1795 TEST_F(P2PTestConductor, LocalP2PTestOfferDataChannelOnly) { |
| 1795 webrtc::PeerConnectionInterface::RTCConfiguration rtc_config; | 1796 webrtc::PeerConnectionInterface::RTCConfiguration rtc_config; |
| 1796 rtc_config.bundle_policy = | 1797 rtc_config.bundle_policy = |
| 1797 webrtc::PeerConnectionInterface::kBundlePolicyMaxBundle; | 1798 webrtc::PeerConnectionInterface::kBundlePolicyMaxBundle; |
| 1798 ASSERT_TRUE(CreateTestClients(rtc_config, rtc_config)); | 1799 ASSERT_TRUE(CreateTestClients(rtc_config, rtc_config)); |
| 1799 initializing_client()->CreateDataChannel(); | 1800 initializing_client()->CreateDataChannel(); |
| 1800 initializing_client()->Negotiate(); | 1801 initializing_client()->Negotiate(); |
| 1801 } | 1802 } |
| 1803 #endif |
| 1802 | 1804 |
| 1803 // This test sets up a Jsep call between two parties, and the callee only | 1805 // This test sets up a Jsep call between two parties, and the callee only |
| 1804 // accept to receive video. | 1806 // accept to receive video. |
| 1805 TEST_F(P2PTestConductor, LocalP2PTestAnswerVideo) { | 1807 TEST_F(P2PTestConductor, LocalP2PTestAnswerVideo) { |
| 1806 ASSERT_TRUE(CreateTestClients()); | 1808 ASSERT_TRUE(CreateTestClients()); |
| 1807 receiving_client()->SetReceiveAudioVideo(false, true); | 1809 receiving_client()->SetReceiveAudioVideo(false, true); |
| 1808 LocalP2PTest(); | 1810 LocalP2PTest(); |
| 1809 } | 1811 } |
| 1810 | 1812 |
| 1811 // This test sets up a Jsep call between two parties, and the callee only | 1813 // This test sets up a Jsep call between two parties, and the callee only |
| (...skipping 269 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2081 EXPECT_EQ_WAIT(data, initializing_client()->data_observer()->last_message(), | 2083 EXPECT_EQ_WAIT(data, initializing_client()->data_observer()->last_message(), |
| 2082 kMaxWaitMs); | 2084 kMaxWaitMs); |
| 2083 | 2085 |
| 2084 receiving_client()->data_channel()->Close(); | 2086 receiving_client()->data_channel()->Close(); |
| 2085 // Send new offer and answer. | 2087 // Send new offer and answer. |
| 2086 receiving_client()->Negotiate(); | 2088 receiving_client()->Negotiate(); |
| 2087 EXPECT_FALSE(initializing_client()->data_observer()->IsOpen()); | 2089 EXPECT_FALSE(initializing_client()->data_observer()->IsOpen()); |
| 2088 EXPECT_FALSE(receiving_client()->data_observer()->IsOpen()); | 2090 EXPECT_FALSE(receiving_client()->data_observer()->IsOpen()); |
| 2089 } | 2091 } |
| 2090 | 2092 |
| 2093 #ifdef HAVE_SCTP |
| 2091 // This test sets up a call between two parties with audio, video and an SCTP | 2094 // This test sets up a call between two parties with audio, video and an SCTP |
| 2092 // data channel. | 2095 // data channel. |
| 2093 TEST_F(P2PTestConductor, LocalP2PTestSctpDataChannel) { | 2096 TEST_F(P2PTestConductor, LocalP2PTestSctpDataChannel) { |
| 2094 ASSERT_TRUE(CreateTestClients()); | 2097 ASSERT_TRUE(CreateTestClients()); |
| 2095 initializing_client()->CreateDataChannel(); | 2098 initializing_client()->CreateDataChannel(); |
| 2096 LocalP2PTest(); | 2099 LocalP2PTest(); |
| 2097 ASSERT_TRUE(initializing_client()->data_channel() != nullptr); | 2100 ASSERT_TRUE(initializing_client()->data_channel() != nullptr); |
| 2098 EXPECT_TRUE_WAIT(receiving_client()->data_channel() != nullptr, kMaxWaitMs); | 2101 EXPECT_TRUE_WAIT(receiving_client()->data_channel() != nullptr, kMaxWaitMs); |
| 2099 EXPECT_TRUE_WAIT(initializing_client()->data_observer()->IsOpen(), | 2102 EXPECT_TRUE_WAIT(initializing_client()->data_observer()->IsOpen(), |
| 2100 kMaxWaitMs); | 2103 kMaxWaitMs); |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2168 std::sort(receiving_client_received_messages.begin(), | 2171 std::sort(receiving_client_received_messages.begin(), |
| 2169 receiving_client_received_messages.end()); | 2172 receiving_client_received_messages.end()); |
| 2170 EXPECT_EQ(sent_messages, initializing_client_received_messages); | 2173 EXPECT_EQ(sent_messages, initializing_client_received_messages); |
| 2171 EXPECT_EQ(sent_messages, receiving_client_received_messages); | 2174 EXPECT_EQ(sent_messages, receiving_client_received_messages); |
| 2172 | 2175 |
| 2173 receiving_client()->data_channel()->Close(); | 2176 receiving_client()->data_channel()->Close(); |
| 2174 EXPECT_TRUE_WAIT(!initializing_client()->data_observer()->IsOpen(), | 2177 EXPECT_TRUE_WAIT(!initializing_client()->data_observer()->IsOpen(), |
| 2175 kMaxWaitMs); | 2178 kMaxWaitMs); |
| 2176 EXPECT_TRUE_WAIT(!receiving_client()->data_observer()->IsOpen(), kMaxWaitMs); | 2179 EXPECT_TRUE_WAIT(!receiving_client()->data_observer()->IsOpen(), kMaxWaitMs); |
| 2177 } | 2180 } |
| 2181 #endif // HAVE_SCTP |
| 2178 | 2182 |
| 2179 // This test sets up a call between two parties and creates a data channel. | 2183 // This test sets up a call between two parties and creates a data channel. |
| 2180 // The test tests that received data is buffered unless an observer has been | 2184 // The test tests that received data is buffered unless an observer has been |
| 2181 // registered. | 2185 // registered. |
| 2182 // Rtp data channels can receive data before the underlying | 2186 // Rtp data channels can receive data before the underlying |
| 2183 // transport has detected that a channel is writable and thus data can be | 2187 // transport has detected that a channel is writable and thus data can be |
| 2184 // received before the data channel state changes to open. That is hard to test | 2188 // received before the data channel state changes to open. That is hard to test |
| 2185 // but the same buffering is used in that case. | 2189 // but the same buffering is used in that case. |
| 2186 TEST_F(P2PTestConductor, RegisterDataChannelObserver) { | 2190 TEST_F(P2PTestConductor, RegisterDataChannelObserver) { |
| 2187 FakeConstraints setup_constraints; | 2191 FakeConstraints setup_constraints; |
| (...skipping 609 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2797 server.urls.push_back("turn:hostname2"); | 2801 server.urls.push_back("turn:hostname2"); |
| 2798 servers.push_back(server); | 2802 servers.push_back(server); |
| 2799 EXPECT_TRUE(webrtc::ParseIceServers(servers, &stun_servers_, &turn_servers_)); | 2803 EXPECT_TRUE(webrtc::ParseIceServers(servers, &stun_servers_, &turn_servers_)); |
| 2800 EXPECT_EQ(2U, turn_servers_.size()); | 2804 EXPECT_EQ(2U, turn_servers_.size()); |
| 2801 EXPECT_NE(turn_servers_[0].priority, turn_servers_[1].priority); | 2805 EXPECT_NE(turn_servers_[0].priority, turn_servers_[1].priority); |
| 2802 } | 2806 } |
| 2803 | 2807 |
| 2804 #endif // if !defined(THREAD_SANITIZER) | 2808 #endif // if !defined(THREAD_SANITIZER) |
| 2805 | 2809 |
| 2806 } // namespace | 2810 } // namespace |
| OLD | NEW |