Home | History | Annotate | Download | only in media
      1 // Copyright (c) 2012 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 #ifndef CONTENT_RENDERER_MEDIA_AUDIO_INPUT_MESSAGE_FILTER_H_
      6 #define CONTENT_RENDERER_MEDIA_AUDIO_INPUT_MESSAGE_FILTER_H_
      7 
      8 #include "base/id_map.h"
      9 #include "base/memory/scoped_ptr.h"
     10 #include "base/memory/shared_memory.h"
     11 #include "base/sync_socket.h"
     12 #include "content/common/content_export.h"
     13 #include "ipc/message_filter.h"
     14 #include "media/audio/audio_input_ipc.h"
     15 
     16 namespace base {
     17 class MessageLoopProxy;
     18 }
     19 
     20 namespace content {
     21 
     22 // MessageFilter that handles audio input messages and delegates them to
     23 // audio capturers. Created on render thread, AudioMessageFilter is operated on
     24 // IO thread (secondary thread of render process), it intercepts audio messages
     25 // and process them on IO thread since these messages are time critical.
     26 class CONTENT_EXPORT AudioInputMessageFilter : public IPC::MessageFilter {
     27  public:
     28   explicit AudioInputMessageFilter(
     29       const scoped_refptr<base::MessageLoopProxy>& io_message_loop);
     30 
     31   // Getter for the one AudioInputMessageFilter object.
     32   static AudioInputMessageFilter* Get();
     33 
     34   // Create an AudioInputIPC to be owned by one delegate.  |render_view_id| is
     35   // the render view containing the entity consuming the audio.
     36   //
     37   // The returned object is not thread-safe, and must be used on
     38   // |io_message_loop|.
     39   scoped_ptr<media::AudioInputIPC> CreateAudioInputIPC(int render_view_id);
     40 
     41   scoped_refptr<base::MessageLoopProxy> io_message_loop() const {
     42     return io_message_loop_;
     43   }
     44 
     45  private:
     46   // Implementation of media::AudioInputIPC which augments IPC calls with
     47   // stream_id and the destination render_view_id.
     48   class AudioInputIPCImpl;
     49 
     50   virtual ~AudioInputMessageFilter();
     51 
     52   // Sends an IPC message using |channel_|.
     53   void Send(IPC::Message* message);
     54 
     55   // IPC::MessageFilter override. Called on |io_message_loop_|.
     56   virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
     57   virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE;
     58   virtual void OnFilterRemoved() OVERRIDE;
     59   virtual void OnChannelClosing() OVERRIDE;
     60 
     61   // Received when browser process has created an audio input stream.
     62   void OnStreamCreated(int stream_id,
     63                        base::SharedMemoryHandle handle,
     64 #if defined(OS_WIN)
     65                        base::SyncSocket::Handle socket_handle,
     66 #else
     67                        base::FileDescriptor socket_descriptor,
     68 #endif
     69                        uint32 length,
     70                        uint32 total_segments);
     71 
     72   // Notification of volume property of an audio input stream.
     73   void OnStreamVolume(int stream_id, double volume);
     74 
     75   // Received when internal state of browser process' audio input stream has
     76   // changed.
     77   void OnStreamStateChanged(int stream_id,
     78                             media::AudioInputIPCDelegate::State state);
     79 
     80   // A map of stream ids to delegates.
     81   IDMap<media::AudioInputIPCDelegate> delegates_;
     82 
     83   // IPC sender for Send(), must only be accesed on |io_message_loop_|.
     84   IPC::Sender* sender_;
     85 
     86   // Message loop on which IPC calls are driven.
     87   const scoped_refptr<base::MessageLoopProxy> io_message_loop_;
     88 
     89   // The singleton instance for this filter.
     90   static AudioInputMessageFilter* g_filter;
     91 
     92   DISALLOW_COPY_AND_ASSIGN(AudioInputMessageFilter);
     93 };
     94 
     95 }  // namespace content
     96 
     97 #endif  // CONTENT_RENDERER_MEDIA_AUDIO_INPUT_MESSAGE_FILTER_H_
     98