Method read

Engine/source/platform/async/asyncBufferedStream.h:236–273

template< typename T, typename Stream >
U32 AsyncBufferedInputStream< T, Stream >::read( ElementType* buffer, U32 num )
{
   if( !num )
      return 0;

   U32 numRead = 0;
   for( U32 i = 0; i < num; ++ i )
   {
      // Try to pop a element off the buffered element list.
   
      ElementType element;
      if( mBufferedElements.tryPopFront( element ) )
      {
         buffer[ i ] = element;
         numRead ++;
      }
      else
         break;
   }

   // Get the request chain going again, if it has stopped.
   
   while( 1 )
   {
      U32 numBuffered = mNumBufferedElements;
      U32 newNumBuffered = numBuffered - numRead;
      
      if( dCompareAndSwap( mNumBufferedElements, numBuffered, newNumBuffered ) )
      {
         if( numBuffered == mMaxBufferedElements )
            _requestNext();
         
         break;
      }
   }

   return numRead;
}


//=============================================================================