| OLD | NEW |
| 1 /* | 1 /* |
| 2 * libjingle | 2 * libjingle |
| 3 * Copyright 2012 Google Inc. | 3 * Copyright 2012 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 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 436 default: | 436 default: |
| 437 ADD_FAILURE(); | 437 ADD_FAILURE(); |
| 438 break; | 438 break; |
| 439 } | 439 } |
| 440 } | 440 } |
| 441 | 441 |
| 442 MediaStreamInterface* RemoteStream(const std::string& label) { | 442 MediaStreamInterface* RemoteStream(const std::string& label) { |
| 443 return remote_streams_->find(label); | 443 return remote_streams_->find(label); |
| 444 } | 444 } |
| 445 StreamCollectionInterface* remote_streams() const { return remote_streams_; } | 445 StreamCollectionInterface* remote_streams() const { return remote_streams_; } |
| 446 virtual void OnAddStream(MediaStreamInterface* stream) { | 446 void OnAddStream(MediaStreamInterface* stream) override { |
| 447 last_added_stream_ = stream; | 447 last_added_stream_ = stream; |
| 448 remote_streams_->AddStream(stream); | 448 remote_streams_->AddStream(stream); |
| 449 } | 449 } |
| 450 virtual void OnRemoveStream(MediaStreamInterface* stream) { | 450 void OnRemoveStream(MediaStreamInterface* stream) override { |
| 451 last_removed_stream_ = stream; | 451 last_removed_stream_ = stream; |
| 452 remote_streams_->RemoveStream(stream); | 452 remote_streams_->RemoveStream(stream); |
| 453 } | 453 } |
| 454 virtual void OnRenegotiationNeeded() { | 454 void OnRenegotiationNeeded() override { renegotiation_needed_ = true; } |
| 455 renegotiation_needed_ = true; | 455 void OnDataChannel(DataChannelInterface* data_channel) override { |
| 456 } | |
| 457 virtual void OnDataChannel(DataChannelInterface* data_channel) { | |
| 458 last_datachannel_ = data_channel; | 456 last_datachannel_ = data_channel; |
| 459 } | 457 } |
| 460 | 458 |
| 461 virtual void OnIceConnectionChange( | 459 void OnIceConnectionChange( |
| 462 PeerConnectionInterface::IceConnectionState new_state) { | 460 PeerConnectionInterface::IceConnectionState new_state) override { |
| 463 EXPECT_EQ(pc_->ice_connection_state(), new_state); | 461 EXPECT_EQ(pc_->ice_connection_state(), new_state); |
| 464 } | 462 } |
| 465 virtual void OnIceGatheringChange( | 463 void OnIceGatheringChange( |
| 466 PeerConnectionInterface::IceGatheringState new_state) { | 464 PeerConnectionInterface::IceGatheringState new_state) override { |
| 467 EXPECT_EQ(pc_->ice_gathering_state(), new_state); | 465 EXPECT_EQ(pc_->ice_gathering_state(), new_state); |
| 466 ice_complete_ = new_state == PeerConnectionInterface::kIceGatheringComplete; |
| 468 } | 467 } |
| 469 virtual void OnIceCandidate(const webrtc::IceCandidateInterface* candidate) { | 468 void OnIceCandidate(const webrtc::IceCandidateInterface* candidate) override { |
| 470 EXPECT_NE(PeerConnectionInterface::kIceGatheringNew, | 469 EXPECT_NE(PeerConnectionInterface::kIceGatheringNew, |
| 471 pc_->ice_gathering_state()); | 470 pc_->ice_gathering_state()); |
| 472 | 471 |
| 473 std::string sdp; | 472 std::string sdp; |
| 474 EXPECT_TRUE(candidate->ToString(&sdp)); | 473 EXPECT_TRUE(candidate->ToString(&sdp)); |
| 475 EXPECT_LT(0u, sdp.size()); | 474 EXPECT_LT(0u, sdp.size()); |
| 476 last_candidate_.reset(webrtc::CreateIceCandidate(candidate->sdp_mid(), | 475 last_candidate_.reset(webrtc::CreateIceCandidate(candidate->sdp_mid(), |
| 477 candidate->sdp_mline_index(), sdp, NULL)); | 476 candidate->sdp_mline_index(), sdp, NULL)); |
| 478 EXPECT_TRUE(last_candidate_.get() != NULL); | 477 EXPECT_TRUE(last_candidate_.get() != NULL); |
| 479 } | 478 } |
| 480 // TODO(bemasc): Remove this once callers transition to OnSignalingChange. | |
| 481 virtual void OnIceComplete() { | |
| 482 ice_complete_ = true; | |
| 483 // OnIceGatheringChange(IceGatheringCompleted) and OnIceComplete() should | |
| 484 // be called approximately simultaneously. For ease of testing, this | |
| 485 // check additionally requires that they be called in the above order. | |
| 486 EXPECT_EQ(PeerConnectionInterface::kIceGatheringComplete, | |
| 487 pc_->ice_gathering_state()); | |
| 488 } | |
| 489 | 479 |
| 490 // Returns the label of the last added stream. | 480 // Returns the label of the last added stream. |
| 491 // Empty string if no stream have been added. | 481 // Empty string if no stream have been added. |
| 492 std::string GetLastAddedStreamLabel() { | 482 std::string GetLastAddedStreamLabel() { |
| 493 if (last_added_stream_.get()) | 483 if (last_added_stream_.get()) |
| 494 return last_added_stream_->label(); | 484 return last_added_stream_->label(); |
| 495 return ""; | 485 return ""; |
| 496 } | 486 } |
| 497 std::string GetLastRemovedStreamLabel() { | 487 std::string GetLastRemovedStreamLabel() { |
| 498 if (last_removed_stream_.get()) | 488 if (last_removed_stream_.get()) |
| (...skipping 2017 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2516 FakeConstraints updated_answer_c; | 2506 FakeConstraints updated_answer_c; |
| 2517 answer_c.SetMandatoryReceiveAudio(false); | 2507 answer_c.SetMandatoryReceiveAudio(false); |
| 2518 answer_c.SetMandatoryReceiveVideo(false); | 2508 answer_c.SetMandatoryReceiveVideo(false); |
| 2519 | 2509 |
| 2520 cricket::MediaSessionOptions updated_answer_options; | 2510 cricket::MediaSessionOptions updated_answer_options; |
| 2521 EXPECT_TRUE( | 2511 EXPECT_TRUE( |
| 2522 ParseConstraintsForAnswer(&updated_answer_c, &updated_answer_options)); | 2512 ParseConstraintsForAnswer(&updated_answer_c, &updated_answer_options)); |
| 2523 EXPECT_TRUE(updated_answer_options.has_audio()); | 2513 EXPECT_TRUE(updated_answer_options.has_audio()); |
| 2524 EXPECT_TRUE(updated_answer_options.has_video()); | 2514 EXPECT_TRUE(updated_answer_options.has_video()); |
| 2525 } | 2515 } |
| OLD | NEW |