10e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// libjingle 20e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Copyright 2004 Google Inc. 30e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// 40e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Redistribution and use in source and binary forms, with or without 50e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// modification, are permitted provided that the following conditions are met: 60e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// 70e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// 1. Redistributions of source code must retain the above copyright notice, 80e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// this list of conditions and the following disclaimer. 90e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// 2. Redistributions in binary form must reproduce the above copyright notice, 100e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// this list of conditions and the following disclaimer in the documentation 110e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// and/or other materials provided with the distribution. 120e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// 3. The name of the author may not be used to endorse or promote products 130e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// derived from this software without specific prior written permission. 140e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// 150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 160e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 170e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 180e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 230e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 240e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 250e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 260e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org#include "talk/media/base/filemediaengine.h" 270e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 28b9518277716cf5081d3058d86ab7d98b78f696e8pbos@webrtc.org#include <limits.h> 290e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 30cf81adffe15fa8ea0f333432e41f6d504148f18abuildbot@webrtc.org#include "talk/media/base/rtpdump.h" 31cf81adffe15fa8ea0f333432e41f6d504148f18abuildbot@webrtc.org#include "talk/media/base/rtputils.h" 32cf81adffe15fa8ea0f333432e41f6d504148f18abuildbot@webrtc.org#include "talk/media/base/streamparams.h" 332a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/buffer.h" 342a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/event.h" 352a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/logging.h" 362a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/pathutils.h" 372a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org#include "webrtc/base/stream.h" 380e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 390e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgnamespace cricket { 400e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 410e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 420e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Implementation of FileMediaEngine. 430e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 440e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgint FileMediaEngine::GetCapabilities() { 450e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org int capabilities = 0; 460e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!voice_input_filename_.empty()) { 470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org capabilities |= AUDIO_SEND; 480e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 490e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!voice_output_filename_.empty()) { 500e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org capabilities |= AUDIO_RECV; 510e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 520e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!video_input_filename_.empty()) { 530e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org capabilities |= VIDEO_SEND; 540e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 550e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!video_output_filename_.empty()) { 560e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org capabilities |= VIDEO_RECV; 570e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 580e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return capabilities; 590e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 600e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 610e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgVoiceMediaChannel* FileMediaEngine::CreateChannel() { 622a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::FileStream* input_file_stream = NULL; 632a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::FileStream* output_file_stream = NULL; 640e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 650e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (voice_input_filename_.empty() && voice_output_filename_.empty()) 660e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return NULL; 670e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!voice_input_filename_.empty()) { 682a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org input_file_stream = rtc::Filesystem::OpenFile( 692a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Pathname(voice_input_filename_), "rb"); 700e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!input_file_stream) { 710e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_ERROR) << "Not able to open the input audio stream file."; 720e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return NULL; 730e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 740e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 750e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 760e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!voice_output_filename_.empty()) { 772a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org output_file_stream = rtc::Filesystem::OpenFile( 782a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Pathname(voice_output_filename_), "wb"); 790e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!output_file_stream) { 800e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org delete input_file_stream; 810e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_ERROR) << "Not able to open the output audio stream file."; 820e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return NULL; 830e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 840e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 850e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 86cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org return new FileVoiceChannel(input_file_stream, output_file_stream, 87cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org rtp_sender_thread_); 880e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 890e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 900e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgVideoMediaChannel* FileMediaEngine::CreateVideoChannel( 910e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org VoiceMediaChannel* voice_ch) { 922a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::FileStream* input_file_stream = NULL; 932a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::FileStream* output_file_stream = NULL; 940e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 950e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (video_input_filename_.empty() && video_output_filename_.empty()) 960e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return NULL; 970e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 980e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!video_input_filename_.empty()) { 992a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org input_file_stream = rtc::Filesystem::OpenFile( 1002a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Pathname(video_input_filename_), "rb"); 1010e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!input_file_stream) { 1020e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_ERROR) << "Not able to open the input video stream file."; 1030e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return NULL; 1040e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1050e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1060e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1070e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!video_output_filename_.empty()) { 1082a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org output_file_stream = rtc::Filesystem::OpenFile( 1092a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Pathname(video_output_filename_), "wb"); 1100e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!output_file_stream) { 1110e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org delete input_file_stream; 1120e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_ERROR) << "Not able to open the output video stream file."; 1130e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return NULL; 1140e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1160e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 117cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org return new FileVideoChannel(input_file_stream, output_file_stream, 118cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org rtp_sender_thread_); 1190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 1200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 1220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Definition of RtpSenderReceiver. 1230e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 1242a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.orgclass RtpSenderReceiver : public rtc::MessageHandler { 1250e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org public: 1260e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org RtpSenderReceiver(MediaChannel* channel, 1272a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* input_file_stream, 1282a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* output_file_stream, 1292a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* sender_thread); 130e5b49108d39835fbab2ae1c29eff4542a57a8ed5wu@webrtc.org virtual ~RtpSenderReceiver(); 1310e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1320e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Called by media channel. Context: media channel thread. 1330e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool SetSend(bool send); 1340e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org void SetSendSsrc(uint32 ssrc); 1352a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org void OnPacketReceived(rtc::Buffer* packet); 1360e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1370e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Override virtual method of parent MessageHandler. Context: Worker Thread. 1382a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org virtual void OnMessage(rtc::Message* pmsg); 1390e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1400e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org private: 1410e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Read the next RTP dump packet, whose RTP SSRC is the same as first_ssrc_. 1420e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Return true if successful. 1430e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool ReadNextPacket(RtpDumpPacket* packet); 1440e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Send a RTP packet to the network. The input parameter data points to the 1450e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // start of the RTP packet and len is the packet size. Return true if the sent 1460e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // size is equal to len. 1470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool SendRtpPacket(const void* data, size_t len); 1480e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1490e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org MediaChannel* media_channel_; 1502a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<rtc::StreamInterface> input_stream_; 1512a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<rtc::StreamInterface> output_stream_; 1522a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<RtpDumpLoopReader> rtp_dump_reader_; 1532a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::scoped_ptr<RtpDumpWriter> rtp_dump_writer_; 1542a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* sender_thread_; 155cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org bool own_sender_thread_; 1560e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // RTP dump packet read from the input stream. 1570e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org RtpDumpPacket rtp_dump_packet_; 1580e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org uint32 start_send_time_; 1590e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool sending_; 1600e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool first_packet_; 1610e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org uint32 first_ssrc_; 1620e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1630e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org DISALLOW_COPY_AND_ASSIGN(RtpSenderReceiver); 1640e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org}; 1650e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1660e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 1670e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Implementation of RtpSenderReceiver. 1680e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 1690e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgRtpSenderReceiver::RtpSenderReceiver( 1700e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org MediaChannel* channel, 1712a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* input_file_stream, 1722a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* output_file_stream, 1732a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* sender_thread) 1740e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org : media_channel_(channel), 175cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org input_stream_(input_file_stream), 176cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org output_stream_(output_file_stream), 1770e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org sending_(false), 1780e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org first_packet_(true) { 179cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org if (sender_thread == NULL) { 1802a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org sender_thread_ = new rtc::Thread(); 181cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org own_sender_thread_ = true; 182cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org } else { 183cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org sender_thread_ = sender_thread; 184cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org own_sender_thread_ = false; 185cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org } 186cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org 1870e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (input_stream_) { 1880e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_dump_reader_.reset(new RtpDumpLoopReader(input_stream_.get())); 1890e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Start the sender thread, which reads rtp dump records, waits based on 1900e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // the record timestamps, and sends the RTP packets to the network. 191cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org if (own_sender_thread_) { 192cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org sender_thread_->Start(); 193cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org } 1940e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 1950e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 1960e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Create a rtp dump writer for the output RTP dump stream. 1970e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (output_stream_) { 1980e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_dump_writer_.reset(new RtpDumpWriter(output_stream_.get())); 1990e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2000e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2010e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 202e5b49108d39835fbab2ae1c29eff4542a57a8ed5wu@webrtc.orgRtpSenderReceiver::~RtpSenderReceiver() { 203cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org if (own_sender_thread_) { 204cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org sender_thread_->Stop(); 205cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org delete sender_thread_; 206cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org } 207e5b49108d39835fbab2ae1c29eff4542a57a8ed5wu@webrtc.org} 208e5b49108d39835fbab2ae1c29eff4542a57a8ed5wu@webrtc.org 2090e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool RtpSenderReceiver::SetSend(bool send) { 2100e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org bool was_sending = sending_; 2110e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org sending_ = send; 2120e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!was_sending && sending_) { 213cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org sender_thread_->PostDelayed(0, this); // Wake up the send thread. 2142a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org start_send_time_ = rtc::Time(); 2150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2160e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 2170e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2180e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2190e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgvoid RtpSenderReceiver::SetSendSsrc(uint32 ssrc) { 2200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (rtp_dump_reader_) { 2210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_dump_reader_->SetSsrc(ssrc); 2220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2230e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2240e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2252a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.orgvoid RtpSenderReceiver::OnPacketReceived(rtc::Buffer* packet) { 2260e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (rtp_dump_writer_) { 2270e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_dump_writer_->WriteRtpPacket(packet->data(), packet->length()); 2280e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2290e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2300e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2312a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.orgvoid RtpSenderReceiver::OnMessage(rtc::Message* pmsg) { 2320e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!sending_) { 2330e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // If the sender thread is not sending, ignore this message. The thread goes 2340e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // to sleep until SetSend(true) wakes it up. 2350e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return; 2360e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2370e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!first_packet_) { 2380e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // Send the previously read packet. 2390e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org SendRtpPacket(&rtp_dump_packet_.data[0], rtp_dump_packet_.data.size()); 2400e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2410e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2420e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (ReadNextPacket(&rtp_dump_packet_)) { 2432a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org int wait = rtc::TimeUntil( 2440e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org start_send_time_ + rtp_dump_packet_.elapsed_time); 2452a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org wait = rtc::_max(0, wait); 246cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org sender_thread_->PostDelayed(wait, this); 2470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } else { 248cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org sender_thread_->Quit(); 2490e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2500e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2510e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2520e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool RtpSenderReceiver::ReadNextPacket(RtpDumpPacket* packet) { 2532a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org while (rtc::SR_SUCCESS == rtp_dump_reader_->ReadPacket(packet)) { 2540e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org uint32 ssrc; 2550e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (!packet->GetRtpSsrc(&ssrc)) { 2560e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 2570e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2580e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (first_packet_) { 2590e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org first_packet_ = false; 2600e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org first_ssrc_ = ssrc; 2610e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2620e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (ssrc == first_ssrc_) { 2630e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 2640e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2650e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 2660e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 2670e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2680e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2690e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool RtpSenderReceiver::SendRtpPacket(const void* data, size_t len) { 2707162d28d68ad58802a5a52eca0df59150ee7b9d4henrike@webrtc.org if (!media_channel_) 2710e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 2720e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2732a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Buffer packet(data, len, kMaxRtpPacketLen); 2747162d28d68ad58802a5a52eca0df59150ee7b9d4henrike@webrtc.org return media_channel_->SendPacket(&packet); 2750e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2760e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2770e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 2780e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Implementation of FileVoiceChannel. 2790e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 2800e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgFileVoiceChannel::FileVoiceChannel( 2812a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* input_file_stream, 2822a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* output_file_stream, 2832a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* rtp_sender_thread) 2840e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org : send_ssrc_(0), 2850e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_(new RtpSenderReceiver(this, input_file_stream, 286cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org output_file_stream, 287cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org rtp_sender_thread)) {} 2880e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2890e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgFileVoiceChannel::~FileVoiceChannel() {} 2900e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2910e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVoiceChannel::SetSendCodecs(const std::vector<AudioCodec>& codecs) { 2920e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // TODO(whyuan): Check the format of RTP dump input. 2930e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 2940e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2950e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 2960e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVoiceChannel::SetSend(SendFlags flag) { 2970e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return rtp_sender_receiver_->SetSend(flag != SEND_NOTHING); 2980e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 2990e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3000e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVoiceChannel::AddSendStream(const StreamParams& sp) { 3010e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (send_ssrc_ != 0 || sp.ssrcs.size() != 1) { 3020e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_ERROR) << "FileVoiceChannel only supports one send stream."; 3030e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 3040e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3050e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org send_ssrc_ = sp.ssrcs[0]; 3060e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 3070e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 3080e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3090e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3100e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVoiceChannel::RemoveSendStream(uint32 ssrc) { 3110e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (ssrc != send_ssrc_) 3120e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 3130e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org send_ssrc_ = 0; 3140e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 3150e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 3160e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3170e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 318f89a403cd8db88001322bbb0765c4636fd123700wu@webrtc.orgvoid FileVoiceChannel::OnPacketReceived( 3192a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Buffer* packet, const rtc::PacketTime& packet_time) { 3200e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_->OnPacketReceived(packet); 3210e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3220e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3230e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 3240e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org// Implementation of FileVideoChannel. 3250e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org/////////////////////////////////////////////////////////////////////////// 3260e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgFileVideoChannel::FileVideoChannel( 3272a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* input_file_stream, 3282a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::StreamInterface* output_file_stream, 3292a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Thread* rtp_sender_thread) 3300e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org : send_ssrc_(0), 3310e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_(new RtpSenderReceiver(this, input_file_stream, 332cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org output_file_stream, 333cfd624796c7321c5ffac2249b407cdd0d496e00awu@webrtc.org rtp_sender_thread)) {} 3340e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3350e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgFileVideoChannel::~FileVideoChannel() {} 3360e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3370e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVideoChannel::SetSendCodecs(const std::vector<VideoCodec>& codecs) { 3380e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org // TODO(whyuan): Check the format of RTP dump input. 3390e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 3400e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3410e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3420e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVideoChannel::SetSend(bool send) { 3430e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return rtp_sender_receiver_->SetSend(send); 3440e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3450e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3460e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVideoChannel::AddSendStream(const StreamParams& sp) { 3470e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (send_ssrc_ != 0 || sp.ssrcs.size() != 1) { 3480e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org LOG(LS_ERROR) << "FileVideoChannel only support one send stream."; 3490e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 3500e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org } 3510e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org send_ssrc_ = sp.ssrcs[0]; 3520e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 3530e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 3540e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3550e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3560e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.orgbool FileVideoChannel::RemoveSendStream(uint32 ssrc) { 3570e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org if (ssrc != send_ssrc_) 3580e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return false; 3590e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org send_ssrc_ = 0; 3600e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 3610e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org return true; 3620e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3630e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 364f89a403cd8db88001322bbb0765c4636fd123700wu@webrtc.orgvoid FileVideoChannel::OnPacketReceived( 3652a86ce22ccc387dfa6f8a98ce3eba5c1e6f9e538buildbot@webrtc.org rtc::Buffer* packet, const rtc::PacketTime& packet_time) { 3660e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org rtp_sender_receiver_->OnPacketReceived(packet); 3670e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} 3680e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org 3690e118e7129884fbea117e78d6f2068139a414dbhenrike@webrtc.org} // namespace cricket 370