[Fetch API] Reflect spec changes of bodyUsed property

third_party/WebKit/Source/modules/serviceworkers/RespondWithObserver.cpp

 // 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 "config.h"
 #include "modules/serviceworkers/RespondWithObserver.h"
 
 #include "bindings/core/v8/ScriptFunction.h"
 #include "bindings/core/v8/ScriptPromise.h"
 #include "bindings/core/v8/ScriptValue.h"
@@ skipping 39 matching lines @@
         break;
     case WebServiceWorkerResponseErrorBodyUsed:
         errorMessage = errorMessage + "a Response whose \"bodyUsed\" is \"true\" cannot be used to respond to a request.";
         break;
     case WebServiceWorkerResponseErrorResponseTypeOpaqueForClientRequest:
         errorMessage = errorMessage + "an \"opaque\" response was used for a client request.";
         break;
     case WebServiceWorkerResponseErrorResponseTypeOpaqueRedirect:
         errorMessage = errorMessage + "an \"opaqueredirect\" type response was used for a request which is not a navigation request.";
         break;
+    case WebServiceWorkerResponseErrorBodyLocked:
+        errorMessage = errorMessage + "a Response whose \"body\" is locked cannot be used to respond to a request.";
+        break;
     case WebServiceWorkerResponseErrorUnknown:
     default:
         errorMessage = errorMessage + "an unexpected error occurred.";
         break;
     }
     return errorMessage;
 }
 
 bool isNavigationRequest(WebURLRequest::FrameType frameType)
 {
@@ skipping 149 matching lines @@
         }
     }
     if (!isNavigationRequest(m_frameType) && responseType == FetchResponseData::OpaqueRedirectType) {
         responseWasRejected(WebServiceWorkerResponseErrorResponseTypeOpaqueRedirect);
         return;
     }
     if (response->bodyUsed()) {
         responseWasRejected(WebServiceWorkerResponseErrorBodyUsed);
         return;
     }
+    if (response->isBodyLocked()) {
+        responseWasRejected(WebServiceWorkerResponseErrorBodyLocked);
+        return;
+    }
 
-    response->setBodyPassed();
     WebServiceWorkerResponse webResponse;
     response->populateWebServiceWorkerResponse(webResponse);
     BodyStreamBuffer* buffer = response->internalBodyBuffer();
     if (buffer) {
         RefPtr<BlobDataHandle> blobDataHandle = buffer->drainAsBlobDataHandle(FetchDataConsumerHandle::Reader::AllowBlobWithInvalidSize);
         if (blobDataHandle) {
             webResponse.setBlobDataHandle(blobDataHandle);
         } else {
             Stream* outStream = Stream::create(executionContext(), "");
             webResponse.setStreamURL(outStream->url());
@@ skipping 14 matching lines @@
     , m_state(Initial)
 {
 }
 
 DEFINE_TRACE(RespondWithObserver)
 {
     ContextLifecycleObserver::trace(visitor);
 }
 
 } // namespace blink