Method read

Engine/source/core/ogg/oggTheoraDecoder.cpp:253–317

//-----------------------------------------------------------------------------

U32 OggTheoraDecoder::read( OggTheoraFrame** buffer, U32 num )
{
   #ifdef TORQUE_DEBUG
   AssertFatal( dCompareAndSwap( mLock, 0, 1 ), "OggTheoraDecoder::read() - simultaneous reads not thread-safe" );
   #endif
   
   U32 numRead = 0;
   
   for( U32 i = 0; i < num; ++ i )
   {
      // Read and decode a packet.
      
      if( !_nextPacket() )
         return numRead; // End of stream.
      
      // Decode the frame to Y'CbCr.
      
      th_ycbcr_buffer ycbcr;
      th_decode_ycbcr_out( mTheoraDecoder, ycbcr );
      
      // Allocate a packet.
      
      const U32 width = getFrameWidth();
      const U32 height = getFrameHeight();
      
      OggTheoraFrame* packet;
      if( !mFreePackets.tryPopFront( packet ) )
         packet = constructSingle< OggTheoraFrame* >( mPacketFormat.mPitch * height );
         
      packet->mFrameNumber = mCurrentFrameNumber;
      packet->mFrameTime = mCurrentFrameTime;
      packet->mFrameDuration = mFrameDuration;
      
      // Transcode the packet.
      
      #if ( defined( TORQUE_COMPILER_GCC ) || defined( TORQUE_COMPILER_VISUALC ) ) && (defined( TORQUE_CPU_X86 ) )      
      if(      ( mTranscoder == TRANSCODER_Auto || mTranscoder == TRANSCODER_SSE2420RGBA ) &&
               getDecoderPixelFormat() == PIXEL_FORMAT_420 &&
               Platform::SystemInfo.processor.properties & CPU_PROP_SSE2 &&
               mPacketFormat.mFormat == GFXFormatR8G8B8A8 &&
               mTheoraInfo.pic_x == 0 &&
               mTheoraInfo.pic_y == 0 )
      {
         _transcode420toRGBA_SSE2( ycbcr, ( U8* ) packet->data, width, height, mPacketFormat.mPitch );
      }
      else
      
      #endif
      
      {
         // Use generic transcoder.
         
         _transcode( ycbcr, ( U8* ) packet->data, width, height );
      }
                  
      buffer[ i ] = packet;
      ++ numRead;
   }