Method _requestNext

Engine/source/platform/async/asyncPacketStream.h:274–324

template< typename Stream, class Packet >
void AsyncPacketBufferedInputStream< Stream, Packet >::_requestNext()
{
   Stream& stream = this->getSourceStream();
   bool isEOS = !this->mNumRemainingSourceElements;
   if( isEOS && this->mIsLooping )
   {
      StreamType* s = &Deref( stream );
      IResettable* resettable = dynamic_cast< IResettable* >( s );
      if( resettable )
      {
         resettable->reset();
         isEOS = false;
         this->mNumRemainingSourceElements = mNumTotalSourceElements;
      }
   }
   else if( isEOS )
      return;

   //TODO: scale priority depending on feed status

   // Allocate a packet.

   U32 numElements = mPacketSize;
   PacketType* packet = _newPacket( numElements );
   packet->mIndex = mNextPacketIndex;
   mNextPacketIndex ++;

   // Queue a stream packet work item.

   if( numElements >= this->mNumRemainingSourceElements )
   {
      if( !this->mIsLooping )
      {
         this->mNumRemainingSourceElements = 0;
         packet->mIsLast = true;
      }
      else
         this->mNumRemainingSourceElements = ( this->mNumTotalSourceElements - numElements + this->mNumRemainingSourceElements );
   }
   else
      this->mNumRemainingSourceElements -= numElements;
      
   #ifdef DEBUG_SPEW
   Platform::outputDebugString( "[AsyncPacketStream] packet %i, %i remaining, %i total",
      packet->mIndex, this->mNumRemainingSourceElements, mNumTotalSourceElements );
   #endif

   ThreadSafeRef< PacketReadItem > workItem;
   _newReadItem( workItem, packet, numElements );
   this->mThreadPool->queueWorkItem( workItem );
}

#undef DEBUG_SPEW
#endif // !_ASYNCPACKETSTREAM_H_