1e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng// Copyright 2014 The Chromium Authors. All rights reserved. 2e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng// Use of this source code is governed by a BSD-style license that can be 3e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng// found in the LICENSE file. 4e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 5e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#ifndef CHROME_RENDERER_MEDIA_CAST_IPC_DISPATCHER_H_ 6e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#define CHROME_RENDERER_MEDIA_CAST_IPC_DISPATCHER_H_ 7e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 8e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "base/callback.h" 9e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "base/id_map.h" 10e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "ipc/ipc_channel_proxy.h" 11e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "ipc/message_filter.h" 12e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "media/cast/cast_sender.h" 13e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "media/cast/logging/logging_defines.h" 14e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng#include "media/cast/net/cast_transport_sender.h" 15e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 16e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Chengclass CastTransportSenderIPC; 17e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 18e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng// This dispatcher listens to incoming IPC messages and sends 19e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng// the call to the correct CastTransportSenderIPC instance. 20e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Chengclass CastIPCDispatcher : public IPC::MessageFilter { 21e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng public: 22e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng explicit CastIPCDispatcher( 23e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng const scoped_refptr<base::MessageLoopProxy>& io_message_loop); 24e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 25e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng static CastIPCDispatcher* Get(); 26e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng void Send(IPC::Message* message); 27e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng int32 AddSender(CastTransportSenderIPC* sender); 28e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng void RemoveSender(int32 channel_id); 29e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 30e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng // IPC::MessageFilter implementation 31e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; 32e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE; 33e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng virtual void OnFilterRemoved() OVERRIDE; 34e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng virtual void OnChannelClosing() OVERRIDE; 35e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 36e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng protected: 37e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng virtual ~CastIPCDispatcher(); 38e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng 39e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng private: 40e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng void OnNotifyStatusChange( 41e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng int32 channel_id, 42e6e8a0bd7cffcc9ae2e0e75546fb12a19213d4aeBen Cheng media::cast::CastTransportStatus status); 43 void OnRtpStatistics( 44 int32 channel_id, 45 bool audio, 46 const media::cast::RtcpSenderInfo& sender_info, 47 base::TimeTicks time_sent, 48 uint32 rtp_timestamp); 49 void OnRawEvents(int32 channel_id, 50 const std::vector<media::cast::PacketEvent>& packet_events, 51 const std::vector<media::cast::FrameEvent>& frame_events); 52 void OnRtt(int32 channel_id, uint32 ssrc, base::TimeDelta rtt); 53 void OnRtcpCastMessage(int32 channel_id, 54 uint32 ssrc, 55 const media::cast::RtcpCastMessage& cast_message); 56 57 static CastIPCDispatcher* global_instance_; 58 59 // For IPC Send(); must only be accesed on |io_message_loop_|. 60 IPC::Sender* sender_; 61 62 // Message loop on which IPC calls are driven. 63 const scoped_refptr<base::MessageLoopProxy> io_message_loop_; 64 65 // A map of stream ids to delegates; must only be accessed on 66 // |io_message_loop_|. 67 IDMap<CastTransportSenderIPC> id_map_; 68 DISALLOW_COPY_AND_ASSIGN(CastIPCDispatcher); 69}; 70 71#endif // CHROME_RENDERER_MEDIA_CAST_IPC_DISPATCHER_H_ 72