Index: chrome/renderer/extensions/cast_streaming_native_handler.cc |
diff --git a/chrome/renderer/extensions/webrtc_native_handler.cc b/chrome/renderer/extensions/cast_streaming_native_handler.cc |
similarity index 78% |
rename from chrome/renderer/extensions/webrtc_native_handler.cc |
rename to chrome/renderer/extensions/cast_streaming_native_handler.cc |
index ac3bf18a11e09f86147c0026e13fc033d37d9f81..00316c760a23046d61cb9c48054828bdd0d751d4 100644 |
--- a/chrome/renderer/extensions/webrtc_native_handler.cc |
+++ b/chrome/renderer/extensions/cast_streaming_native_handler.cc |
@@ -2,16 +2,16 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-#include "chrome/renderer/extensions/webrtc_native_handler.h" |
+#include "chrome/renderer/extensions/cast_streaming_native_handler.h" |
#include <functional> |
#include "base/logging.h" |
#include "base/message_loop/message_loop.h" |
-#include "chrome/common/extensions/api/webrtc_cast_send_transport.h" |
-#include "chrome/common/extensions/api/webrtc_cast_udp_transport.h" |
+#include "chrome/common/extensions/api/cast_streaming_rtp_stream.h" |
+#include "chrome/common/extensions/api/cast_streaming_udp_transport.h" |
#include "chrome/renderer/extensions/chrome_v8_context.h" |
-#include "chrome/renderer/media/cast_send_transport.h" |
+#include "chrome/renderer/media/cast_rtp_stream.h" |
#include "chrome/renderer/media/cast_session.h" |
#include "chrome/renderer/media/cast_udp_transport.h" |
#include "content/public/renderer/v8_value_converter.h" |
@@ -22,16 +22,16 @@ |
using content::V8ValueConverter; |
// Extension types. |
-using extensions::api::webrtc_cast_send_transport::CodecSpecificParams; |
-using extensions::api::webrtc_cast_send_transport::RtpCaps; |
-using extensions::api::webrtc_cast_send_transport::RtpParams; |
-using extensions::api::webrtc_cast_send_transport::RtpPayloadParams; |
-using extensions::api::webrtc_cast_udp_transport::UdpParams; |
+using extensions::api::cast_streaming_rtp_stream::CodecSpecificParams; |
+using extensions::api::cast_streaming_rtp_stream::RtpCaps; |
+using extensions::api::cast_streaming_rtp_stream::RtpParams; |
+using extensions::api::cast_streaming_rtp_stream::RtpPayloadParams; |
+using extensions::api::cast_streaming_udp_transport::UdpParams; |
namespace extensions { |
namespace { |
-const char kSendTransportNotFound[] = "The send transport cannot be found"; |
+const char kRtpStreamNotFound[] = "The RTP stream cannot be found"; |
const char kUdpTransportNotFound[] = "The UDP transport cannot be found"; |
const char kInvalidUdpParams[] = "Invalid UDP params"; |
const char kInvalidRtpParams[] = "Invalid value for RTP params"; |
@@ -122,37 +122,37 @@ void ToCastRtpParams(const RtpParams& ext_params, CastRtpParams* cast_params) { |
} // namespace |
-WebRtcNativeHandler::WebRtcNativeHandler(ChromeV8Context* context) |
+CastStreamingNativeHandler::CastStreamingNativeHandler(ChromeV8Context* context) |
: ObjectBackedNativeHandler(context), |
last_transport_id_(0), |
weak_factory_(this) { |
RouteFunction("CreateSession", |
- base::Bind(&WebRtcNativeHandler::CreateCastSession, |
+ base::Bind(&CastStreamingNativeHandler::CreateCastSession, |
base::Unretained(this))); |
- RouteFunction("DestroyCastSendTransport", |
- base::Bind(&WebRtcNativeHandler::DestroyCastSendTransport, |
+ RouteFunction("DestroyCastRtpStream", |
+ base::Bind(&CastStreamingNativeHandler::DestroyCastRtpStream, |
base::Unretained(this))); |
- RouteFunction("GetCapsCastSendTransport", |
- base::Bind(&WebRtcNativeHandler::GetCapsCastSendTransport, |
+ RouteFunction("GetCapsCastRtpStream", |
+ base::Bind(&CastStreamingNativeHandler::GetCapsCastRtpStream, |
base::Unretained(this))); |
- RouteFunction("StartCastSendTransport", |
- base::Bind(&WebRtcNativeHandler::StartCastSendTransport, |
+ RouteFunction("StartCastRtpStream", |
+ base::Bind(&CastStreamingNativeHandler::StartCastRtpStream, |
base::Unretained(this))); |
- RouteFunction("StopCastSendTransport", |
- base::Bind(&WebRtcNativeHandler::StopCastSendTransport, |
+ RouteFunction("StopCastRtpStream", |
+ base::Bind(&CastStreamingNativeHandler::StopCastRtpStream, |
base::Unretained(this))); |
RouteFunction("DestroyCastUdpTransport", |
- base::Bind(&WebRtcNativeHandler::DestroyCastUdpTransport, |
+ base::Bind(&CastStreamingNativeHandler::DestroyCastUdpTransport, |
base::Unretained(this))); |
RouteFunction("StartCastUdpTransport", |
- base::Bind(&WebRtcNativeHandler::StartCastUdpTransport, |
+ base::Bind(&CastStreamingNativeHandler::StartCastUdpTransport, |
base::Unretained(this))); |
} |
-WebRtcNativeHandler::~WebRtcNativeHandler() { |
+CastStreamingNativeHandler::~CastStreamingNativeHandler() { |
} |
-void WebRtcNativeHandler::CreateCastSession( |
+void CastStreamingNativeHandler::CreateCastSession( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(3, args.Length()); |
CHECK(args[0]->IsObject()); |
@@ -169,10 +169,10 @@ void WebRtcNativeHandler::CreateCastSession( |
return; |
scoped_refptr<CastSession> session(new CastSession()); |
- scoped_ptr<CastSendTransport> stream1( |
- new CastSendTransport(track1.component(), session)); |
- scoped_ptr<CastSendTransport> stream2( |
- new CastSendTransport(track2.component(), session)); |
+ scoped_ptr<CastRtpStream> stream1( |
+ new CastRtpStream(track1.component(), session)); |
+ scoped_ptr<CastRtpStream> stream2( |
+ new CastRtpStream(track2.component(), session)); |
scoped_ptr<CastUdpTransport> udp_transport( |
new CastUdpTransport(session)); |
@@ -181,26 +181,26 @@ void WebRtcNativeHandler::CreateCastSession( |
base::MessageLoop::current()->PostTask( |
FROM_HERE, |
base::Bind( |
- &WebRtcNativeHandler::CallCreateCallback, |
+ &CastStreamingNativeHandler::CallCreateCallback, |
weak_factory_.GetWeakPtr(), |
base::Passed(&stream1), |
base::Passed(&stream2), |
base::Passed(&udp_transport))); |
} |
-void WebRtcNativeHandler::CallCreateCallback( |
- scoped_ptr<CastSendTransport> stream1, |
- scoped_ptr<CastSendTransport> stream2, |
+void CastStreamingNativeHandler::CallCreateCallback( |
+ scoped_ptr<CastRtpStream> stream1, |
+ scoped_ptr<CastRtpStream> stream2, |
scoped_ptr<CastUdpTransport> udp_transport) { |
v8::HandleScope handle_scope(context()->isolate()); |
v8::Context::Scope context_scope(context()->v8_context()); |
const int stream1_id = last_transport_id_++; |
- send_transport_map_[stream1_id] = |
- linked_ptr<CastSendTransport>(stream1.release()); |
+ rtp_stream_map_[stream1_id] = |
+ linked_ptr<CastRtpStream>(stream1.release()); |
const int stream2_id = last_transport_id_++; |
- send_transport_map_[stream2_id] = |
- linked_ptr<CastSendTransport>(stream2.release()); |
+ rtp_stream_map_[stream2_id] = |
+ linked_ptr<CastRtpStream>(stream2.release()); |
const int udp_id = last_transport_id_++; |
udp_transport_map_[udp_id] = |
linked_ptr<CastUdpTransport>(udp_transport.release()); |
@@ -214,24 +214,24 @@ void WebRtcNativeHandler::CallCreateCallback( |
create_callback_.reset(); |
} |
-void WebRtcNativeHandler::DestroyCastSendTransport( |
+void CastStreamingNativeHandler::DestroyCastRtpStream( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(1, args.Length()); |
CHECK(args[0]->IsInt32()); |
const int transport_id = args[0]->ToInt32()->Value(); |
- if (!GetSendTransportOrThrow(transport_id)) |
+ if (!GetRtpStreamOrThrow(transport_id)) |
return; |
- send_transport_map_.erase(transport_id); |
+ rtp_stream_map_.erase(transport_id); |
} |
-void WebRtcNativeHandler::GetCapsCastSendTransport( |
+void CastStreamingNativeHandler::GetCapsCastRtpStream( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(1, args.Length()); |
CHECK(args[0]->IsInt32()); |
const int transport_id = args[0]->ToInt32()->Value(); |
- CastSendTransport* transport = GetSendTransportOrThrow(transport_id); |
+ CastRtpStream* transport = GetRtpStreamOrThrow(transport_id); |
if (!transport) |
return; |
@@ -245,14 +245,14 @@ void WebRtcNativeHandler::GetCapsCastSendTransport( |
caps_value.get(), context()->v8_context())); |
} |
-void WebRtcNativeHandler::StartCastSendTransport( |
+void CastStreamingNativeHandler::StartCastRtpStream( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(2, args.Length()); |
CHECK(args[0]->IsInt32()); |
CHECK(args[1]->IsObject()); |
const int transport_id = args[0]->ToInt32()->Value(); |
- CastSendTransport* transport = GetSendTransportOrThrow(transport_id); |
+ CastRtpStream* transport = GetRtpStreamOrThrow(transport_id); |
if (!transport) |
return; |
@@ -276,19 +276,19 @@ void WebRtcNativeHandler::StartCastSendTransport( |
transport->Start(cast_params); |
} |
-void WebRtcNativeHandler::StopCastSendTransport( |
+void CastStreamingNativeHandler::StopCastRtpStream( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(1, args.Length()); |
CHECK(args[0]->IsInt32()); |
const int transport_id = args[0]->ToInt32()->Value(); |
- CastSendTransport* transport = GetSendTransportOrThrow(transport_id); |
+ CastRtpStream* transport = GetRtpStreamOrThrow(transport_id); |
if (!transport) |
return; |
transport->Stop(); |
} |
-void WebRtcNativeHandler::DestroyCastUdpTransport( |
+void CastStreamingNativeHandler::DestroyCastUdpTransport( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(1, args.Length()); |
CHECK(args[0]->IsInt32()); |
@@ -299,7 +299,7 @@ void WebRtcNativeHandler::DestroyCastUdpTransport( |
udp_transport_map_.erase(transport_id); |
} |
-void WebRtcNativeHandler::StartCastUdpTransport( |
+void CastStreamingNativeHandler::StartCastUdpTransport( |
const v8::FunctionCallbackInfo<v8::Value>& args) { |
CHECK_EQ(2, args.Length()); |
CHECK(args[0]->IsInt32()); |
@@ -327,19 +327,19 @@ void WebRtcNativeHandler::StartCastUdpTransport( |
transport->Start(net::HostPortPair(udp_params->address, udp_params->port)); |
} |
-CastSendTransport* WebRtcNativeHandler::GetSendTransportOrThrow( |
+CastRtpStream* CastStreamingNativeHandler::GetRtpStreamOrThrow( |
int transport_id) const { |
- SendTransportMap::const_iterator iter = send_transport_map_.find( |
+ RtpStreamMap::const_iterator iter = rtp_stream_map_.find( |
transport_id); |
- if (iter != send_transport_map_.end()) |
+ if (iter != rtp_stream_map_.end()) |
return iter->second.get(); |
v8::Isolate* isolate = context()->v8_context()->GetIsolate(); |
- isolate->ThrowException(v8::Exception::RangeError( |
- v8::String::NewFromUtf8(isolate, kSendTransportNotFound))); |
+ isolate->ThrowException(v8::Exception::RangeError(v8::String::NewFromUtf8( |
+ isolate, kRtpStreamNotFound))); |
return NULL; |
} |
-CastUdpTransport* WebRtcNativeHandler::GetUdpTransportOrThrow( |
+CastUdpTransport* CastStreamingNativeHandler::GetUdpTransportOrThrow( |
int transport_id) const { |
UdpTransportMap::const_iterator iter = udp_transport_map_.find( |
transport_id); |