10e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/* 20e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * libjingle SCTP 30e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * Copyright 2013 Google Inc 40e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * 50e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * Redistribution and use in source and binary forms, with or without 60e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * modification, are permitted provided that the following conditions are met: 70e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * 80e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * 1. Redistributions of source code must retain the above copyright notice, 90e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * this list of conditions and the following disclaimer. 100e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * 2. Redistributions in binary form must reproduce the above copyright notice, 110e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * this list of conditions and the following disclaimer in the documentation 120e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * and/or other materials provided with the distribution. 130e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * 3. The name of the author may not be used to endorse or promote products 140e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * derived from this software without specific prior written permission. 150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * 160e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 170e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 180e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 230e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 240e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 250e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 260e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org */ 270e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 280e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org#include <errno.h> 290e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org#include <stdarg.h> 300e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org#include <stdio.h> 310e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org#include <string> 322a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org#include <vector> 330e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 34cf81adffe15fa8ea0f333432e41f6d504148f18abuildbot@webrtc.org#include "talk/media/base/constants.h" 35cf81adffe15fa8ea0f333432e41f6d504148f18abuildbot@webrtc.org#include "talk/media/base/mediachannel.h" 36cf81adffe15fa8ea0f333432e41f6d504148f18abuildbot@webrtc.org#include "talk/media/sctp/sctpdataengine.h" 372a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/bind.h" 382a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/buffer.h" 392a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/criticalsection.h" 402a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/gunit.h" 412a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/helpers.h" 422a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/messagehandler.h" 432a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/messagequeue.h" 442a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/scoped_ptr.h" 452a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/ssladapter.h" 462a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/thread.h" 470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 481a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com#ifdef HAVE_NSS_SSL_H 491a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com// TODO(thorcarpenter): Remove after webrtc switches over to BoringSSL. 501a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com#include "webrtc/base/nssstreamadapter.h" 511a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com#endif // HAVE_NSS_SSL_H 521a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com 530e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgenum { 540e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org MSG_PACKET = 1, 550e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org}; 560e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 570e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Fake NetworkInterface that sends/receives sctp packets. The one in 580e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// talk/media/base/fakenetworkinterface.h only works with rtp/rtcp. 590e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgclass SctpFakeNetworkInterface : public cricket::MediaChannel::NetworkInterface, 602a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org public rtc::MessageHandler { 610e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org public: 622a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org explicit SctpFakeNetworkInterface(rtc::Thread* thread) 630e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org : thread_(thread), 640e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org dest_(NULL) { 650e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 660e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 670e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org void SetDestination(cricket::DataMediaChannel* dest) { dest_ = dest; } 680e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 690e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org protected: 700e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Called to send raw packet down the wire (e.g. SCTP an packet). 712a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org virtual bool SendPacket(rtc::Buffer* packet, 722a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::DiffServCodePoint dscp) { 730e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_VERBOSE) << "SctpFakeNetworkInterface::SendPacket"; 740e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 750e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // TODO(ldixon): Can/should we use Buffer.TransferTo here? 760e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Note: this assignment does a deep copy of data from packet. 77c30ce01178b62054138f82dc81232d3fa2ee8e29pbos@webrtc.org rtc::Buffer* buffer = new rtc::Buffer(packet->data(), packet->length()); 782a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org thread_->Post(this, MSG_PACKET, rtc::WrapMessageData(buffer)); 790e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_VERBOSE) << "SctpFakeNetworkInterface::SendPacket, Posted message."; 800e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 810e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 820e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 830e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Called when a raw packet has been recieved. This passes the data to the 840e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // code that will interpret the packet. e.g. to get the content payload from 850e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // an SCTP packet. 862a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org virtual void OnMessage(rtc::Message* msg) { 870e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_VERBOSE) << "SctpFakeNetworkInterface::OnMessage"; 882a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<rtc::Buffer> buffer( 892a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org static_cast<rtc::TypedMessageData<rtc::Buffer*>*>( 90121ec58e782ab350f3d1319381d6782f35b27addjiayl@webrtc.org msg->pdata)->data()); 910e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (dest_) { 922a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org dest_->OnPacketReceived(buffer.get(), rtc::PacketTime()); 930e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 94121ec58e782ab350f3d1319381d6782f35b27addjiayl@webrtc.org delete msg->pdata; 950e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 960e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 970e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Unsupported functions required to exist by NetworkInterface. 980e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // TODO(ldixon): Refactor parent NetworkInterface class so these are not 990e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // required. They are RTC specific and should be in an appropriate subclass. 1002a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org virtual bool SendRtcp(rtc::Buffer* packet, 1012a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::DiffServCodePoint dscp) { 1020e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_WARNING) << "Unsupported: SctpFakeNetworkInterface::SendRtcp."; 1030e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 1040e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1052a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org virtual int SetOption(SocketType type, rtc::Socket::Option opt, 1060e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org int option) { 1070e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_WARNING) << "Unsupported: SctpFakeNetworkInterface::SetOption."; 1080e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return 0; 1090e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1102a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org virtual void SetDefaultDSCPCode(rtc::DiffServCodePoint dscp) { 111391247d05a663265807c400947ab6eb01ae3d690mallinath@webrtc.org LOG(LS_WARNING) << "Unsupported: SctpFakeNetworkInterface::SetOption."; 112391247d05a663265807c400947ab6eb01ae3d690mallinath@webrtc.org } 1130e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1140e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org private: 1150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Not owned by this class. 1162a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* thread_; 1170e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::DataMediaChannel* dest_; 1180e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org}; 1190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// This is essentially a buffer to hold recieved data. It stores only the last 1210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// received data. Calling OnDataReceived twice overwrites old data with the 1220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// newer one. 1230e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// TODO(ldixon): Implement constraints, and allow new data to be added to old 1240e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// instead of replacing it. 1250e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgclass SctpFakeDataReceiver : public sigslot::has_slots<> { 1260e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org public: 1270e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org SctpFakeDataReceiver() : received_(false) {} 1280e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1290e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org void Clear() { 1300e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org received_ = false; 1310e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org last_data_ = ""; 1320e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org last_params_ = cricket::ReceiveDataParams(); 1330e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1340e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1350e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org virtual void OnDataReceived(const cricket::ReceiveDataParams& params, 1360e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org const char* data, size_t length) { 1370e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org received_ = true; 1380e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org last_data_ = std::string(data, length); 1390e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org last_params_ = params; 1400e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1410e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1420e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool received() const { return received_; } 1430e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org std::string last_data() const { return last_data_; } 1440e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::ReceiveDataParams last_params() const { return last_params_; } 1450e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1460e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org private: 1470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool received_; 1480e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org std::string last_data_; 1490e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::ReceiveDataParams last_params_; 1500e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org}; 1510e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 152d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.orgclass SignalReadyToSendObserver : public sigslot::has_slots<> { 153d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org public: 154d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SignalReadyToSendObserver() : signaled_(false), writable_(false) {} 155d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 156d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org void OnSignaled(bool writable) { 157d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org signaled_ = true; 158d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org writable_ = writable; 159d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org } 160d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 161d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org bool IsSignaled(bool writable) { 162d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org return signaled_ && (writable_ == writable); 163d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org } 164d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 165d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org private: 166d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org bool signaled_; 167d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org bool writable_; 168d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org}; 169d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 1702a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.orgclass SignalChannelClosedObserver : public sigslot::has_slots<> { 1712a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org public: 1722a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SignalChannelClosedObserver() {} 1732a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org void BindSelf(cricket::SctpDataMediaChannel* channel) { 174f365c83eeda1a21af3740b70798f6ca65c7bc182buildbot@webrtc.org channel->SignalStreamClosedRemotely.connect( 1752a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org this, &SignalChannelClosedObserver::OnStreamClosed); 1762a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 177f365c83eeda1a21af3740b70798f6ca65c7bc182buildbot@webrtc.org void OnStreamClosed(uint32 stream) { 1782a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org streams_.push_back(stream); 1792a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 1802a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 181f365c83eeda1a21af3740b70798f6ca65c7bc182buildbot@webrtc.org int StreamCloseCount(uint32 stream) { 1822a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org return std::count(streams_.begin(), streams_.end(), stream); 1832a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 1842a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 185f365c83eeda1a21af3740b70798f6ca65c7bc182buildbot@webrtc.org bool WasStreamClosed(uint32 stream) { 1862a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org return std::find(streams_.begin(), streams_.end(), stream) 1872a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org != streams_.end(); 1882a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 1892a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 1902a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org private: 191f365c83eeda1a21af3740b70798f6ca65c7bc182buildbot@webrtc.org std::vector<uint32> streams_; 1922a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org}; 1932a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 1942a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.orgclass SignalChannelClosedReopener : public sigslot::has_slots<> { 1952a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org public: 1962a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SignalChannelClosedReopener(cricket::SctpDataMediaChannel* channel, 1972a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SctpDataMediaChannel* peer) 1982a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org : channel_(channel), peer_(peer) {} 1992a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 2002a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org void OnStreamClosed(int stream) { 2012a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::StreamParams p(cricket::StreamParams::CreateLegacy(stream)); 2022a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel_->AddSendStream(p); 2032a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel_->AddRecvStream(p); 2042a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org peer_->AddSendStream(p); 2052a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org peer_->AddRecvStream(p); 2062a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org streams_.push_back(stream); 2072a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 2082a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 2092a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org int StreamCloseCount(int stream) { 2102a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org return std::count(streams_.begin(), streams_.end(), stream); 2112a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 2122a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 2132a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org private: 2142a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SctpDataMediaChannel* channel_; 2152a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SctpDataMediaChannel* peer_; 2162a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org std::vector<int> streams_; 2172a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org}; 2182a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 2190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// SCTP Data Engine testing framework. 220cc712021a90cc93a68b4e65930cd0a0ad0a88d4ewu@webrtc.orgclass SctpDataMediaChannelTest : public testing::Test, 221cc712021a90cc93a68b4e65930cd0a0ad0a88d4ewu@webrtc.org public sigslot::has_slots<> { 2220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org protected: 22313a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org // usrsctp uses the NSS random number generator on non-Android platforms, 22413a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org // so we need to initialize SSL. 22513a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org static void SetUpTestCase() { 2261a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com#ifdef HAVE_NSS_SSL_H 2271a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com // TODO(thorcarpenter): Remove after webrtc switches over to BoringSSL. 2281a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com if (!rtc::NSSContext::InitializeSSL(NULL)) { 2291a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com LOG(LS_WARNING) << "Unabled to initialize NSS."; 2301a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com } 2311a6b25ecc4c1c0af85cf879348cf8c965f3edf07thorcarpenter@google.com#endif // HAVE_NSS_SSL_H 2322a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::InitializeSSL(); 23313a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org } 23413a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org 23513a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org static void TearDownTestCase() { 2362a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::CleanupSSL(); 23713a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org } 23813a42bcb8b909faef285ec36b59740e5696a2295jiayl@webrtc.org 2390e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org virtual void SetUp() { 2400e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org engine_.reset(new cricket::SctpDataEngine()); 2410e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2420e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 243d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org void SetupConnectedChannels() { 2442a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org net1_.reset(new SctpFakeNetworkInterface(rtc::Thread::Current())); 2452a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org net2_.reset(new SctpFakeNetworkInterface(rtc::Thread::Current())); 246d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org recv1_.reset(new SctpFakeDataReceiver()); 247d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org recv2_.reset(new SctpFakeDataReceiver()); 248d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan1_.reset(CreateChannel(net1_.get(), recv1_.get())); 249d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan1_->set_debug_name("chan1/connector"); 250d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan2_.reset(CreateChannel(net2_.get(), recv2_.get())); 251d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan2_->set_debug_name("chan2/listener"); 252d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // Setup two connected channels ready to send and receive. 253d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org net1_->SetDestination(chan2_.get()); 254d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org net2_->SetDestination(chan1_.get()); 255d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 256d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org LOG(LS_VERBOSE) << "Channel setup ----------------------------- "; 2572a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org AddStream(1); 2582a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org AddStream(2); 259d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 260d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org LOG(LS_VERBOSE) << "Connect the channels -----------------------------"; 261d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // chan1 wants to setup a data connection. 262d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan1_->SetReceive(true); 263d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // chan1 will have sent chan2 a request to setup a data connection. After 264d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // chan2 accepts the offer, chan2 connects to chan1 with the following. 265d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan2_->SetReceive(true); 266d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan2_->SetSend(true); 267d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // Makes sure that network packets are delivered and simulates a 268d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // deterministic and realistic small timing delay between the SetSend calls. 269d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org ProcessMessagesUntilIdle(); 270d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 271d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // chan1 and chan2 are now connected so chan1 enables sending to complete 272d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org // the creation of the connection. 273d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org chan1_->SetSend(true); 274d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org } 275d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 2762a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org virtual void TearDown() { 2772a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel1()->SetSend(false); 2782a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel2()->SetSend(false); 279c30ce01178b62054138f82dc81232d3fa2ee8e29pbos@webrtc.org 280c30ce01178b62054138f82dc81232d3fa2ee8e29pbos@webrtc.org // Process messages until idle to prevent a sent packet from being dropped 281c30ce01178b62054138f82dc81232d3fa2ee8e29pbos@webrtc.org // and causing memory leaks (not being deleted by the receiver). 282c30ce01178b62054138f82dc81232d3fa2ee8e29pbos@webrtc.org ProcessMessagesUntilIdle(); 2832a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 2842a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 2852a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org void AddStream(int ssrc) { 2862a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::StreamParams p(cricket::StreamParams::CreateLegacy(ssrc)); 2872a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan1_->AddSendStream(p); 2882a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan1_->AddRecvStream(p); 2892a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan2_->AddSendStream(p); 2902a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan2_->AddRecvStream(p); 2912a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org } 2922a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 2930e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::SctpDataMediaChannel* CreateChannel( 2942a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SctpFakeNetworkInterface* net, SctpFakeDataReceiver* recv) { 2950e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::SctpDataMediaChannel* channel = 2960e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org static_cast<cricket::SctpDataMediaChannel*>(engine_->CreateChannel( 2970e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::DCT_SCTP)); 2980e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org channel->SetInterface(net); 2990e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // When data is received, pass it to the SctpFakeDataReceiver. 3000e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org channel->SignalDataReceived.connect( 3010e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org recv, &SctpFakeDataReceiver::OnDataReceived); 3020e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return channel; 3030e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3040e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3050e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool SendData(cricket::SctpDataMediaChannel* chan, uint32 ssrc, 3060e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org const std::string& msg, 3070e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::SendDataResult* result) { 3080e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::SendDataParams params; 3090e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org params.ssrc = ssrc; 3108485ec698cd13d65354e2f81132b5763a3d216a4henrika@webrtc.org 3112a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org return chan->SendData(params, rtc::Buffer( 312d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org &msg[0], msg.length()), result); 3130e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3140e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool ReceivedData(const SctpFakeDataReceiver* recv, uint32 ssrc, 3160e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org const std::string& msg ) { 3170e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return (recv->received() && 3180e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org recv->last_params().ssrc == ssrc && 3190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org recv->last_data() == msg); 3200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool ProcessMessagesUntilIdle() { 3232a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* thread = rtc::Thread::Current(); 3240e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org while (!thread->empty()) { 3252a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Message msg; 3262a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org if (thread->Get(&msg, rtc::kForever)) { 3270e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org thread->Dispatch(&msg); 3280e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3290e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3300e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return !thread->IsQuitting(); 3310e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3320e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 333d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org cricket::SctpDataMediaChannel* channel1() { return chan1_.get(); } 334d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org cricket::SctpDataMediaChannel* channel2() { return chan2_.get(); } 335d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SctpFakeDataReceiver* receiver1() { return recv1_.get(); } 336d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SctpFakeDataReceiver* receiver2() { return recv2_.get(); } 337d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 3380e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org private: 3392a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<cricket::SctpDataEngine> engine_; 3402a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<SctpFakeNetworkInterface> net1_; 3412a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<SctpFakeNetworkInterface> net2_; 3422a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<SctpFakeDataReceiver> recv1_; 3432a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<SctpFakeDataReceiver> recv2_; 3442a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<cricket::SctpDataMediaChannel> chan1_; 3452a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<cricket::SctpDataMediaChannel> chan2_; 3460e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org}; 3470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 348d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org// Verifies that SignalReadyToSend is fired. 349d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.orgTEST_F(SctpDataMediaChannelTest, SignalReadyToSend) { 350d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SetupConnectedChannels(); 351d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 352d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SignalReadyToSendObserver signal_observer_1; 353d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SignalReadyToSendObserver signal_observer_2; 354d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 355d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org channel1()->SignalReadyToSend.connect(&signal_observer_1, 356d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org &SignalReadyToSendObserver::OnSignaled); 357d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org channel2()->SignalReadyToSend.connect(&signal_observer_2, 358d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org &SignalReadyToSendObserver::OnSignaled); 359d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 360d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org cricket::SendDataResult result; 361d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hello?", &result)); 362d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 363d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hello?"), 1000); 364d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org ASSERT_TRUE(SendData(channel2(), 2, "hi chan1", &result)); 365d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 366d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver1(), 2, "hi chan1"), 1000); 367d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 368d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_TRUE_WAIT(signal_observer_1.IsSignaled(true), 1000); 369d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_TRUE_WAIT(signal_observer_2.IsSignaled(true), 1000); 370d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org} 371d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org 3720e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgTEST_F(SctpDataMediaChannelTest, SendData) { 373d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org SetupConnectedChannels(); 3740e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3750e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org cricket::SendDataResult result; 3760e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_VERBOSE) << "chan1 sending: 'hello?' -----------------------------"; 377d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hello?", &result)); 3780e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 379d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hello?"), 1000); 380d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org LOG(LS_VERBOSE) << "recv2.received=" << receiver2()->received() 381d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv2.last_params.ssrc=" 382d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org << receiver2()->last_params().ssrc 383d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv2.last_params.timestamp=" 384d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org << receiver2()->last_params().ssrc 385d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv2.last_params.seq_num=" 386d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org << receiver2()->last_params().seq_num 387d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv2.last_data=" << receiver2()->last_data(); 3880e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3890e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_VERBOSE) << "chan2 sending: 'hi chan1' -----------------------------"; 390d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org ASSERT_TRUE(SendData(channel2(), 2, "hi chan1", &result)); 3910e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 392d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver1(), 2, "hi chan1"), 1000); 393d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org LOG(LS_VERBOSE) << "recv1.received=" << receiver1()->received() 394d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv1.last_params.ssrc=" 395d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org << receiver1()->last_params().ssrc 396d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv1.last_params.timestamp=" 397d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org << receiver1()->last_params().ssrc 398d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv1.last_params.seq_num=" 399d156f12e9ee96258b7b79d0e3d8ddab6b4b87fbbwu@webrtc.org << receiver1()->last_params().seq_num 400d19ccc188174c1154987ce2512be1bc64905a3bcjiayl@webrtc.org << ", recv1.last_data=" << receiver1()->last_data(); 4010e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 402cc712021a90cc93a68b4e65930cd0a0ad0a88d4ewu@webrtc.org 403a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org// Sends a lot of large messages at once and verifies SDR_BLOCK is returned. 404a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.orgTEST_F(SctpDataMediaChannelTest, SendDataBlocked) { 405a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org SetupConnectedChannels(); 406a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org 407a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org cricket::SendDataResult result; 408a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org cricket::SendDataParams params; 409a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org params.ssrc = 1; 410a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org 411a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org std::vector<char> buffer(1024 * 64, 0); 412a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org 413a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org for (size_t i = 0; i < 100; ++i) { 414a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org channel1()->SendData( 4152a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org params, rtc::Buffer(&buffer[0], buffer.size()), &result); 416a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org if (result == cricket::SDR_BLOCK) 417a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org break; 418a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org } 419a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org 420a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org EXPECT_EQ(cricket::SDR_BLOCK, result); 421a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org} 422a7f7834eb84ba9551f91eec23dfa26a211bb93c7jiayl@webrtc.org 4232a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.orgTEST_F(SctpDataMediaChannelTest, ClosesRemoteStream) { 4242a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SetupConnectedChannels(); 4252a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SignalChannelClosedObserver chan_1_sig_receiver, chan_2_sig_receiver; 4262a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_1_sig_receiver.BindSelf(channel1()); 4272a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_2_sig_receiver.BindSelf(channel2()); 4282a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4292a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SendDataResult result; 4302a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hello?", &result)); 4312a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 4322a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hello?"), 1000); 4332a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel2(), 2, "hi chan1", &result)); 4342a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 4352a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver1(), 2, "hi chan1"), 1000); 4362a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4372a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // Close channel 1. Channel 2 should notify us. 4382a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel1()->RemoveSendStream(1); 4392a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_2_sig_receiver.WasStreamClosed(1), 1000); 4402a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org} 4412a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4422a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.orgTEST_F(SctpDataMediaChannelTest, ClosesTwoRemoteStreams) { 4432a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SetupConnectedChannels(); 4442a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org AddStream(3); 4452a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SignalChannelClosedObserver chan_1_sig_receiver, chan_2_sig_receiver; 4462a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_1_sig_receiver.BindSelf(channel1()); 4472a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_2_sig_receiver.BindSelf(channel2()); 4482a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4492a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SendDataResult result; 4502a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hello?", &result)); 4512a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 4522a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hello?"), 1000); 4532a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel2(), 2, "hi chan1", &result)); 4542a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 4552a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver1(), 2, "hi chan1"), 1000); 4562a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4572a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // Close two streams on one side. 4582a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel2()->RemoveSendStream(2); 4592a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel2()->RemoveSendStream(3); 4602a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_1_sig_receiver.WasStreamClosed(2), 1000); 4612a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_1_sig_receiver.WasStreamClosed(3), 1000); 4622a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org} 4632a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4642a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.orgTEST_F(SctpDataMediaChannelTest, ClosesStreamsOnBothSides) { 4652a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SetupConnectedChannels(); 4662a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org AddStream(3); 4672a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org AddStream(4); 4682a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SignalChannelClosedObserver chan_1_sig_receiver, chan_2_sig_receiver; 4692a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_1_sig_receiver.BindSelf(channel1()); 4702a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_2_sig_receiver.BindSelf(channel2()); 4712a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4722a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SendDataResult result; 4732a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hello?", &result)); 4742a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 4752a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hello?"), 1000); 4762a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel2(), 2, "hi chan1", &result)); 4772a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 4782a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver1(), 2, "hi chan1"), 1000); 4792a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4802a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // Close one stream on channel1(), while closing three streams on 4812a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // channel2(). They will conflict (only one side can close anything at a 4822a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // time, apparently). Test the resolution of the conflict. 4832a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel1()->RemoveSendStream(1); 4842a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4852a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel2()->RemoveSendStream(2); 4862a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel2()->RemoveSendStream(3); 4872a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel2()->RemoveSendStream(4); 4882a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_2_sig_receiver.WasStreamClosed(1), 1000); 4892a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_1_sig_receiver.WasStreamClosed(2), 1000); 4902a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_1_sig_receiver.WasStreamClosed(3), 1000); 4912a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_1_sig_receiver.WasStreamClosed(4), 1000); 4922a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org} 4932a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 4942a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.orgTEST_F(SctpDataMediaChannelTest, ReusesAStream) { 4952a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // Shut down channel 1, then open it up again for reuse. 4962a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SetupConnectedChannels(); 4972a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org cricket::SendDataResult result; 4982a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org SignalChannelClosedObserver chan_2_sig_receiver; 4992a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org chan_2_sig_receiver.BindSelf(channel2()); 5002a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 5012a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hello?", &result)); 5022a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 5032a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hello?"), 1000); 5042a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 5052a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel1()->RemoveSendStream(1); 5062a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_2_sig_receiver.WasStreamClosed(1), 1000); 5072a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // Channel 1 is gone now. 5082a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org 5092a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org // Create a new channel 1. 5102a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org AddStream(1); 5112a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org ASSERT_TRUE(SendData(channel1(), 1, "hi?", &result)); 5122a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_EQ(cricket::SDR_SUCCESS, result); 5132a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(ReceivedData(receiver2(), 1, "hi?"), 1000); 5142a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org channel1()->RemoveSendStream(1); 5152a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org EXPECT_TRUE_WAIT(chan_2_sig_receiver.StreamCloseCount(1) == 2, 1000); 5162a81a3893cea812cfa676ff7553038078c17f56cwu@webrtc.org} 517