1// Copyright 2013 The Chromium Authors. All rights reserved. 2// Use of this source code is governed by a BSD-style license that can be 3// found in the LICENSE file. 4 5#include "chrome/renderer/media/cast_session.h" 6 7#include "base/message_loop/message_loop_proxy.h" 8#include "chrome/renderer/media/cast_session_delegate.h" 9#include "content/public/renderer/render_thread.h" 10#include "media/base/bind_to_loop.h" 11#include "media/base/video_frame.h" 12#include "media/cast/cast_config.h" 13#include "media/cast/cast_sender.h" 14 15CastSession::CastSession() 16 : delegate_(new CastSessionDelegate()), 17 io_message_loop_proxy_( 18 content::RenderThread::Get()->GetIOMessageLoopProxy()) { 19} 20 21CastSession::~CastSession() { 22 // We should always be able to delete the object on the IO thread. 23 CHECK(io_message_loop_proxy_->DeleteSoon(FROM_HERE, delegate_.release())); 24} 25 26CastSession::P2PSocketFactory::~P2PSocketFactory() { 27} 28 29void CastSession::StartAudio(const media::cast::AudioSenderConfig& config, 30 const FrameInputAvailableCallback& callback) { 31 io_message_loop_proxy_->PostTask(FROM_HERE, 32 base::Bind(&CastSessionDelegate::StartAudio, 33 base::Unretained(delegate_.get()), 34 config, 35 media::BindToCurrentLoop(callback))); 36} 37 38void CastSession::StartVideo(const media::cast::VideoSenderConfig& config, 39 const FrameInputAvailableCallback& callback) { 40 io_message_loop_proxy_->PostTask(FROM_HERE, 41 base::Bind(&CastSessionDelegate::StartVideo, 42 base::Unretained(delegate_.get()), 43 config, 44 media::BindToCurrentLoop(callback))); 45} 46 47void CastSession::SetSocketFactory(scoped_ptr<P2PSocketFactory> socket_factory, 48 const net::IPEndPoint& remote_address) { 49 io_message_loop_proxy_->PostTask( 50 FROM_HERE, 51 base::Bind(&CastSessionDelegate::SetSocketFactory, 52 base::Unretained(delegate_.get()), 53 base::Passed(socket_factory.Pass()), 54 remote_address)); 55} 56