OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "base/bind.h" | 5 #include "base/bind.h" |
6 #include "base/bind_helpers.h" | 6 #include "base/bind_helpers.h" |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "services/media/framework_mojo/mojo_producer.h" | 9 #include "services/media/framework_mojo/mojo_producer.h" |
10 | 10 |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 { | 49 { |
50 base::AutoLock lock(lock_); | 50 base::AutoLock lock(lock_); |
51 max_pushes_outstanding_ = 0; | 51 max_pushes_outstanding_ = 0; |
52 } | 52 } |
53 | 53 |
54 DCHECK(demand_callback_); | 54 DCHECK(demand_callback_); |
55 demand_callback_(Demand::kNegative); | 55 demand_callback_(Demand::kNegative); |
56 | 56 |
57 DCHECK(consumer_.is_bound()); | 57 DCHECK(consumer_.is_bound()); |
58 consumer_->Flush(callback); | 58 consumer_->Flush(callback); |
59 first_presentation_time_since_flush_ = Packet::kUnknownPresentationTime; | 59 first_pts_since_flush_ = Packet::kUnknownPts; |
60 end_of_stream_= false; | 60 end_of_stream_= false; |
61 } | 61 } |
62 | 62 |
63 void MojoProducer::SetStatusCallback( | 63 void MojoProducer::SetStatusCallback( |
64 const StatusCallback& callback) { | 64 const StatusCallback& callback) { |
65 status_callback_ = callback; | 65 status_callback_ = callback; |
66 } | 66 } |
67 | 67 |
68 int64_t MojoProducer::GetFirstPresentationTimeSinceFlush() { | 68 int64_t MojoProducer::GetFirstPtsSinceFlush() { |
69 return first_presentation_time_since_flush_; | 69 return first_pts_since_flush_; |
70 } | 70 } |
71 | 71 |
72 PayloadAllocator* MojoProducer::allocator() { | 72 PayloadAllocator* MojoProducer::allocator() { |
73 return &mojo_allocator_; | 73 return &mojo_allocator_; |
74 } | 74 } |
75 | 75 |
76 void MojoProducer::SetDemandCallback(const DemandCallback& demand_callback) { | 76 void MojoProducer::SetDemandCallback(const DemandCallback& demand_callback) { |
77 demand_callback_ = demand_callback; | 77 demand_callback_ = demand_callback; |
78 } | 78 } |
79 | 79 |
80 Demand MojoProducer::SupplyPacket(PacketPtr packet) { | 80 Demand MojoProducer::SupplyPacket(PacketPtr packet) { |
81 DCHECK(packet); | 81 DCHECK(packet); |
82 | 82 |
83 if (first_presentation_time_since_flush_ == | 83 if (first_pts_since_flush_ == Packet::kUnknownPts) { |
84 Packet::kUnknownPresentationTime) { | 84 first_pts_since_flush_ = packet->pts(); |
85 first_presentation_time_since_flush_ = packet->presentation_time(); | |
86 } | 85 } |
87 | 86 |
88 // If we're no longer connected, throw the packet away. | 87 // If we're no longer connected, throw the packet away. |
89 if (!consumer_.is_bound()) { | 88 if (!consumer_.is_bound()) { |
90 SetState(MediaState::UNPREPARED); | 89 SetState(MediaState::UNPREPARED); |
91 // TODO(dalesat): More shutdown? | 90 // TODO(dalesat): More shutdown? |
92 return Demand::kNegative; | 91 return Demand::kNegative; |
93 } | 92 } |
94 | 93 |
95 Demand demand; | 94 Demand demand; |
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
185 MediaPacketPtr MojoProducer::CreateMediaPacket( | 184 MediaPacketPtr MojoProducer::CreateMediaPacket( |
186 const PacketPtr& packet) { | 185 const PacketPtr& packet) { |
187 DCHECK(packet); | 186 DCHECK(packet); |
188 | 187 |
189 MediaPacketRegionPtr region = MediaPacketRegion::New(); | 188 MediaPacketRegionPtr region = MediaPacketRegion::New(); |
190 region->offset = packet->size() == 0 ? 0 : | 189 region->offset = packet->size() == 0 ? 0 : |
191 mojo_allocator_.OffsetFromPtr(packet->payload()); | 190 mojo_allocator_.OffsetFromPtr(packet->payload()); |
192 region->length = packet->size(); | 191 region->length = packet->size(); |
193 | 192 |
194 MediaPacketPtr media_packet = MediaPacket::New(); | 193 MediaPacketPtr media_packet = MediaPacket::New(); |
195 media_packet->pts = packet->presentation_time(); | 194 media_packet->pts = packet->pts(); |
196 media_packet->duration = packet->duration(); | |
197 media_packet->end_of_stream = packet->end_of_stream(); | 195 media_packet->end_of_stream = packet->end_of_stream(); |
198 media_packet->payload = region.Pass(); | 196 media_packet->payload = region.Pass(); |
199 | 197 |
200 return media_packet.Pass(); | 198 return media_packet.Pass(); |
201 } | 199 } |
202 | 200 |
203 } // namespace media | 201 } // namespace media |
204 } // namespace mojo | 202 } // namespace mojo |
OLD | NEW |