| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "content/renderer/presentation/presentation_dispatcher.h" | 5 #include "content/renderer/presentation/presentation_dispatcher.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 428 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 439 void PresentationDispatcher::OnSessionMessagesReceived( | 439 void PresentationDispatcher::OnSessionMessagesReceived( |
| 440 blink::mojom::PresentationSessionInfoPtr session_info, | 440 blink::mojom::PresentationSessionInfoPtr session_info, |
| 441 std::vector<blink::mojom::SessionMessagePtr> messages) { | 441 std::vector<blink::mojom::SessionMessagePtr> messages) { |
| 442 if (!controller_) | 442 if (!controller_) |
| 443 return; | 443 return; |
| 444 | 444 |
| 445 for (size_t i = 0; i < messages.size(); ++i) { | 445 for (size_t i = 0; i < messages.size(); ++i) { |
| 446 // Note: Passing batches of messages to the Blink layer would be more | 446 // Note: Passing batches of messages to the Blink layer would be more |
| 447 // efficient. | 447 // efficient. |
| 448 std::unique_ptr<PresentationConnectionClient> session_client( | 448 std::unique_ptr<PresentationConnectionClient> session_client( |
| 449 new PresentationConnectionClient(session_info->url, session_info->id)); | 449 new PresentationConnectionClient(session_info.Clone())); |
| 450 switch (messages[i]->type) { | 450 switch (messages[i]->type) { |
| 451 case blink::mojom::PresentationMessageType::TEXT: { | 451 case blink::mojom::PresentationMessageType::TEXT: { |
| 452 // TODO(mfoltz): Do we need to DCHECK(messages[i]->message)? | 452 // TODO(mfoltz): Do we need to DCHECK(messages[i]->message)? |
| 453 controller_->didReceiveSessionTextMessage( | 453 controller_->didReceiveSessionTextMessage( |
| 454 session_client.release(), | 454 session_client.release(), |
| 455 blink::WebString::fromUTF8(messages[i]->message.value())); | 455 blink::WebString::fromUTF8(messages[i]->message.value())); |
| 456 break; | 456 break; |
| 457 } | 457 } |
| 458 case blink::mojom::PresentationMessageType::ARRAY_BUFFER: | 458 case blink::mojom::PresentationMessageType::ARRAY_BUFFER: |
| 459 case blink::mojom::PresentationMessageType::BLOB: { | 459 case blink::mojom::PresentationMessageType::BLOB: { |
| (...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 547 PresentationDispatcher::AvailabilityStatus::AvailabilityStatus( | 547 PresentationDispatcher::AvailabilityStatus::AvailabilityStatus( |
| 548 const GURL& availability_url) | 548 const GURL& availability_url) |
| 549 : url(availability_url), | 549 : url(availability_url), |
| 550 last_known_availability(false), | 550 last_known_availability(false), |
| 551 listening_state(ListeningState::INACTIVE) {} | 551 listening_state(ListeningState::INACTIVE) {} |
| 552 | 552 |
| 553 PresentationDispatcher::AvailabilityStatus::~AvailabilityStatus() { | 553 PresentationDispatcher::AvailabilityStatus::~AvailabilityStatus() { |
| 554 } | 554 } |
| 555 | 555 |
| 556 } // namespace content | 556 } // namespace content |
| OLD | NEW |