| OLD | NEW |
| 1 /* | 1 /* |
| 2 * libjingle | 2 * libjingle |
| 3 * Copyright 2013 Google Inc. | 3 * Copyright 2013 Google Inc. |
| 4 * | 4 * |
| 5 * Redistribution and use in source and binary forms, with or without | 5 * Redistribution and use in source and binary forms, with or without |
| 6 * modification, are permitted provided that the following conditions are met: | 6 * modification, are permitted provided that the following conditions are met: |
| 7 * | 7 * |
| 8 * 1. Redistributions of source code must retain the above copyright notice, | 8 * 1. Redistributions of source code must retain the above copyright notice, |
| 9 * this list of conditions and the following disclaimer. | 9 * this list of conditions and the following disclaimer. |
| 10 * 2. Redistributions in binary form must reproduce the above copyright notice, | 10 * 2. Redistributions in binary form must reproduce the above copyright notice, |
| (...skipping 30 matching lines...) Expand all Loading... |
| 41 } | 41 } |
| 42 | 42 |
| 43 using webrtc::DataChannelInterface; | 43 using webrtc::DataChannelInterface; |
| 44 using webrtc::FakeConstraints; | 44 using webrtc::FakeConstraints; |
| 45 using webrtc::MediaConstraintsInterface; | 45 using webrtc::MediaConstraintsInterface; |
| 46 using webrtc::MediaStreamInterface; | 46 using webrtc::MediaStreamInterface; |
| 47 using webrtc::PeerConnectionInterface; | 47 using webrtc::PeerConnectionInterface; |
| 48 | 48 |
| 49 namespace { | 49 namespace { |
| 50 | 50 |
| 51 const char kExternalGiceUfrag[] = "1234567890123456"; | |
| 52 const char kExternalGicePwd[] = "123456789012345678901234"; | |
| 53 const size_t kMaxWait = 10000; | 51 const size_t kMaxWait = 10000; |
| 54 | 52 |
| 55 void RemoveLinesFromSdp(const std::string& line_start, | 53 void RemoveLinesFromSdp(const std::string& line_start, |
| 56 std::string* sdp) { | 54 std::string* sdp) { |
| 57 const char kSdpLineEnd[] = "\r\n"; | 55 const char kSdpLineEnd[] = "\r\n"; |
| 58 size_t ssrc_pos = 0; | 56 size_t ssrc_pos = 0; |
| 59 while ((ssrc_pos = sdp->find(line_start, ssrc_pos)) != | 57 while ((ssrc_pos = sdp->find(line_start, ssrc_pos)) != |
| 60 std::string::npos) { | 58 std::string::npos) { |
| 61 size_t end_ssrc = sdp->find(kSdpLineEnd, ssrc_pos); | 59 size_t end_ssrc = sdp->find(kSdpLineEnd, ssrc_pos); |
| 62 sdp->erase(ssrc_pos, end_ssrc - ssrc_pos + strlen(kSdpLineEnd)); | 60 sdp->erase(ssrc_pos, end_ssrc - ssrc_pos + strlen(kSdpLineEnd)); |
| (...skipping 28 matching lines...) Expand all Loading... |
| 91 "a=crypto:1 AES_CM_128_HMAC_SHA1_80 " | 89 "a=crypto:1 AES_CM_128_HMAC_SHA1_80 " |
| 92 "inline:d0RmdmcmVCspeEc3QGZiNWpVLFJhQX1cfHAwJSoj\r\n"; | 90 "inline:d0RmdmcmVCspeEc3QGZiNWpVLFJhQX1cfHAwJSoj\r\n"; |
| 93 const char kDataSdes[] = | 91 const char kDataSdes[] = |
| 94 "a=crypto:1 AES_CM_128_HMAC_SHA1_80 " | 92 "a=crypto:1 AES_CM_128_HMAC_SHA1_80 " |
| 95 "inline:NzB4d1BINUAvLEw6UzF3WSJ+PSdFcGdUJShpX1Zj\r\n"; | 93 "inline:NzB4d1BINUAvLEw6UzF3WSJ+PSdFcGdUJShpX1Zj\r\n"; |
| 96 InjectAfter("a=mid:audio\r\n", kAudioSdes, sdp); | 94 InjectAfter("a=mid:audio\r\n", kAudioSdes, sdp); |
| 97 InjectAfter("a=mid:video\r\n", kVideoSdes, sdp); | 95 InjectAfter("a=mid:video\r\n", kVideoSdes, sdp); |
| 98 InjectAfter("a=mid:data\r\n", kDataSdes, sdp); | 96 InjectAfter("a=mid:data\r\n", kDataSdes, sdp); |
| 99 } | 97 } |
| 100 | 98 |
| 101 void UseGice(std::string* sdp) { | |
| 102 InjectAfter("t=0 0\r\n", "a=ice-options:google-ice\r\n", sdp); | |
| 103 | |
| 104 std::string ufragline = "a=ice-ufrag:"; | |
| 105 std::string pwdline = "a=ice-pwd:"; | |
| 106 RemoveLinesFromSdp(ufragline, sdp); | |
| 107 RemoveLinesFromSdp(pwdline, sdp); | |
| 108 ufragline.append(kExternalGiceUfrag); | |
| 109 ufragline.append("\r\n"); | |
| 110 pwdline.append(kExternalGicePwd); | |
| 111 pwdline.append("\r\n"); | |
| 112 const std::string ufrag_pwd = ufragline + pwdline; | |
| 113 | |
| 114 InjectAfter("a=mid:audio\r\n", ufrag_pwd, sdp); | |
| 115 InjectAfter("a=mid:video\r\n", ufrag_pwd, sdp); | |
| 116 InjectAfter("a=mid:data\r\n", ufrag_pwd, sdp); | |
| 117 } | |
| 118 | |
| 119 void RemoveBundle(std::string* sdp) { | 99 void RemoveBundle(std::string* sdp) { |
| 120 RemoveLinesFromSdp("a=group:BUNDLE", sdp); | 100 RemoveLinesFromSdp("a=group:BUNDLE", sdp); |
| 121 } | 101 } |
| 122 | 102 |
| 123 } // namespace | 103 } // namespace |
| 124 | 104 |
| 125 class PeerConnectionEndToEndTest | 105 class PeerConnectionEndToEndTest |
| 126 : public sigslot::has_slots<>, | 106 : public sigslot::has_slots<>, |
| 127 public testing::Test { | 107 public testing::Test { |
| 128 public: | 108 public: |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 172 void WaitForCallEstablished() { | 152 void WaitForCallEstablished() { |
| 173 caller_->WaitForCallEstablished(); | 153 caller_->WaitForCallEstablished(); |
| 174 callee_->WaitForCallEstablished(); | 154 callee_->WaitForCallEstablished(); |
| 175 } | 155 } |
| 176 | 156 |
| 177 void WaitForConnection() { | 157 void WaitForConnection() { |
| 178 caller_->WaitForConnection(); | 158 caller_->WaitForConnection(); |
| 179 callee_->WaitForConnection(); | 159 callee_->WaitForConnection(); |
| 180 } | 160 } |
| 181 | 161 |
| 182 void SetupLegacySdpConverter() { | |
| 183 caller_->SignalOnSdpCreated.connect( | |
| 184 this, &PeerConnectionEndToEndTest::ConvertToLegacySdp); | |
| 185 callee_->SignalOnSdpCreated.connect( | |
| 186 this, &PeerConnectionEndToEndTest::ConvertToLegacySdp); | |
| 187 } | |
| 188 | |
| 189 void ConvertToLegacySdp(std::string* sdp) { | |
| 190 UseExternalSdes(sdp); | |
| 191 UseGice(sdp); | |
| 192 RemoveBundle(sdp); | |
| 193 LOG(LS_INFO) << "ConvertToLegacySdp: " << *sdp; | |
| 194 } | |
| 195 | |
| 196 void SetupGiceConverter() { | |
| 197 caller_->SignalOnIceCandidateCreated.connect( | |
| 198 this, &PeerConnectionEndToEndTest::AddGiceCredsToCandidate); | |
| 199 callee_->SignalOnIceCandidateCreated.connect( | |
| 200 this, &PeerConnectionEndToEndTest::AddGiceCredsToCandidate); | |
| 201 } | |
| 202 | |
| 203 void AddGiceCredsToCandidate(std::string* sdp) { | |
| 204 std::string gice_creds = " username "; | |
| 205 gice_creds.append(kExternalGiceUfrag); | |
| 206 gice_creds.append(" password "); | |
| 207 gice_creds.append(kExternalGicePwd); | |
| 208 gice_creds.append("\r\n"); | |
| 209 Replace("\r\n", gice_creds, sdp); | |
| 210 LOG(LS_INFO) << "AddGiceCredsToCandidate: " << *sdp; | |
| 211 } | |
| 212 | |
| 213 void OnCallerAddedDataChanel(DataChannelInterface* dc) { | 162 void OnCallerAddedDataChanel(DataChannelInterface* dc) { |
| 214 caller_signaled_data_channels_.push_back(dc); | 163 caller_signaled_data_channels_.push_back(dc); |
| 215 } | 164 } |
| 216 | 165 |
| 217 void OnCalleeAddedDataChannel(DataChannelInterface* dc) { | 166 void OnCalleeAddedDataChannel(DataChannelInterface* dc) { |
| 218 callee_signaled_data_channels_.push_back(dc); | 167 callee_signaled_data_channels_.push_back(dc); |
| 219 } | 168 } |
| 220 | 169 |
| 221 // Tests that |dc1| and |dc2| can send to and receive from each other. | 170 // Tests that |dc1| and |dc2| can send to and receive from each other. |
| 222 void TestDataChannelSendAndReceive( | 171 void TestDataChannelSendAndReceive( |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 274 Negotiate(); | 223 Negotiate(); |
| 275 WaitForCallEstablished(); | 224 WaitForCallEstablished(); |
| 276 } | 225 } |
| 277 | 226 |
| 278 // Disabled per b/14899892 | 227 // Disabled per b/14899892 |
| 279 TEST_F(PeerConnectionEndToEndTest, DISABLED_CallWithLegacySdp) { | 228 TEST_F(PeerConnectionEndToEndTest, DISABLED_CallWithLegacySdp) { |
| 280 FakeConstraints pc_constraints; | 229 FakeConstraints pc_constraints; |
| 281 pc_constraints.AddMandatory(MediaConstraintsInterface::kEnableDtlsSrtp, | 230 pc_constraints.AddMandatory(MediaConstraintsInterface::kEnableDtlsSrtp, |
| 282 false); | 231 false); |
| 283 CreatePcs(&pc_constraints); | 232 CreatePcs(&pc_constraints); |
| 284 SetupLegacySdpConverter(); | |
| 285 SetupGiceConverter(); | |
| 286 GetAndAddUserMedia(); | 233 GetAndAddUserMedia(); |
| 287 Negotiate(); | 234 Negotiate(); |
| 288 WaitForCallEstablished(); | 235 WaitForCallEstablished(); |
| 289 } | 236 } |
| 290 | 237 |
| 291 // Verifies that a DataChannel created before the negotiation can transition to | 238 // Verifies that a DataChannel created before the negotiation can transition to |
| 292 // "OPEN" and transfer data. | 239 // "OPEN" and transfer data. |
| 293 TEST_F(PeerConnectionEndToEndTest, CreateDataChannelBeforeNegotiate) { | 240 TEST_F(PeerConnectionEndToEndTest, CreateDataChannelBeforeNegotiate) { |
| 294 MAYBE_SKIP_TEST(rtc::SSLStreamAdapter::HaveDtlsSrtp); | 241 MAYBE_SKIP_TEST(rtc::SSLStreamAdapter::HaveDtlsSrtp); |
| 295 | 242 |
| (...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 410 | 357 |
| 411 caller_dc_1->Send(webrtc::DataBuffer(message_1)); | 358 caller_dc_1->Send(webrtc::DataBuffer(message_1)); |
| 412 EXPECT_EQ_WAIT(message_1, dc_1_observer->last_message(), kMaxWait); | 359 EXPECT_EQ_WAIT(message_1, dc_1_observer->last_message(), kMaxWait); |
| 413 | 360 |
| 414 caller_dc_2->Send(webrtc::DataBuffer(message_2)); | 361 caller_dc_2->Send(webrtc::DataBuffer(message_2)); |
| 415 EXPECT_EQ_WAIT(message_2, dc_2_observer->last_message(), kMaxWait); | 362 EXPECT_EQ_WAIT(message_2, dc_2_observer->last_message(), kMaxWait); |
| 416 | 363 |
| 417 EXPECT_EQ(1U, dc_1_observer->received_message_count()); | 364 EXPECT_EQ(1U, dc_1_observer->received_message_count()); |
| 418 EXPECT_EQ(1U, dc_2_observer->received_message_count()); | 365 EXPECT_EQ(1U, dc_2_observer->received_message_count()); |
| 419 } | 366 } |
| OLD | NEW |