1 // Copyright 2014 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.
5 #ifndef CHROME_RENDERER_MEDIA_CAST_IPC_DISPATCHER_H_
6 #define CHROME_RENDERER_MEDIA_CAST_IPC_DISPATCHER_H_
8 #include "base/callback.h"
9 #include "base/id_map.h"
10 #include "ipc/ipc_channel_proxy.h"
11 #include "ipc/message_filter.h"
12 #include "media/cast/cast_sender.h"
13 #include "media/cast/logging/logging_defines.h"
14 #include "media/cast/net/cast_transport_sender.h"
16 class CastTransportSenderIPC;
18 // This dispatcher listens to incoming IPC messages and sends
19 // the call to the correct CastTransportSenderIPC instance.
20 class CastIPCDispatcher : public IPC::MessageFilter {
22 explicit CastIPCDispatcher(
23 const scoped_refptr<base::MessageLoopProxy>& io_message_loop);
25 static CastIPCDispatcher* Get();
26 void Send(IPC::Message* message);
27 int32 AddSender(CastTransportSenderIPC* sender);
28 void RemoveSender(int32 channel_id);
30 // IPC::MessageFilter implementation
31 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
32 virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE;
33 virtual void OnFilterRemoved() OVERRIDE;
34 virtual void OnChannelClosing() OVERRIDE;
37 virtual ~CastIPCDispatcher();
40 void OnNotifyStatusChange(
42 media::cast::CastTransportStatus status);
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,
54 const media::cast::RtcpRttReport& rtt_report);
55 void OnRtcpCastMessage(int32 channel_id,
57 const media::cast::RtcpCastMessage& cast_message);
59 static CastIPCDispatcher* global_instance_;
61 // For IPC Send(); must only be accesed on |io_message_loop_|.
64 // Message loop on which IPC calls are driven.
65 const scoped_refptr<base::MessageLoopProxy> io_message_loop_;
67 // A map of stream ids to delegates; must only be accessed on
68 // |io_message_loop_|.
69 IDMap<CastTransportSenderIPC> id_map_;
70 DISALLOW_COPY_AND_ASSIGN(CastIPCDispatcher);
73 #endif // CHROME_RENDERER_MEDIA_CAST_IPC_DISPATCHER_H_