// Copyright (c) 2013 The Chromium Authors. All rights reserved. // Use of this source code is governed by a BSD-style license that can be // found in the LICENSE file. #ifndef CONTENT_RENDERER_PEPPER_PEPPER_VIDEO_SOURCE_HOST_H_ #define CONTENT_RENDERER_PEPPER_PEPPER_VIDEO_SOURCE_HOST_H_ #include "base/compiler_specific.h" #include "base/memory/ref_counted.h" #include "base/memory/scoped_ptr.h" #include "base/memory/weak_ptr.h" #include "content/common/content_export.h" #include "content/renderer/media/video_source_handler.h" #include "ppapi/c/pp_time.h" #include "ppapi/host/host_message_context.h" #include "ppapi/host/resource_host.h" struct PP_ImageDataDesc; namespace content { class RendererPpapiHost; class CONTENT_EXPORT PepperVideoSourceHost : public ppapi::host::ResourceHost { public: PepperVideoSourceHost(RendererPpapiHost* host, PP_Instance instance, PP_Resource resource); virtual ~PepperVideoSourceHost(); virtual int32_t OnResourceMessageReceived( const IPC::Message& msg, ppapi::host::HostMessageContext* context) OVERRIDE; private: // This helper object receives frames on a video worker thread and passes // them on to us. class FrameReceiver : public FrameReaderInterface, public base::RefCountedThreadSafe<FrameReceiver> { public: explicit FrameReceiver(const base::WeakPtr<PepperVideoSourceHost>& host); // FrameReaderInterface implementation. virtual bool GotFrame(const scoped_refptr<media::VideoFrame>& frame) OVERRIDE; void OnGotFrame(const scoped_refptr<media::VideoFrame>& frame); private: friend class base::RefCountedThreadSafe<FrameReceiver>; virtual ~FrameReceiver(); base::WeakPtr<PepperVideoSourceHost> host_; scoped_refptr<base::MessageLoopProxy> main_message_loop_proxy_; }; friend class FrameReceiver; int32_t OnHostMsgOpen(ppapi::host::HostMessageContext* context, const std::string& stream_url); int32_t OnHostMsgGetFrame(ppapi::host::HostMessageContext* context); int32_t OnHostMsgClose(ppapi::host::HostMessageContext* context); // Sends the reply to a GetFrame message from the plugin. A reply is always // sent and last_frame_, reply_context_, and get_frame_pending_ are all reset. void SendGetFrameReply(); // Sends the reply to a GetFrame message from the plugin in case of an error. void SendGetFrameErrorReply(int32_t error); void Close(); RendererPpapiHost* renderer_ppapi_host_; ppapi::host::ReplyMessageContext reply_context_; scoped_ptr<VideoSourceHandler> source_handler_; scoped_refptr<FrameReceiver> frame_receiver_; std::string stream_url_; scoped_refptr<media::VideoFrame> last_frame_; bool get_frame_pending_; base::WeakPtrFactory<PepperVideoSourceHost> weak_factory_; DISALLOW_COPY_AND_ASSIGN(PepperVideoSourceHost); }; } // namespace content #endif // CONTENT_RENDERER_PEPPER_PEPPER_VIDEO_SOURCE_HOST_H_