15976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// libjingle 25976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Copyright 2004 Google Inc. 35976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 45976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Redistribution and use in source and binary forms, with or without 55976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// modification, are permitted provided that the following conditions are met: 65976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 75976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 1. Redistributions of source code must retain the above copyright notice, 85976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// this list of conditions and the following disclaimer. 95976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 2. Redistributions in binary form must reproduce the above copyright notice, 105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// this list of conditions and the following disclaimer in the documentation 115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// and/or other materials provided with the distribution. 125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 3. The name of the author may not be used to endorse or promote products 135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// derived from this software without specific prior written permission. 145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// 155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/media/base/filemediaengine.h" 275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include <climits> 295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/buffer.h" 315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/event.h" 325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/logging.h" 335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/pathutils.h" 345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/base/stream.h" 355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/media/base/rtpdump.h" 365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/media/base/rtputils.h" 375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/media/base/streamparams.h" 385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgnamespace cricket { 405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Implementation of FileMediaEngine. 435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgint FileMediaEngine::GetCapabilities() { 455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int capabilities = 0; 465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!voice_input_filename_.empty()) { 475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org capabilities |= AUDIO_SEND; 485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!voice_output_filename_.empty()) { 505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org capabilities |= AUDIO_RECV; 515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!video_input_filename_.empty()) { 535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org capabilities |= VIDEO_SEND; 545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!video_output_filename_.empty()) { 565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org capabilities |= VIDEO_RECV; 575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return capabilities; 595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgVoiceMediaChannel* FileMediaEngine::CreateChannel() { 625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::FileStream* input_file_stream = NULL; 635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::FileStream* output_file_stream = NULL; 645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (voice_input_filename_.empty() && voice_output_filename_.empty()) 665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return NULL; 675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!voice_input_filename_.empty()) { 685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org input_file_stream = talk_base::Filesystem::OpenFile( 695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::Pathname(voice_input_filename_), "rb"); 705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!input_file_stream) { 715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "Not able to open the input audio stream file."; 725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return NULL; 735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!voice_output_filename_.empty()) { 775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org output_file_stream = talk_base::Filesystem::OpenFile( 785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::Pathname(voice_output_filename_), "wb"); 795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!output_file_stream) { 805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org delete input_file_stream; 815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "Not able to open the output audio stream file."; 825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return NULL; 835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return new FileVoiceChannel(input_file_stream, output_file_stream); 875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgVideoMediaChannel* FileMediaEngine::CreateVideoChannel( 905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org VoiceMediaChannel* voice_ch) { 915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::FileStream* input_file_stream = NULL; 925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::FileStream* output_file_stream = NULL; 935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (video_input_filename_.empty() && video_output_filename_.empty()) 955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return NULL; 965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!video_input_filename_.empty()) { 985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org input_file_stream = talk_base::Filesystem::OpenFile( 995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::Pathname(video_input_filename_), "rb"); 1005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!input_file_stream) { 1015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "Not able to open the input video stream file."; 1025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return NULL; 1035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!video_output_filename_.empty()) { 1075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org output_file_stream = talk_base::Filesystem::OpenFile( 1085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::Pathname(video_output_filename_), "wb"); 1095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!output_file_stream) { 1105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org delete input_file_stream; 1115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "Not able to open the output video stream file."; 1125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return NULL; 1135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return new FileVideoChannel(input_file_stream, output_file_stream); 1175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 1185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 1205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Definition of RtpSenderReceiver. 1215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 1225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass RtpSenderReceiver 1235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org : public talk_base::Thread, public talk_base::MessageHandler { 1245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org public: 1255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org RtpSenderReceiver(MediaChannel* channel, 1265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* input_file_stream, 1275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* output_file_stream); 1285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Called by media channel. Context: media channel thread. 1305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool SetSend(bool send); 1315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org void SetSendSsrc(uint32 ssrc); 1325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org void OnPacketReceived(talk_base::Buffer* packet); 1335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Override virtual method of parent MessageHandler. Context: Worker Thread. 1355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual void OnMessage(talk_base::Message* pmsg); 1365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org private: 1385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Read the next RTP dump packet, whose RTP SSRC is the same as first_ssrc_. 1395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Return true if successful. 1405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool ReadNextPacket(RtpDumpPacket* packet); 1415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Send a RTP packet to the network. The input parameter data points to the 1425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // start of the RTP packet and len is the packet size. Return true if the sent 1435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // size is equal to len. 1445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool SendRtpPacket(const void* data, size_t len); 1455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org MediaChannel* media_channel_; 1475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::scoped_ptr<talk_base::StreamInterface> input_stream_; 1485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::scoped_ptr<talk_base::StreamInterface> output_stream_; 1495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::scoped_ptr<RtpDumpLoopReader> rtp_dump_reader_; 1505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::scoped_ptr<RtpDumpWriter> rtp_dump_writer_; 1515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // RTP dump packet read from the input stream. 1525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org RtpDumpPacket rtp_dump_packet_; 1535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org uint32 start_send_time_; 1545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool sending_; 1555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool first_packet_; 1565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org uint32 first_ssrc_; 1575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org DISALLOW_COPY_AND_ASSIGN(RtpSenderReceiver); 1595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 1625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Implementation of RtpSenderReceiver. 1635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 1645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgRtpSenderReceiver::RtpSenderReceiver( 1655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org MediaChannel* channel, 1665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* input_file_stream, 1675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* output_file_stream) 1685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org : media_channel_(channel), 1695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org sending_(false), 1705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org first_packet_(true) { 1715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org input_stream_.reset(input_file_stream); 1725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (input_stream_) { 1735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_dump_reader_.reset(new RtpDumpLoopReader(input_stream_.get())); 1745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Start the sender thread, which reads rtp dump records, waits based on 1755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // the record timestamps, and sends the RTP packets to the network. 1765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org Thread::Start(); 1775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Create a rtp dump writer for the output RTP dump stream. 1805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org output_stream_.reset(output_file_stream); 1815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (output_stream_) { 1825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_dump_writer_.reset(new RtpDumpWriter(output_stream_.get())); 1835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 1855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool RtpSenderReceiver::SetSend(bool send) { 1875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org bool was_sending = sending_; 1885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org sending_ = send; 1895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!was_sending && sending_) { 1905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org PostDelayed(0, this); // Wake up the send thread. 1915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org start_send_time_ = talk_base::Time(); 1925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 1945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 1955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid RtpSenderReceiver::SetSendSsrc(uint32 ssrc) { 1975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (rtp_dump_reader_) { 1985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_dump_reader_->SetSsrc(ssrc); 1995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid RtpSenderReceiver::OnPacketReceived(talk_base::Buffer* packet) { 2035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (rtp_dump_writer_) { 2045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_dump_writer_->WriteRtpPacket(packet->data(), packet->length()); 2055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid RtpSenderReceiver::OnMessage(talk_base::Message* pmsg) { 2095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!sending_) { 2105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // If the sender thread is not sending, ignore this message. The thread goes 2115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // to sleep until SetSend(true) wakes it up. 2125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return; 2135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!first_packet_) { 2165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Send the previously read packet. 2175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org SendRtpPacket(&rtp_dump_packet_.data[0], rtp_dump_packet_.data.size()); 2185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (ReadNextPacket(&rtp_dump_packet_)) { 2215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int wait = talk_base::TimeUntil( 2225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org start_send_time_ + rtp_dump_packet_.elapsed_time); 2235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org wait = talk_base::_max(0, wait); 2245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org PostDelayed(wait, this); 2255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } else { 2265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org Quit(); 2275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool RtpSenderReceiver::ReadNextPacket(RtpDumpPacket* packet) { 2315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org while (talk_base::SR_SUCCESS == rtp_dump_reader_->ReadPacket(packet)) { 2325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org uint32 ssrc; 2335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!packet->GetRtpSsrc(&ssrc)) { 2345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (first_packet_) { 2375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org first_packet_ = false; 2385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org first_ssrc_ = ssrc; 2395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (ssrc == first_ssrc_) { 2415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 2425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool RtpSenderReceiver::SendRtpPacket(const void* data, size_t len) { 248c1c67e5a722135af4ca83ee4c7d2dbe3f26bae70henrike@webrtc.org if (!media_channel_) 2495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::Buffer packet(data, len, kMaxRtpPacketLen); 252c1c67e5a722135af4ca83ee4c7d2dbe3f26bae70henrike@webrtc.org return media_channel_->SendPacket(&packet); 2535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 2565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Implementation of FileVoiceChannel. 2575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 2585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgFileVoiceChannel::FileVoiceChannel( 2595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* input_file_stream, 2605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* output_file_stream) 2615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org : send_ssrc_(0), 2625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_(new RtpSenderReceiver(this, input_file_stream, 2635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org output_file_stream)) {} 2645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgFileVoiceChannel::~FileVoiceChannel() {} 2665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVoiceChannel::SetSendCodecs(const std::vector<AudioCodec>& codecs) { 2685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO(whyuan): Check the format of RTP dump input. 2695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 2705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVoiceChannel::SetSend(SendFlags flag) { 2735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return rtp_sender_receiver_->SetSend(flag != SEND_NOTHING); 2745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVoiceChannel::AddSendStream(const StreamParams& sp) { 2775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (send_ssrc_ != 0 || sp.ssrcs.size() != 1) { 2785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "FileVoiceChannel only supports one send stream."; 2795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 2815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org send_ssrc_ = sp.ssrcs[0]; 2825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 2835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 2845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVoiceChannel::RemoveSendStream(uint32 ssrc) { 2875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (ssrc != send_ssrc_) 2885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 2895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org send_ssrc_ = 0; 2905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 2915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 2925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid FileVoiceChannel::OnPacketReceived(talk_base::Buffer* packet) { 2955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_->OnPacketReceived(packet); 2965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 2975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 2985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 2995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org// Implementation of FileVideoChannel. 3005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/////////////////////////////////////////////////////////////////////////// 3015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgFileVideoChannel::FileVideoChannel( 3025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* input_file_stream, 3035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::StreamInterface* output_file_stream) 3045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org : send_ssrc_(0), 3055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_(new RtpSenderReceiver(this, input_file_stream, 3065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org output_file_stream)) {} 3075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgFileVideoChannel::~FileVideoChannel() {} 3095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVideoChannel::SetSendCodecs(const std::vector<VideoCodec>& codecs) { 3115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // TODO(whyuan): Check the format of RTP dump input. 3125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 3135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVideoChannel::SetSend(bool send) { 3165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return rtp_sender_receiver_->SetSend(send); 3175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVideoChannel::AddSendStream(const StreamParams& sp) { 3205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (send_ssrc_ != 0 || sp.ssrcs.size() != 1) { 3215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org LOG(LS_ERROR) << "FileVideoChannel only support one send stream."; 3225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 3235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 3245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org send_ssrc_ = sp.ssrcs[0]; 3255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 3265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 3275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgbool FileVideoChannel::RemoveSendStream(uint32 ssrc) { 3305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (ssrc != send_ssrc_) 3315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return false; 3325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org send_ssrc_ = 0; 3335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_->SetSendSsrc(send_ssrc_); 3345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return true; 3355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgvoid FileVideoChannel::OnPacketReceived(talk_base::Buffer* packet) { 3385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org rtp_sender_receiver_->OnPacketReceived(packet); 3395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 3405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 3415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} // namespace cricket 342