Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(362)

Side by Side Diff: services/media/common/media_pipe_base.h

Issue 2097953002: Motown: Rename MediaProducer/Consumer to MediaPacketProducer/Consumer (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Fixed #ifndef guards Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 #ifndef SERVICES_MEDIA_COMMON_MEDIA_PIPE_BASE_H_ 5 #ifndef SERVICES_MEDIA_COMMON_MEDIA_PIPE_BASE_H_
6 #define SERVICES_MEDIA_COMMON_MEDIA_PIPE_BASE_H_ 6 #define SERVICES_MEDIA_COMMON_MEDIA_PIPE_BASE_H_
7 7
8 #include <atomic> 8 #include <atomic>
9 #include <deque> 9 #include <deque>
10 #include <memory> 10 #include <memory>
11 11
12 #include "base/synchronization/lock.h" 12 #include "base/synchronization/lock.h"
13 #include "base/task_runner.h" 13 #include "base/task_runner.h"
14 #include "mojo/public/cpp/bindings/binding.h" 14 #include "mojo/public/cpp/bindings/binding.h"
15 #include "mojo/public/cpp/system/buffer.h" 15 #include "mojo/public/cpp/system/buffer.h"
16 #include "mojo/services/media/common/interfaces/media_transport.mojom.h" 16 #include "mojo/services/media/common/interfaces/media_transport.mojom.h"
17 17
18 namespace mojo { 18 namespace mojo {
19 namespace media { 19 namespace media {
20 20
21 class MediaPipeBase : public MediaConsumer { 21 class MediaPipeBase : public MediaPacketConsumer {
22 protected: 22 protected:
23 class MappedSharedBuffer; 23 class MappedSharedBuffer;
24 using MappedSharedBufferPtr = std::shared_ptr<MappedSharedBuffer>; 24 using MappedSharedBufferPtr = std::shared_ptr<MappedSharedBuffer>;
25 25
26 public: 26 public:
27 class MediaPacketState { 27 class MediaPacketState {
28 public: 28 public:
29 ~MediaPacketState(); 29 ~MediaPacketState();
30 30
31 const MediaPacketPtr& packet() const { return packet_; } 31 const MediaPacketPtr& packet() const { return packet_; }
32 const MappedSharedBufferPtr& buffer() const { return buffer_; } 32 const MappedSharedBufferPtr& buffer() const { return buffer_; }
33 void SetResult(MediaConsumer::SendResult result); 33 void SetResult(MediaPacketConsumer::SendResult result);
34 34
35 private: 35 private:
36 friend class MediaPipeBase; 36 friend class MediaPipeBase;
37 MediaPacketState(MediaPacketPtr packet, 37 MediaPacketState(MediaPacketPtr packet,
38 const MappedSharedBufferPtr& buffer, 38 const MappedSharedBufferPtr& buffer,
39 const SendPacketCallback& cbk); 39 const SendPacketCallback& cbk);
40 40
41 MediaPacketPtr packet_; 41 MediaPacketPtr packet_;
42 MappedSharedBufferPtr buffer_; 42 MappedSharedBufferPtr buffer_;
43 SendPacketCallback cbk_; 43 SendPacketCallback cbk_;
44 std::atomic<MediaConsumer::SendResult> result_; 44 std::atomic<MediaPacketConsumer::SendResult> result_;
45 }; 45 };
46 using MediaPacketStatePtr = std::unique_ptr<MediaPacketState>; 46 using MediaPacketStatePtr = std::unique_ptr<MediaPacketState>;
47 47
48 // Default constructor and destructor 48 // Default constructor and destructor
49 MediaPipeBase(); 49 MediaPipeBase();
50 ~MediaPipeBase() override; 50 ~MediaPipeBase() override;
51 51
52 // Initialize the internal state of the pipe (allocate resources, etc..) 52 // Initialize the internal state of the pipe (allocate resources, etc..)
53 MojoResult Init(InterfaceRequest<MediaConsumer> request); 53 MojoResult Init(InterfaceRequest<MediaPacketConsumer> request);
54 54
55 bool IsInitialized() const; 55 bool IsInitialized() const;
56 void Reset(); 56 void Reset();
57 57
58 protected: 58 protected:
59 class MappedSharedBuffer { 59 class MappedSharedBuffer {
60 public: 60 public:
61 static MappedSharedBufferPtr Create(ScopedSharedBufferHandle handle, 61 static MappedSharedBufferPtr Create(ScopedSharedBufferHandle handle,
62 uint64_t size); 62 uint64_t size);
63 ~MappedSharedBuffer(); 63 ~MappedSharedBuffer();
(...skipping 11 matching lines...) Expand all
75 }; 75 };
76 76
77 // Interface to be implemented by derived classes 77 // Interface to be implemented by derived classes
78 virtual void OnPacketReceived(MediaPacketStatePtr state) = 0; 78 virtual void OnPacketReceived(MediaPacketStatePtr state) = 0;
79 virtual void OnPrimeRequested(const PrimeCallback& cbk) = 0; 79 virtual void OnPrimeRequested(const PrimeCallback& cbk) = 0;
80 virtual bool OnFlushRequested(const FlushCallback& cbk) = 0; 80 virtual bool OnFlushRequested(const FlushCallback& cbk) = 0;
81 81
82 MappedSharedBufferPtr buffer_; 82 MappedSharedBufferPtr buffer_;
83 83
84 private: 84 private:
85 Binding<MediaConsumer> binding_; 85 Binding<MediaPacketConsumer> binding_;
86 86
87 // MediaConsumer.mojom implementation. 87 // MediaPacketConsumer.mojom implementation.
88 void SetBuffer(ScopedSharedBufferHandle handle, 88 void SetBuffer(ScopedSharedBufferHandle handle,
89 const SetBufferCallback& cbk) final; 89 const SetBufferCallback& cbk) final;
90 void SendPacket(MediaPacketPtr packet, 90 void SendPacket(MediaPacketPtr packet,
91 const SendPacketCallback& cbk) final; 91 const SendPacketCallback& cbk) final;
92 void Prime(const PrimeCallback& cbk) final; 92 void Prime(const PrimeCallback& cbk) final;
93 void Flush(const FlushCallback& cbk) final; 93 void Flush(const FlushCallback& cbk) final;
94 }; 94 };
95 95
96 } // namespace media 96 } // namespace media
97 } // namespace mojo 97 } // namespace mojo
98 98
99 #endif // SERVICES_MEDIA_COMMON_MEDIA_PIPE_BASE_H_ 99 #endif // SERVICES_MEDIA_COMMON_MEDIA_PIPE_BASE_H_
OLDNEW
« no previous file with comments | « services/media/audio/audio_track_to_output_link.cc ('k') | services/media/common/media_pipe_base.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698