blob: 225ade0235ddc6ea46b70034055061473d697951 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
// Copyright 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 CHROME_RENDERER_EXTENSIONS_CAST_STREAMING_NATIVE_HANDLER_H_
#define CHROME_RENDERER_EXTENSIONS_CAST_STREAMING_NATIVE_HANDLER_H_
#include <map>
#include "base/memory/linked_ptr.h"
#include "base/memory/weak_ptr.h"
#include "extensions/renderer/object_backed_native_handler.h"
#include "extensions/renderer/scoped_persistent.h"
#include "v8/include/v8.h"
class CastRtpStream;
class CastUdpTransport;
namespace base {
class BinaryValue;
class DictionaryValue;
}
namespace extensions {
// Native code that handle chrome.webrtc custom bindings.
class CastStreamingNativeHandler : public ObjectBackedNativeHandler {
public:
explicit CastStreamingNativeHandler(ScriptContext* context);
~CastStreamingNativeHandler() override;
private:
void CreateCastSession(
const v8::FunctionCallbackInfo<v8::Value>& args);
void DestroyCastRtpStream(
const v8::FunctionCallbackInfo<v8::Value>& args);
void CreateParamsCastRtpStream(
const v8::FunctionCallbackInfo<v8::Value>& args);
void GetSupportedParamsCastRtpStream(
const v8::FunctionCallbackInfo<v8::Value>& args);
void StartCastRtpStream(
const v8::FunctionCallbackInfo<v8::Value>& args);
void StopCastRtpStream(
const v8::FunctionCallbackInfo<v8::Value>& args);
void DestroyCastUdpTransport(
const v8::FunctionCallbackInfo<v8::Value>& args);
void SetDestinationCastUdpTransport(
const v8::FunctionCallbackInfo<v8::Value>& args);
void SetOptionsCastUdpTransport(
const v8::FunctionCallbackInfo<v8::Value>& args);
void StopCastUdpTransport(
const v8::FunctionCallbackInfo<v8::Value>& args);
void ToggleLogging(const v8::FunctionCallbackInfo<v8::Value>& args);
void GetRawEvents(const v8::FunctionCallbackInfo<v8::Value>& args);
void GetStats(const v8::FunctionCallbackInfo<v8::Value>& args);
// Helper method to call the v8 callback function after a session is
// created.
void CallCreateCallback(scoped_ptr<CastRtpStream> stream1,
scoped_ptr<CastRtpStream> stream2,
scoped_ptr<CastUdpTransport> udp_transport);
void CallStartCallback(int stream_id);
void CallStopCallback(int stream_id);
void CallErrorCallback(int stream_id, const std::string& message);
void CallGetRawEventsCallback(int transport_id,
scoped_ptr<base::BinaryValue> raw_events);
void CallGetStatsCallback(int transport_id,
scoped_ptr<base::DictionaryValue> stats);
// Gets the RTP stream or UDP transport indexed by an ID.
// If not found, returns NULL and throws a V8 exception.
CastRtpStream* GetRtpStreamOrThrow(int stream_id) const;
CastUdpTransport* GetUdpTransportOrThrow(int transport_id) const;
int last_transport_id_;
typedef std::map<int, linked_ptr<CastRtpStream> > RtpStreamMap;
RtpStreamMap rtp_stream_map_;
typedef std::map<int, linked_ptr<CastUdpTransport> > UdpTransportMap;
UdpTransportMap udp_transport_map_;
extensions::ScopedPersistent<v8::Function> create_callback_;
typedef std::map<int,
linked_ptr<extensions::ScopedPersistent<v8::Function> > >
RtpStreamCallbackMap;
RtpStreamCallbackMap get_raw_events_callbacks_;
RtpStreamCallbackMap get_stats_callbacks_;
base::WeakPtrFactory<CastStreamingNativeHandler> weak_factory_;
DISALLOW_COPY_AND_ASSIGN(CastStreamingNativeHandler);
};
} // namespace extensions
#endif // CHROME_RENDERER_EXTENSIONS_CAST_STREAMING_NATIVE_HANDLER_H_
|
