Minor robustness improvements for VTVideoDecodeAccelerator.

content/common/gpu/media/vt_video_decode_accelerator.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include <algorithm>
 
 #include <CoreVideo/CoreVideo.h>
 #include <OpenGL/CGLIOSurface.h>
 #include <OpenGL/gl.h>
 
@@ skipping 614 matching lines @@
   }
 }
 
 // This method may be called on any VideoToolbox thread.
 void VTVideoDecodeAccelerator::Output(
     void* source_frame_refcon,
     OSStatus status,
     CVImageBufferRef image_buffer) {
   if (status) {
     NOTIFY_STATUS("Decoding", status);
-  } else if (CFGetTypeID(image_buffer) != CVPixelBufferGetTypeID()) {
+  } else if (!image_buffer ||

[DaleCurtis, 2015/02/04 22:38:52]

Needs a comment if this is unexpected.

+             (CFGetTypeID(image_buffer) != CVPixelBufferGetTypeID())) {
     DLOG(ERROR) << "Decoded frame is not a CVPixelBuffer";
     NotifyError(PLATFORM_FAILURE);
   } else {
     Frame* frame = reinterpret_cast<Frame*>(source_frame_refcon);
     frame->image.reset(image_buffer, base::scoped_policy::RETAIN);
     gpu_task_runner_->PostTask(FROM_HERE, base::Bind(
         &VTVideoDecodeAccelerator::DecodeDone, weak_this_, frame));
   }
 }
 
@@ skipping 62 matching lines @@
   } else {
     client_->DismissPictureBuffer(picture_id);
   }
 }
 
 void VTVideoDecodeAccelerator::ProcessWorkQueues() {
   DCHECK(gpu_thread_checker_.CalledOnValidThread());
   switch (state_) {
     case STATE_DECODING:
       // TODO(sandersd): Batch where possible.
-      while (ProcessReorderQueue() || ProcessTaskQueue());
+      while (state_ == STATE_DECODING) {
+        if (!ProcessReorderQueue() && !ProcessTaskQueue())
+          break;
+      }
       return;
 
     case STATE_ERROR:
       // Do nothing until Destroy() is called.
       return;
 
     case STATE_DESTROYING:
       // Drop tasks until we are ready to destruct.
       while (!task_queue_.empty()) {
         if (task_queue_.front().type == TASK_DESTROY) {
@@ skipping 212 matching lines @@
   assigned_bitstream_ids_.clear();
   state_ = STATE_DESTROYING;
   QueueFlush(TASK_DESTROY);
 }
 
 bool VTVideoDecodeAccelerator::CanDecodeOnIOThread() {
   return false;
 }
 
 }  // namespace content