Implementation of 'AudioContext.getOutputTimestamp' method

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

 /*
  * Copyright (C) 2010, 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 672 matching lines @@
         // touched as its handler may have been released already.
         if (m_finishedSourceNodes.contains(node))
             continue;
         if (node->handler().getNodeType() == AudioHandler::NodeTypeAudioBufferSource) {
             AudioBufferSourceNode* sourceNode = static_cast<AudioBufferSourceNode*>(node);
             sourceNode->audioBufferSourceHandler().handleStoppableSourceNode();
         }
     }
 }
 
-void AbstractAudioContext::handlePreRenderTasks()
+void AbstractAudioContext::handlePreRenderTasks(const WebAudioTimestamp& outputTimestamp)
 {
     ASSERT(isAudioThread());
 
     // At the beginning of every render quantum, try to update the internal rendering graph state (from main thread changes).
     // It's OK if the tryLock() fails, we'll just take slightly longer to pick up the changes.
     if (tryLock()) {
         deferredTaskHandler().handleDeferredTasks();
 
         resolvePromisesForResume();
 
         // Check to see if source nodes can be stopped because the end time has passed.
         handleStoppableSourceNodes();
 
         // Update the dirty state of the listener.
         listener()->updateState();
 
+        // Update output timestamp.
+        m_outputTimestamp = outputTimestamp;
+
         unlock();
     }
 }
 
 void AbstractAudioContext::handlePostRenderTasks()
 {
     ASSERT(isAudioThread());
 
     // Must use a tryLock() here too.  Don't worry, the lock will very rarely be contended and this method is called frequently.
     // The worst that can happen is that there will be some nodes which will take slightly longer than usual to be deleted or removed
@@ skipping 46 matching lines @@
 }
 
 void AbstractAudioContext::rejectPendingDecodeAudioDataResolvers()
 {
     // Now reject any pending decodeAudioData resolvers
     for (auto& resolver : m_decodeAudioResolvers)
         resolver->reject(DOMException::create(InvalidStateError, "Audio context is going away"));
     m_decodeAudioResolvers.clear();
 }
 
+WebAudioTimestamp AbstractAudioContext::outputTimestamp()
+{
+    AutoLocker locker(this);
+    return m_outputTimestamp;
+}
+
 void AbstractAudioContext::rejectPendingResolvers()
 {
     ASSERT(isMainThread());
 
     // Audio context is closing down so reject any resume promises that are still pending.
 
     for (auto& resolver : m_resumeResolvers) {
         resolver->reject(DOMException::create(InvalidStateError, "Audio context is going away"));
     }
     m_resumeResolvers.clear();
@@ skipping 44 matching lines @@
 
 SecurityOrigin* AbstractAudioContext::getSecurityOrigin() const
 {
     if (getExecutionContext())
         return getExecutionContext()->getSecurityOrigin();
 
     return nullptr;
 }
 
 } // namespace blink