Reset decompressor after each frame in DecoderRowBased::DecodePacket().

remoting/base/decoder_row_based.cc

 // Copyright (c) 2010 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 "remoting/base/decoder_row_based.h"
 
 #include "remoting/base/decompressor.h"
 #include "remoting/base/decompressor_zlib.h"
 #include "remoting/base/decompressor_verbatim.h"
 #include "remoting/base/util.h"
@@ skipping 102 matching lines @@
     row_pos_ += written;
 
     // If this row is completely filled then move onto the next row.
     if (row_pos_ == row_size) {
       ++row_y_;
       row_pos_ = 0;
       out += stride;
     }
   }
 
-  if (state_ == kDone && row_y_ < clip_.height()) {
-    state_ = kError;
-    LOG(WARNING) << "Received LAST_PACKET, but didn't get enough data.";
-    return DECODE_ERROR;
+  if (state_ == kDone) {
+    if (row_y_ < clip_.height()) {
+      state_ = kError;
+      return DECODE_ERROR;
+    }
+
+    decompressor_->Reset();
+    return DECODE_DONE;
+  } else {
+    return DECODE_IN_PROGRESS;
   }
-
-  return state_ == kDone ? DECODE_DONE : DECODE_IN_PROGRESS;
 }
 
 void DecoderRowBased::UpdateStateForPacket(const VideoPacket* packet) {
   if (state_ == kError) {
     return;
   }
 
   if (packet->flags() & VideoPacket::FIRST_PACKET) {
     if (state_ != kReady && state_ != kDone) {
       state_ = kError;
@@ skipping 29 matching lines @@
 
 void DecoderRowBased::GetUpdatedRects(UpdatedRects* rects) {
   rects->push_back(clip_);
 }
 
 VideoPacketFormat::Encoding DecoderRowBased::Encoding() {
   return encoding_;
 }
 
 }  // namespace remoting