1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
/*
* Copyright (C) 2011, Google Inc. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
* ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include "config.h"
#if ENABLE(WEB_AUDIO)
#include "AsyncAudioDecoder.h"
#include "AudioBuffer.h"
#include "AudioBufferCallback.h"
#include <JavaScriptCore/ArrayBuffer.h>
#include <wtf/MainThread.h>
namespace WebCore {
AsyncAudioDecoder::AsyncAudioDecoder()
{
// Start worker thread.
Locker locker { m_threadCreationMutex };
m_thread = Thread::create("Audio Decoder", [this] {
runLoop();
}, ThreadType::Audio);
}
AsyncAudioDecoder::~AsyncAudioDecoder()
{
m_queue.kill();
// Stop thread.
m_thread->waitForCompletion();
}
void AsyncAudioDecoder::decodeAsync(Ref<ArrayBuffer>&& audioData, float sampleRate, Function<void(ExceptionOr<Ref<AudioBuffer>>&&)>&& callback)
{
ASSERT(isMainThread());
auto decodingTask = makeUnique<DecodingTask>(WTFMove(audioData), sampleRate, WTFMove(callback));
m_queue.append(WTFMove(decodingTask)); // note that ownership of the task is effectively taken by the queue.
}
void AsyncAudioDecoder::runLoop()
{
ASSERT(!isMainThread());
{
// Wait for until we have m_thread established before starting the run loop.
Locker locker { m_threadCreationMutex };
}
// Keep running decoding tasks until we're killed.
while (auto decodingTask = m_queue.waitForMessage()) {
// Let the task take care of its own ownership.
// See DecodingTask::notifyComplete() for cleanup.
decodingTask.release()->decode();
}
}
AsyncAudioDecoder::DecodingTask::DecodingTask(Ref<ArrayBuffer>&& audioData, float sampleRate, Function<void(ExceptionOr<Ref<AudioBuffer>>&&)>&& callback)
: m_audioData(WTFMove(audioData))
, m_sampleRate(sampleRate)
, m_callback(WTFMove(callback))
{
}
void AsyncAudioDecoder::DecodingTask::decode()
{
// Do the actual decoding and invoke the callback.
m_audioBuffer = AudioBuffer::createFromAudioFileData(m_audioData->data(), m_audioData->byteLength(), false, sampleRate());
// Decoding is finished, but we need to do the callbacks on the main thread.
callOnMainThread([this] {
notifyComplete();
});
}
void AsyncAudioDecoder::DecodingTask::notifyComplete()
{
if (auto* audioBuffer = this->audioBuffer())
callback()(Ref { *audioBuffer });
else
callback()(Exception { EncodingError, "Decoding failed"_s });
// Our ownership was given up in AsyncAudioDecoder::runLoop()
// Make sure to clean up here.
delete this;
}
} // namespace WebCore
#endif // ENABLE(WEB_AUDIO)
|
