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 #ifndef PPAPI_PROXY_AUDIO_ENCODER_RESOURCE_H_ | 5 #ifndef PPAPI_PROXY_AUDIO_ENCODER_RESOURCE_H_ |
6 #define PPAPI_PROXY_AUDIO_ENCODER_RESOURCE_H_ | 6 #define PPAPI_PROXY_AUDIO_ENCODER_RESOURCE_H_ |
7 | 7 |
8 #include "base/basictypes.h" | 8 #include "base/basictypes.h" |
9 #include "base/memory/ref_counted.h" | 9 #include "base/memory/ref_counted.h" |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
11 #include "base/memory/scoped_vector.h" | 11 #include "base/memory/scoped_vector.h" |
12 #include "ppapi/proxy/connection.h" | 12 #include "ppapi/proxy/connection.h" |
13 #include "ppapi/proxy/plugin_resource.h" | 13 #include "ppapi/proxy/plugin_resource.h" |
| 14 #include "ppapi/shared_impl/media_stream_buffer_manager.h" |
14 #include "ppapi/shared_impl/resource.h" | 15 #include "ppapi/shared_impl/resource.h" |
15 #include "ppapi/thunk/ppb_audio_encoder_api.h" | 16 #include "ppapi/thunk/ppb_audio_encoder_api.h" |
16 | 17 |
17 namespace ppapi { | 18 namespace ppapi { |
18 | 19 |
19 class TrackedCallback; | 20 class TrackedCallback; |
20 | 21 |
21 namespace proxy { | 22 namespace proxy { |
22 | 23 |
23 class SerializedHandle; | 24 class AudioBufferResource; |
24 class VideoFrameResource; | |
25 | 25 |
26 class PPAPI_PROXY_EXPORT AudioEncoderResource | 26 class PPAPI_PROXY_EXPORT AudioEncoderResource |
27 : public PluginResource, | 27 : public PluginResource, |
28 public thunk::PPB_AudioEncoder_API { | 28 public thunk::PPB_AudioEncoder_API, |
| 29 public ppapi::MediaStreamBufferManager::Delegate { |
29 public: | 30 public: |
30 AudioEncoderResource(Connection connection, PP_Instance instance); | 31 AudioEncoderResource(Connection connection, PP_Instance instance); |
31 ~AudioEncoderResource() override; | 32 ~AudioEncoderResource() override; |
32 | 33 |
33 thunk::PPB_AudioEncoder_API* AsPPB_AudioEncoder_API() override; | 34 thunk::PPB_AudioEncoder_API* AsPPB_AudioEncoder_API() override; |
34 | 35 |
35 private: | 36 private: |
36 // PPB_AduioEncoder_API implementation. | 37 // MediaStreamBufferManager::Delegate implementation. |
| 38 void OnNewBufferEnqueued() override {} |
| 39 |
| 40 // PPB_AudioEncoder_API implementation. |
37 int32_t GetSupportedProfiles( | 41 int32_t GetSupportedProfiles( |
38 const PP_ArrayOutput& output, | 42 const PP_ArrayOutput& output, |
39 const scoped_refptr<TrackedCallback>& callback) override; | 43 const scoped_refptr<TrackedCallback>& callback) override; |
40 int32_t Initialize(uint32_t channels, | 44 int32_t Initialize(uint32_t channels, |
41 PP_AudioBuffer_SampleRate input_sample_rate, | 45 PP_AudioBuffer_SampleRate input_sample_rate, |
42 PP_AudioBuffer_SampleSize input_sample_size, | 46 PP_AudioBuffer_SampleSize input_sample_size, |
43 PP_AudioProfile output_profile, | 47 PP_AudioProfile output_profile, |
44 uint32_t initial_bitrate, | 48 uint32_t initial_bitrate, |
45 PP_HardwareAcceleration acceleration, | 49 PP_HardwareAcceleration acceleration, |
46 const scoped_refptr<TrackedCallback>& callback) override; | 50 const scoped_refptr<TrackedCallback>& callback) override; |
47 int32_t GetNumberOfSamples() override; | 51 int32_t GetNumberOfSamples() override; |
48 int32_t GetBuffer(PP_Resource* audio_buffer, | 52 int32_t GetBuffer(PP_Resource* audio_buffer, |
49 const scoped_refptr<TrackedCallback>& callback) override; | 53 const scoped_refptr<TrackedCallback>& callback) override; |
50 int32_t Encode(PP_Resource audio_buffer, | 54 int32_t Encode(PP_Resource audio_buffer, |
51 const scoped_refptr<TrackedCallback>& callback) override; | 55 const scoped_refptr<TrackedCallback>& callback) override; |
52 int32_t GetBitstreamBuffer( | 56 int32_t GetBitstreamBuffer( |
53 PP_AudioBitstreamBuffer* bitstream_buffer, | 57 PP_AudioBitstreamBuffer* bitstream_buffer, |
54 const scoped_refptr<TrackedCallback>& callback) override; | 58 const scoped_refptr<TrackedCallback>& callback) override; |
55 void RecycleBitstreamBuffer( | 59 void RecycleBitstreamBuffer( |
56 const PP_AudioBitstreamBuffer* bitstream_buffer) override; | 60 const PP_AudioBitstreamBuffer* bitstream_buffer) override; |
57 void RequestBitrateChange(uint32_t bitrate) override; | 61 void RequestBitrateChange(uint32_t bitrate) override; |
58 void Close() override; | 62 void Close() override; |
59 | 63 |
| 64 // PluginResource implementation. |
| 65 void OnReplyReceived(const ResourceMessageReplyParams& params, |
| 66 const IPC::Message& msg) override; |
| 67 |
| 68 // Message handlers for the host's messages. |
| 69 void OnPluginMsgGetSupportedProfilesReply( |
| 70 const PP_ArrayOutput& output, |
| 71 const ResourceMessageReplyParams& params, |
| 72 const std::vector<PP_AudioProfileDescription>& profiles); |
| 73 void OnPluginMsgInitializeReply(const ResourceMessageReplyParams& params, |
| 74 int32_t number_of_samples, |
| 75 int32_t audio_buffer_count, |
| 76 int32_t audio_buffer_size, |
| 77 int32_t bitstream_buffer_count, |
| 78 int32_t bitstream_buffer_size); |
| 79 void OnPluginMsgEncodeReply(const ResourceMessageReplyParams& params, |
| 80 int32_t buffer_id); |
| 81 void OnPluginMsgBitstreamBufferReady(const ResourceMessageReplyParams& params, |
| 82 int32_t buffer_id); |
| 83 void OnPluginMsgNotifyError(const ResourceMessageReplyParams& params, |
| 84 int32_t error); |
| 85 |
| 86 // Internal utility functions. |
| 87 void NotifyError(int32_t error); |
| 88 void TryGetAudioBuffer(); |
| 89 void TryWriteBitstreamBuffer(); |
| 90 void ReleaseBuffers(); |
| 91 |
| 92 int32_t encoder_last_error_; |
| 93 |
| 94 bool initialized_; |
| 95 |
| 96 uint32_t number_of_samples_; |
| 97 |
| 98 using AudioBufferMap = |
| 99 std::map<PP_Resource, scoped_refptr<AudioBufferResource>>; |
| 100 AudioBufferMap audio_buffers_; |
| 101 |
| 102 scoped_refptr<TrackedCallback> get_supported_profiles_callback_; |
| 103 scoped_refptr<TrackedCallback> initialize_callback_; |
| 104 scoped_refptr<TrackedCallback> get_buffer_callback_; |
| 105 PP_Resource* get_buffer_data_; |
| 106 |
| 107 using EncodeMap = std::map<int32_t, scoped_refptr<TrackedCallback>>; |
| 108 EncodeMap encode_callbacks_; |
| 109 |
| 110 scoped_refptr<TrackedCallback> get_bitstream_buffer_callback_; |
| 111 PP_AudioBitstreamBuffer* get_bitstream_buffer_data_; |
| 112 |
| 113 MediaStreamBufferManager audio_buffer_manager_; |
| 114 MediaStreamBufferManager bitstream_buffer_manager_; |
| 115 |
| 116 // Map of bitstream buffer pointers to buffer ids. |
| 117 using BufferMap = std::map<void*, int32_t>; |
| 118 BufferMap bitstream_buffer_map_; |
| 119 |
60 DISALLOW_COPY_AND_ASSIGN(AudioEncoderResource); | 120 DISALLOW_COPY_AND_ASSIGN(AudioEncoderResource); |
61 }; | 121 }; |
62 | 122 |
63 } // namespace proxy | 123 } // namespace proxy |
64 } // namespace ppapi | 124 } // namespace ppapi |
65 | 125 |
66 #endif // PPAPI_PROXY_AUDIO_ENCODER_RESOURCE_H_ | 126 #endif // PPAPI_PROXY_AUDIO_ENCODER_RESOURCE_H_ |
OLD | NEW |