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