Chromium Code Reviews

Side by Side Diff: services/media/framework_mojo/mojo_consumer.cc

Issue 1822333002: Motown: wholesale clang-format (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: dalesat Created 4 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
View unified diff |
OLDNEW
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/logging.h" 6 #include "base/logging.h"
7 #include "base/message_loop/message_loop.h" 7 #include "base/message_loop/message_loop.h"
8 #include "services/media/framework_mojo/mojo_consumer.h" 8 #include "services/media/framework_mojo/mojo_consumer.h"
9 9
10 namespace mojo { 10 namespace mojo {
(...skipping 17 matching lines...)
28 void MojoConsumer::SetPrimeRequestedCallback( 28 void MojoConsumer::SetPrimeRequestedCallback(
29 const PrimeRequestedCallback& callback) { 29 const PrimeRequestedCallback& callback) {
30 prime_requested_callback_ = callback; 30 prime_requested_callback_ = callback;
31 } 31 }
32 32
33 void MojoConsumer::SetFlushRequestedCallback( 33 void MojoConsumer::SetFlushRequestedCallback(
34 const FlushRequestedCallback& callback) { 34 const FlushRequestedCallback& callback) {
35 flush_requested_callback_ = callback; 35 flush_requested_callback_ = callback;
36 } 36 }
37 37
38 void MojoConsumer::SetBuffer( 38 void MojoConsumer::SetBuffer(ScopedSharedBufferHandle buffer,
39 ScopedSharedBufferHandle buffer, 39 const SetBufferCallback& callback) {
40 const SetBufferCallback& callback) {
41 buffer_.InitFromHandle(buffer.Pass()); 40 buffer_.InitFromHandle(buffer.Pass());
42 callback.Run(); 41 callback.Run();
43 } 42 }
44 43
45 void MojoConsumer::SendPacket( 44 void MojoConsumer::SendPacket(MediaPacketPtr media_packet,
46 MediaPacketPtr media_packet, 45 const SendPacketCallback& callback) {
47 const SendPacketCallback& callback) {
48 DCHECK(media_packet); 46 DCHECK(media_packet);
49 DCHECK(supply_callback_); 47 DCHECK(supply_callback_);
50 supply_callback_(PacketImpl::Create( 48 supply_callback_(
51 media_packet.Pass(), 49 PacketImpl::Create(media_packet.Pass(), callback, task_runner_, buffer_));
52 callback,
53 task_runner_,
54 buffer_));
55 } 50 }
56 51
57 void MojoConsumer::Prime(const PrimeCallback& callback) { 52 void MojoConsumer::Prime(const PrimeCallback& callback) {
58 if (prime_requested_callback_) { 53 if (prime_requested_callback_) {
59 prime_requested_callback_(callback); 54 prime_requested_callback_(callback);
60 } else { 55 } else {
61 LOG(WARNING) << "prime requested but no callback registered"; 56 LOG(WARNING) << "prime requested but no callback registered";
62 callback.Run(); 57 callback.Run();
63 } 58 }
64 } 59 }
(...skipping 18 matching lines...)
83 void MojoConsumer::SetSupplyCallback(const SupplyCallback& supply_callback) { 78 void MojoConsumer::SetSupplyCallback(const SupplyCallback& supply_callback) {
84 supply_callback_ = supply_callback; 79 supply_callback_ = supply_callback;
85 } 80 }
86 81
87 void MojoConsumer::SetDownstreamDemand(Demand demand) {} 82 void MojoConsumer::SetDownstreamDemand(Demand demand) {}
88 83
89 MojoConsumer::PacketImpl::PacketImpl( 84 MojoConsumer::PacketImpl::PacketImpl(
90 MediaPacketPtr media_packet, 85 MediaPacketPtr media_packet,
91 const SendPacketCallback& callback, 86 const SendPacketCallback& callback,
92 scoped_refptr<base::SingleThreadTaskRunner> task_runner, 87 scoped_refptr<base::SingleThreadTaskRunner> task_runner,
93 const MappedSharedBuffer& buffer) : 88 const MappedSharedBuffer& buffer)
94 Packet( 89 : Packet(media_packet->pts,
95 media_packet->pts, 90 media_packet->end_of_stream,
96 media_packet->end_of_stream, 91 media_packet->payload->length,
97 media_packet->payload->length, 92 media_packet->payload->length == 0
98 media_packet->payload->length == 0 ? 93 ? nullptr
99 nullptr : 94 : buffer.PtrFromOffset(media_packet->payload->offset)),
100 buffer.PtrFromOffset(media_packet->payload->offset)), 95 media_packet_(media_packet.Pass()),
101 media_packet_(media_packet.Pass()), 96 callback_(callback),
102 callback_(callback), 97 task_runner_(task_runner) {}
103 task_runner_(task_runner) {}
104 98
105 MojoConsumer::PacketImpl::~PacketImpl() {} 99 MojoConsumer::PacketImpl::~PacketImpl() {}
106 100
107 // static 101 // static
108 void MojoConsumer::PacketImpl::RunCallback(const SendPacketCallback& callback) { 102 void MojoConsumer::PacketImpl::RunCallback(const SendPacketCallback& callback) {
109 callback.Run(MediaConsumer::SendResult::CONSUMED); 103 callback.Run(MediaConsumer::SendResult::CONSUMED);
110 } 104 }
111 105
112 void MojoConsumer::PacketImpl::Release() { 106 void MojoConsumer::PacketImpl::Release() {
113 // TODO(dalesat): Is there a cleaner way to do this? 107 // TODO(dalesat): Is there a cleaner way to do this?
114 task_runner_->PostTask(FROM_HERE, base::Bind(&RunCallback, callback_)); 108 task_runner_->PostTask(FROM_HERE, base::Bind(&RunCallback, callback_));
115 delete this; 109 delete this;
116 } 110 }
117 111
118 } // namespace media 112 } // namespace media
119 } // namespace mojo 113 } // namespace mojo
OLDNEW
« no previous file with comments | « services/media/framework_mojo/mojo_consumer.h ('k') | services/media/framework_mojo/mojo_formatting.h » ('j') | no next file with comments »

Powered by Google App Engine