anonymous_namespace{ScrubState.cpp}::ScrubQueue Struct Reference

Inheritance diagram for anonymous_namespace{ScrubState.cpp}::ScrubQueue:

Collaboration diagram for anonymous_namespace{ScrubState.cpp}::ScrubQueue:

Classes
struct	Data
struct	Message

Public Member Functions
	ScrubQueue ()
void	Init (double t0, double rate, const ScrubbingOptions &options)
void	Update (double end, const ScrubbingOptions &options)
void	Get (sampleCount &startSample, sampleCount &endSample, sampleCount inDuration, sampleCount &duration)
void	Stop ()
double	LastTrackTime () const
	~ScrubQueue ()
bool	Started () const

Static Public Attributes
static ScrubQueue	Instance

Private Attributes
double	mStartTime {}
bool	mStarted { false }
std::atomic< bool >	mStopped { false }
Data	mData
double	mRate {}
MessageBuffer< Message >	mMessage
sampleCount	mAccumulatedSeekDuration {}

Detailed Description

Definition at line 16 of file ScrubState.cpp.

Constructor & Destructor Documentation

ScrubQueue()

anonymous_namespace{ScrubState.cpp}::ScrubQueue::ScrubQueue ( )

inline

Definition at line 20 of file ScrubState.cpp.

{}

~ScrubQueue()

anonymous_namespace{ScrubState.cpp}::ScrubQueue::~ScrubQueue ( )

inline

Definition at line 123 of file ScrubState.cpp.

{}

Member Function Documentation

Get()

void anonymous_namespace{ScrubState.cpp}::ScrubQueue::Get ( sampleCount &  startSample, sampleCount &  endSample, sampleCount  inDuration, sampleCount &  duration  )

inline

Definition at line 42 of file ScrubState.cpp.

   {
      // Called by the thread that calls AudioIO::SequenceBufferExchange
      startSample = endSample = duration = -1LL;
      sampleCount s0Init;
 
      Message message( mMessage.Read() );
      if ( !mStarted ) {
         s0Init = llrint( mRate *
            std::max( message.options.minTime,
               std::min( message.options.maxTime, mStartTime ) ) );
 
         // Make some initial silence. This is not needed in the case of
         // keyboard scrubbing or play-at-speed, because the initial speed
         // is known when this function is called the first time.
         if ( !(message.options.isKeyboardScrubbing) ) {
            mData.mS0 = mData.mS1 = s0Init;
            mData.mGoal = -1;
            mData.mDuration = duration = inDuration;
            mData.mSilence = 0;
         }
      }
 
      if (mStarted || message.options.isKeyboardScrubbing) {
         Data newData;
         inDuration += mAccumulatedSeekDuration;
 
         // If already started, use the previous end as NEW start.
         const auto s0 = mStarted ? mData.mS1 : s0Init;
         const sampleCount s1 ( message.options.bySpeed
            ? s0.as_double() +
               lrint(inDuration.as_double() * message.end) // end is a speed
            : lrint(message.end * mRate)            // end is a time
         );
         auto success =
            newData.Init(mData, s0, s1, inDuration, message.options, mRate);
         if (success)
            mAccumulatedSeekDuration = 0;
         else {
            mAccumulatedSeekDuration += inDuration;
            return;
         }
         mData = newData;
      };
 
      mStarted = true;
 
      Data &entry = mData;
      if (  mStopped.load( std::memory_order_relaxed ) ) {
         // We got the shut-down signal, or we discarded all the work.
         // Output the -1 values.
      }
      else if (entry.mDuration > 0) {
         // First use of the entry
         startSample = entry.mS0;
         endSample = entry.mS1;
         duration = entry.mDuration;
         entry.mDuration = 0;
      }
      else if (entry.mSilence > 0) {
         // Second use of the entry
         startSample = endSample = entry.mS1;
         duration = entry.mSilence;
         entry.mSilence = 0;
      }
   }

References sampleCount::as_double(), ScrubbingOptions::bySpeed, anonymous_namespace{ScrubState.cpp}::ScrubQueue::Message::end, entry, anonymous_namespace{ScrubState.cpp}::ScrubQueue::Data::Init(), ScrubbingOptions::isKeyboardScrubbing, lrint, ScrubbingOptions::maxTime, min(), ScrubbingOptions::minTime, and anonymous_namespace{ScrubState.cpp}::ScrubQueue::Message::options.

Here is the call graph for this function:

Init()

void anonymous_namespace{ScrubState.cpp}::ScrubQueue::Init ( double  t0, double  rate, const ScrubbingOptions &  options  )

inline

Definition at line 22 of file ScrubState.cpp.

   {
      mRate = rate;
      mStartTime = t0;
      const double t1 = options.bySpeed ? options.initSpeed : t0;
      Update( t1, options );
 
      mStarted = false;
      mStopped = false;
      mAccumulatedSeekDuration = 0;
   }

References ScrubbingOptions::bySpeed, and ScrubbingOptions::initSpeed.

LastTrackTime()

double anonymous_namespace{ScrubState.cpp}::ScrubQueue::LastTrackTime ( ) const

inline

Definition at line 117 of file ScrubState.cpp.

   {
      // Needed by the main thread sometimes
      return mData.mS1.as_double() / mRate;
   }

Started()

bool anonymous_namespace{ScrubState.cpp}::ScrubQueue::Started ( ) const

inline

Definition at line 125 of file ScrubState.cpp.

{ return mStarted; }

Stop()

void anonymous_namespace{ScrubState.cpp}::ScrubQueue::Stop ( )

inline

Definition at line 110 of file ScrubState.cpp.

   {
      mStopped.store( true, std::memory_order_relaxed );
      mStarted = false;
   }

Update()

void anonymous_namespace{ScrubState.cpp}::ScrubQueue::Update ( double  end, const ScrubbingOptions &  options  )

inline

Definition at line 36 of file ScrubState.cpp.

   {
      // Called by another thread
      mMessage.Write({ end, options });
   }

References details::end().

Here is the call graph for this function:

Member Data Documentation

Instance

ScrubQueue anonymous_namespace{ScrubState.cpp}::ScrubQueue::Instance

static

Definition at line 18 of file ScrubState.cpp.

mAccumulatedSeekDuration

sampleCount anonymous_namespace{ScrubState.cpp}::ScrubQueue::mAccumulatedSeekDuration {}

private

Definition at line 287 of file ScrubState.cpp.

mData

Data anonymous_namespace{ScrubState.cpp}::ScrubQueue::mData

private

Definition at line 278 of file ScrubState.cpp.

mMessage

MessageBuffer<Message> anonymous_namespace{ScrubState.cpp}::ScrubQueue::mMessage

private

Definition at line 286 of file ScrubState.cpp.

mRate

double anonymous_namespace{ScrubState.cpp}::ScrubQueue::mRate {}

private

Definition at line 279 of file ScrubState.cpp.

mStarted

bool anonymous_namespace{ScrubState.cpp}::ScrubQueue::mStarted { false }

private

Definition at line 276 of file ScrubState.cpp.

mStartTime

double anonymous_namespace{ScrubState.cpp}::ScrubQueue::mStartTime {}

private

Definition at line 275 of file ScrubState.cpp.

mStopped

std::atomic<bool> anonymous_namespace{ScrubState.cpp}::ScrubQueue::mStopped { false }

private

Definition at line 277 of file ScrubState.cpp.

---

The documentation for this struct was generated from the following file:

• ScrubState.cpp