15d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)// Copyright 2014 The Chromium Authors. All rights reserved. 25d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)// found in the LICENSE file. 45d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 55d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "ppapi/proxy/media_stream_track_resource_base.h" 65d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 75d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "base/logging.h" 85d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "ppapi/proxy/ppapi_messages.h" 95d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 105d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)namespace ppapi { 115d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)namespace proxy { 125d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 135d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)MediaStreamTrackResourceBase::MediaStreamTrackResourceBase( 145d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) Connection connection, 155d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PP_Instance instance, 165d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int pending_renderer_id, 175d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const std::string& id) 185d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) : PluginResource(connection, instance), 195d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) buffer_manager_(this), 205d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) id_(id), 215d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) has_ended_(false) { 225d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) AttachToPendingHost(RENDERER, pending_renderer_id); 235d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 245d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 25010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles)MediaStreamTrackResourceBase::MediaStreamTrackResourceBase( 26010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) Connection connection, 27010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) PP_Instance instance) 28010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) : PluginResource(connection, instance), 29010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) buffer_manager_(this), 30010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) has_ended_(false) { 31010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles)} 32010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)MediaStreamTrackResourceBase::~MediaStreamTrackResourceBase() { 345d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 355d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 365d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)void MediaStreamTrackResourceBase::SendEnqueueBufferMessageToHost( 375d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int32_t index) { 385d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) DCHECK_GE(index, 0); 395d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) DCHECK_LT(index, buffer_manager()->number_of_buffers()); 405d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) Post(RENDERER, PpapiHostMsg_MediaStreamTrack_EnqueueBuffer(index)); 415d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 425d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 435d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)void MediaStreamTrackResourceBase::OnReplyReceived( 445d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const ResourceMessageReplyParams& params, 455d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const IPC::Message& msg) { 46cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) PPAPI_BEGIN_MESSAGE_MAP(MediaStreamTrackResourceBase, msg) 475d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PPAPI_DISPATCH_PLUGIN_RESOURCE_CALL( 485d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PpapiPluginMsg_MediaStreamTrack_InitBuffers, OnPluginMsgInitBuffers) 495d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PPAPI_DISPATCH_PLUGIN_RESOURCE_CALL( 505d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PpapiPluginMsg_MediaStreamTrack_EnqueueBuffer, OnPluginMsgEnqueueBuffer) 51010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) PPAPI_DISPATCH_PLUGIN_RESOURCE_CALL( 52010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) PpapiPluginMsg_MediaStreamTrack_EnqueueBuffers, 53010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) OnPluginMsgEnqueueBuffers) 545d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PPAPI_DISPATCH_PLUGIN_RESOURCE_CALL_UNHANDLED( 555d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) PluginResource::OnReplyReceived(params, msg)) 56cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) PPAPI_END_MESSAGE_MAP() 575d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 585d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 595d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)void MediaStreamTrackResourceBase::CloseInternal() { 605d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) if (!has_ended_) { 615d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) Post(RENDERER, PpapiHostMsg_MediaStreamTrack_Close()); 625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) has_ended_ = true; 635d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) } 645d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 655d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 665d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)void MediaStreamTrackResourceBase::OnPluginMsgInitBuffers( 675d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const ResourceMessageReplyParams& params, 685d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int32_t number_of_buffers, 69010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) int32_t buffer_size, 70010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool readonly) { 715d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) base::SharedMemoryHandle shm_handle = base::SharedMemory::NULLHandle(); 725d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) params.TakeSharedMemoryHandleAtIndex(0, &shm_handle); 735d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) buffer_manager_.SetBuffers(number_of_buffers, buffer_size, 74010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) scoped_ptr<base::SharedMemory>(new base::SharedMemory(shm_handle, 75010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) readonly)), 765d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) false); 775d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 785d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 795d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)void MediaStreamTrackResourceBase::OnPluginMsgEnqueueBuffer( 805d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const ResourceMessageReplyParams& params, 815d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int32_t index) { 825d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) buffer_manager_.EnqueueBuffer(index); 835d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 845d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 85010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles)void MediaStreamTrackResourceBase::OnPluginMsgEnqueueBuffers( 86010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) const ResourceMessageReplyParams& params, 87010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) const std::vector<int32_t>& indices) { 88010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) for (size_t i = 0; i < indices.size(); ++i) 89010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) buffer_manager_.EnqueueBuffer(indices[i]); 90010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles)} 91010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 925d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} // namespace proxy 935d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} // namespace ppapi 94