| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/renderer/extensions/cast_streaming_native_handler.h" | 5 #include "chrome/renderer/extensions/cast_streaming_native_handler.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <algorithm> | 10 #include <algorithm> |
| (...skipping 15 matching lines...) Expand all Loading... |
| 26 #include "chrome/common/extensions/api/cast_streaming_receiver_session.h" | 26 #include "chrome/common/extensions/api/cast_streaming_receiver_session.h" |
| 27 #include "chrome/common/extensions/api/cast_streaming_rtp_stream.h" | 27 #include "chrome/common/extensions/api/cast_streaming_rtp_stream.h" |
| 28 #include "chrome/common/extensions/api/cast_streaming_udp_transport.h" | 28 #include "chrome/common/extensions/api/cast_streaming_udp_transport.h" |
| 29 #include "chrome/renderer/media/cast_receiver_session.h" | 29 #include "chrome/renderer/media/cast_receiver_session.h" |
| 30 #include "chrome/renderer/media/cast_rtp_stream.h" | 30 #include "chrome/renderer/media/cast_rtp_stream.h" |
| 31 #include "chrome/renderer/media/cast_session.h" | 31 #include "chrome/renderer/media/cast_session.h" |
| 32 #include "chrome/renderer/media/cast_udp_transport.h" | 32 #include "chrome/renderer/media/cast_udp_transport.h" |
| 33 #include "content/public/child/v8_value_converter.h" | 33 #include "content/public/child/v8_value_converter.h" |
| 34 #include "content/public/renderer/media_stream_utils.h" | 34 #include "content/public/renderer/media_stream_utils.h" |
| 35 #include "extensions/common/extension.h" | 35 #include "extensions/common/extension.h" |
| 36 #include "extensions/renderer/extension_bindings_system.h" |
| 36 #include "extensions/renderer/script_context.h" | 37 #include "extensions/renderer/script_context.h" |
| 37 #include "media/base/audio_parameters.h" | 38 #include "media/base/audio_parameters.h" |
| 38 #include "media/base/limits.h" | 39 #include "media/base/limits.h" |
| 39 #include "net/base/host_port_pair.h" | 40 #include "net/base/host_port_pair.h" |
| 40 #include "net/base/ip_address.h" | 41 #include "net/base/ip_address.h" |
| 41 #include "third_party/WebKit/public/platform/WebMediaStream.h" | 42 #include "third_party/WebKit/public/platform/WebMediaStream.h" |
| 42 #include "third_party/WebKit/public/platform/WebMediaStreamTrack.h" | 43 #include "third_party/WebKit/public/platform/WebMediaStreamTrack.h" |
| 43 #include "third_party/WebKit/public/platform/WebURL.h" | 44 #include "third_party/WebKit/public/platform/WebURL.h" |
| 44 #include "third_party/WebKit/public/web/WebDOMMediaStreamTrack.h" | 45 #include "third_party/WebKit/public/web/WebDOMMediaStreamTrack.h" |
| 45 #include "third_party/WebKit/public/web/WebMediaStreamRegistry.h" | 46 #include "third_party/WebKit/public/web/WebMediaStreamRegistry.h" |
| (...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 287 | 288 |
| 288 } // namespace | 289 } // namespace |
| 289 | 290 |
| 290 // |last_transport_id_| is the identifier for the next created RTP stream. To | 291 // |last_transport_id_| is the identifier for the next created RTP stream. To |
| 291 // create globally unique IDs used for referring to RTP stream objects in | 292 // create globally unique IDs used for referring to RTP stream objects in |
| 292 // browser process, we set its higher 16 bits as HASH(extension_id)&0x7fff, and | 293 // browser process, we set its higher 16 bits as HASH(extension_id)&0x7fff, and |
| 293 // lower 16 bits as the sequence number of the RTP stream created in the same | 294 // lower 16 bits as the sequence number of the RTP stream created in the same |
| 294 // extension. Collision will happen when the first RTP stream keeps alive after | 295 // extension. Collision will happen when the first RTP stream keeps alive after |
| 295 // creating another 64k-1 RTP streams in the same extension, which is very | 296 // creating another 64k-1 RTP streams in the same extension, which is very |
| 296 // unlikely to happen in normal use cases. | 297 // unlikely to happen in normal use cases. |
| 297 CastStreamingNativeHandler::CastStreamingNativeHandler(ScriptContext* context) | 298 CastStreamingNativeHandler::CastStreamingNativeHandler( |
| 299 ScriptContext* context, |
| 300 ExtensionBindingsSystem* bindings_system) |
| 298 : ObjectBackedNativeHandler(context), | 301 : ObjectBackedNativeHandler(context), |
| 299 last_transport_id_( | 302 last_transport_id_( |
| 300 context->extension() | 303 context->extension() |
| 301 ? (((base::Hash(context->extension()->id()) & 0x7fff) << 16) + 1) | 304 ? (((base::Hash(context->extension()->id()) & 0x7fff) << 16) + 1) |
| 302 : 1), | 305 : 1), |
| 306 bindings_system_(bindings_system), |
| 303 weak_factory_(this) { | 307 weak_factory_(this) { |
| 304 RouteFunction("CreateSession", "cast.streaming.session", | 308 RouteFunction("CreateSession", "cast.streaming.session", |
| 305 base::Bind(&CastStreamingNativeHandler::CreateCastSession, | 309 base::Bind(&CastStreamingNativeHandler::CreateCastSession, |
| 306 weak_factory_.GetWeakPtr())); | 310 weak_factory_.GetWeakPtr())); |
| 307 RouteFunction("DestroyCastRtpStream", "cast.streaming.rtpStream", | 311 RouteFunction("DestroyCastRtpStream", "cast.streaming.rtpStream", |
| 308 base::Bind(&CastStreamingNativeHandler::DestroyCastRtpStream, | 312 base::Bind(&CastStreamingNativeHandler::DestroyCastRtpStream, |
| 309 weak_factory_.GetWeakPtr())); | 313 weak_factory_.GetWeakPtr())); |
| 310 RouteFunction( | 314 RouteFunction( |
| 311 "GetSupportedParamsCastRtpStream", "cast.streaming.rtpStream", | 315 "GetSupportedParamsCastRtpStream", "cast.streaming.rtpStream", |
| 312 base::Bind(&CastStreamingNativeHandler::GetSupportedParamsCastRtpStream, | 316 base::Bind(&CastStreamingNativeHandler::GetSupportedParamsCastRtpStream, |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 440 const int udp_id = last_transport_id_++; | 444 const int udp_id = last_transport_id_++; |
| 441 udp_transport_map_[udp_id] = std::move(udp_transport); | 445 udp_transport_map_[udp_id] = std::move(udp_transport); |
| 442 callback_args[2] = v8::Integer::New(isolate, udp_id); | 446 callback_args[2] = v8::Integer::New(isolate, udp_id); |
| 443 context()->SafeCallFunction( | 447 context()->SafeCallFunction( |
| 444 v8::Local<v8::Function>::New(isolate, create_callback_), 3, | 448 v8::Local<v8::Function>::New(isolate, create_callback_), 3, |
| 445 callback_args); | 449 callback_args); |
| 446 create_callback_.Reset(); | 450 create_callback_.Reset(); |
| 447 } | 451 } |
| 448 | 452 |
| 449 void CastStreamingNativeHandler::CallStartCallback(int stream_id) const { | 453 void CastStreamingNativeHandler::CallStartCallback(int stream_id) const { |
| 450 v8::Isolate* isolate = context()->isolate(); | 454 base::ListValue event_args; |
| 451 v8::HandleScope handle_scope(isolate); | 455 event_args.AppendInteger(stream_id); |
| 452 v8::Context::Scope context_scope(context()->v8_context()); | 456 bindings_system_->DispatchEventInContext("cast.streaming.rtpStream.onStarted", |
| 453 v8::Local<v8::Array> event_args = v8::Array::New(isolate, 1); | 457 &event_args, nullptr, context()); |
| 454 event_args->Set(0, v8::Integer::New(isolate, stream_id)); | |
| 455 context()->DispatchEvent("cast.streaming.rtpStream.onStarted", event_args); | |
| 456 } | 458 } |
| 457 | 459 |
| 458 void CastStreamingNativeHandler::CallStopCallback(int stream_id) const { | 460 void CastStreamingNativeHandler::CallStopCallback(int stream_id) const { |
| 459 v8::Isolate* isolate = context()->isolate(); | 461 base::ListValue event_args; |
| 460 v8::HandleScope handle_scope(isolate); | 462 event_args.AppendInteger(stream_id); |
| 461 v8::Context::Scope context_scope(context()->v8_context()); | 463 bindings_system_->DispatchEventInContext("cast.streaming.rtpStream.onStopped", |
| 462 v8::Local<v8::Array> event_args = v8::Array::New(isolate, 1); | 464 &event_args, nullptr, context()); |
| 463 event_args->Set(0, v8::Integer::New(isolate, stream_id)); | |
| 464 context()->DispatchEvent("cast.streaming.rtpStream.onStopped", event_args); | |
| 465 } | 465 } |
| 466 | 466 |
| 467 void CastStreamingNativeHandler::CallErrorCallback( | 467 void CastStreamingNativeHandler::CallErrorCallback( |
| 468 int stream_id, | 468 int stream_id, |
| 469 const std::string& message) const { | 469 const std::string& message) const { |
| 470 v8::Isolate* isolate = context()->isolate(); | 470 base::ListValue event_args; |
| 471 v8::HandleScope handle_scope(isolate); | 471 event_args.AppendInteger(stream_id); |
| 472 v8::Context::Scope context_scope(context()->v8_context()); | 472 event_args.AppendString(message); |
| 473 v8::Local<v8::Array> event_args = v8::Array::New(isolate, 2); | 473 bindings_system_->DispatchEventInContext("cast.streaming.rtpStream.onError", |
| 474 event_args->Set(0, v8::Integer::New(isolate, stream_id)); | 474 &event_args, nullptr, context()); |
| 475 event_args->Set( | |
| 476 1, | |
| 477 v8::String::NewFromUtf8( | |
| 478 isolate, message.data(), v8::String::kNormalString, message.size())); | |
| 479 context()->DispatchEvent("cast.streaming.rtpStream.onError", event_args); | |
| 480 } | 475 } |
| 481 | 476 |
| 482 void CastStreamingNativeHandler::DestroyCastRtpStream( | 477 void CastStreamingNativeHandler::DestroyCastRtpStream( |
| 483 const v8::FunctionCallbackInfo<v8::Value>& args) { | 478 const v8::FunctionCallbackInfo<v8::Value>& args) { |
| 484 CHECK_EQ(1, args.Length()); | 479 CHECK_EQ(1, args.Length()); |
| 485 CHECK(args[0]->IsInt32()); | 480 CHECK(args[0]->IsInt32()); |
| 486 | 481 |
| 487 const int transport_id = args[0]->ToInt32(args.GetIsolate())->Value(); | 482 const int transport_id = args[0]->ToInt32(args.GetIsolate())->Value(); |
| 488 if (!GetRtpStreamOrThrow(transport_id)) | 483 if (!GetRtpStreamOrThrow(transport_id)) |
| 489 return; | 484 return; |
| (...skipping 504 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 994 LOG(ERROR) << "Failed to add Cast audio track to media stream."; | 989 LOG(ERROR) << "Failed to add Cast audio track to media stream."; |
| 995 } | 990 } |
| 996 if (!content::AddVideoTrackToMediaStream(std::move(video), true, // is_remote | 991 if (!content::AddVideoTrackToMediaStream(std::move(video), true, // is_remote |
| 997 true, // is_readonly | 992 true, // is_readonly |
| 998 &web_stream)) { | 993 &web_stream)) { |
| 999 LOG(ERROR) << "Failed to add Cast video track to media stream."; | 994 LOG(ERROR) << "Failed to add Cast video track to media stream."; |
| 1000 } | 995 } |
| 1001 } | 996 } |
| 1002 | 997 |
| 1003 } // namespace extensions | 998 } // namespace extensions |
| OLD | NEW |