[DO NOT SUBMIT] AudioWorklet FS2a: AudioWorkletThread on OfflineAudioContext

third_party/WebKit/Source/modules/webaudio/OfflineAudioDestinationNode.cpp

 /*
  * 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
@@ skipping 23 matching lines @@
 #include "public/platform/Platform.h"
 #include <algorithm>
 
 namespace blink {
 
 const size_t OfflineAudioDestinationHandler::renderQuantumSize = 128;
 
 OfflineAudioDestinationHandler::OfflineAudioDestinationHandler(AudioNode& node, AudioBuffer* renderTarget)
     : AudioDestinationHandler(node, renderTarget->sampleRate())
     , m_renderTarget(renderTarget)
-    , m_renderThread(adoptPtr(Platform::current()->createThread("offline audio renderer")))
     , m_framesProcessed(0)
     , m_framesToProcess(0)
     , m_isRenderingStarted(false)
     , m_shouldSuspend(false)
 {
+    m_renderThread = AudioWorkletThread::create(*this);
+    // m_renderThread->initialize(frame, std::move(startUpData));
+
     m_renderBus = AudioBus::create(renderTarget->numberOfChannels(), renderQuantumSize);
     m_framesToProcess = m_renderTarget->length();
 }
 
 PassRefPtr<OfflineAudioDestinationHandler> OfflineAudioDestinationHandler::create(AudioNode& node, AudioBuffer* renderTarget)
 {
     return adoptRef(new OfflineAudioDestinationHandler(node, renderTarget));
 }
 
 OfflineAudioDestinationHandler::~OfflineAudioDestinationHandler()
@@ skipping 36 matching lines @@
     ASSERT(isMainThread());
     ASSERT(m_renderThread);
     ASSERT(m_renderTarget);
 
     if (!m_renderTarget)
         return;
 
     // Rendering was not started. Starting now.
     if (!m_isRenderingStarted) {
         m_isRenderingStarted = true;
-        m_renderThread->getWebTaskRunner()->postTask(BLINK_FROM_HERE,
+        m_renderThread->audioRenderThread().postTask(BLINK_FROM_HERE,
             threadSafeBind(&OfflineAudioDestinationHandler::startOfflineRendering, this));
         return;
     }
 
     // Rendering is already started, which implicitly means we resume the
     // rendering by calling |doOfflineRendering| on the render thread.
-    m_renderThread->getWebTaskRunner()->postTask(BLINK_FROM_HERE,
+    m_renderThread->audioRenderThread().postTask(BLINK_FROM_HERE,
         threadSafeBind(&OfflineAudioDestinationHandler::doOfflineRendering, this));
 }
 
 void OfflineAudioDestinationHandler::stopRendering()
 {
     // offline audio rendering CANNOT BE stopped by JavaScript.
     ASSERT_NOT_REACHED();
 }
 
-WebThread* OfflineAudioDestinationHandler::offlineRenderThread()
+AudioWorkletThread* OfflineAudioDestinationHandler::offlineRenderThread()
 {
     ASSERT(m_renderThread);
 
     return m_renderThread.get();
 }
 
 void OfflineAudioDestinationHandler::startOfflineRendering()
 {
     ASSERT(!isMainThread());
 
@@ skipping 181 matching lines @@
 {
     setHandler(OfflineAudioDestinationHandler::create(*this, renderTarget));
 }
 
 OfflineAudioDestinationNode* OfflineAudioDestinationNode::create(AbstractAudioContext* context, AudioBuffer* renderTarget)
 {
     return new OfflineAudioDestinationNode(*context, renderTarget);
 }
 
 } // namespace blink