Add WARN_UNUSED_RESULT to BytesConsumer read methods.

third_party/WebKit/Source/modules/fetch/FetchDataLoader.cpp

 // Copyright 2015 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 "modules/fetch/FetchDataLoader.h"
 
 #include "core/html/parser/TextResourceDecoder.h"
 #include "modules/fetch/BytesConsumer.h"
 #include "wtf/PtrUtil.h"
 #include "wtf/text/StringBuilder.h"
@@ skipping 45 matching lines @@
     }
 
     void onStateChange() override
     {
         while (true) {
             const char* buffer;
             size_t available;
             switch (m_consumer->beginRead(&buffer, &available)) {
             case BytesConsumer::Result::Ok:
                 m_blobData->appendBytes(buffer, available);
-                m_consumer->endRead(available);
+                if (m_consumer->endRead(available) != BytesConsumer::Result::Ok) {
+                    m_client->didFetchDataLoadFailed();
+                    return;
+                }
                 break;
             case BytesConsumer::Result::ShouldWait:
                 return;
             case BytesConsumer::Result::Done: {
                 auto size = m_blobData->length();
                 m_client->didFetchDataLoadedBlobHandle(BlobDataHandle::create(std::move(m_blobData), size));
                 return;
             }
             case BytesConsumer::Result::Error:
                 m_client->didFetchDataLoadFailed();
@@ skipping 41 matching lines @@
     void onStateChange() override
     {
         while (true) {
             const char* buffer;
             size_t available;
             switch (m_consumer->beginRead(&buffer, &available)) {
             case BytesConsumer::Result::Ok:
                 if (available > 0) {
                     unsigned bytesAppended = m_rawData->append(buffer, available);
                     if (!bytesAppended) {
-                        m_consumer->endRead(0);
+                        auto unused = m_consumer->endRead(0);
+                        ALLOW_UNUSED_LOCAL(unused);
                         m_consumer->cancel();
                         m_client->didFetchDataLoadFailed();
                         return;
                     }
                     DCHECK_EQ(bytesAppended, available);
                 }
-                m_consumer->endRead(available);
+                if (m_consumer->endRead(available) != BytesConsumer::Result::Ok) {
+                    m_client->didFetchDataLoadFailed();
+                    return;
+                }
                 break;
             case BytesConsumer::Result::ShouldWait:
                 return;
             case BytesConsumer::Result::Done:
                 m_client->didFetchDataLoadedArrayBuffer(DOMArrayBuffer::create(m_rawData->toArrayBuffer()));
                 return;
             case BytesConsumer::Result::Error:
                 m_client->didFetchDataLoadFailed();
                 return;
             }
@@ skipping 32 matching lines @@
 
     void onStateChange() override
     {
         while (true) {
             const char* buffer;
             size_t available;
             switch (m_consumer->beginRead(&buffer, &available)) {
             case BytesConsumer::Result::Ok:
                 if (available > 0)
                     m_builder.append(m_decoder->decode(buffer, available));
-                m_consumer->endRead(available);
+                if (m_consumer->endRead(available) != BytesConsumer::Result::Ok) {
+                    m_client->didFetchDataLoadFailed();
+                    return;
+                }
                 break;
             case BytesConsumer::Result::ShouldWait:
                 return;
             case BytesConsumer::Result::Done:
                 m_builder.append(m_decoder->flush());
                 m_client->didFetchDataLoadedString(m_builder.toString());
                 return;
             case BytesConsumer::Result::Error:
                 m_client->didFetchDataLoadFailed();
                 return;
@@ skipping 42 matching lines @@
 
     void onStateChange() override
     {
         bool needToFlush = false;
         while (true) {
             const char* buffer;
             size_t available;
             switch (m_consumer->beginRead(&buffer, &available)) {
             case BytesConsumer::Result::Ok:
                 m_outStream->addData(buffer, available);
-                m_consumer->endRead(available);
+                if (m_consumer->endRead(available) != BytesConsumer::Result::Ok) {
+                    m_outStream->abort();
+                    m_client->didFetchDataLoadFailed();
+                    return;
+                }
                 needToFlush = true;
                 break;
             case BytesConsumer::Result::ShouldWait:
                 if (needToFlush)
                     m_outStream->flush();
                 return;
             case BytesConsumer::Result::Done:
                 if (needToFlush)
                     m_outStream->flush();
                 m_outStream->finalize();
@@ skipping 47 matching lines @@
 {
     return new FetchDataLoaderAsString();
 }
 
 FetchDataLoader* FetchDataLoader::createLoaderAsStream(Stream* outStream)
 {
     return new FetchDataLoaderAsStream(outStream);
 }
 
 } // namespace blink