Use DCHECK instead of ASSERT in DataConsumerHandle-related stuff

third_party/WebKit/Source/modules/fetch/DataConsumerTee.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/DataConsumerTee.h"
 
 #include "core/dom/ActiveDOMObject.h"
 #include "core/dom/ExecutionContext.h"
 #include "modules/fetch/DataConsumerHandleUtil.h"
 #include "modules/fetch/FetchBlobDataConsumerHandle.h"
@@ skipping 142 matching lines @@
             std::unique_ptr<Vector<char>> data = wrapUnique(new Vector<char>);
             data->append(buffer, size);
             m_queue.append(std::move(data));
         }
         if (needsNotification)
             notify();
     }
 
     void setResult(Result r)
     {
-        ASSERT(r != WebDataConsumerHandle::Ok);
-        ASSERT(r != WebDataConsumerHandle::ShouldWait);
+        DCHECK(r != WebDataConsumerHandle::Ok);
+        DCHECK(r != WebDataConsumerHandle::ShouldWait);
         {
             MutexLocker locker(m_mutex);
             if (m_result != WebDataConsumerHandle::ShouldWait) {
                 // The result was already set.
                 return;
             }
             m_result = r;
             if (r != WebDataConsumerHandle::Done && !m_isTwoPhaseReadInProgress)
                 m_queue.clear();
         }
         notify();
     }
 
     void notify()
     {
         {
             MutexLocker locker(m_mutex);
             if (!m_client) {
                 // No client is registered.
                 return;
             }
-            ASSERT(m_readerThread);
+            DCHECK(m_readerThread);
             if (!m_readerThread->isCurrentThread()) {
                 m_readerThread->getWebTaskRunner()->postTask(BLINK_FROM_HERE, crossThreadBind(&DestinationContext::notify, wrapPassRefPtr(this)));
                 return;
             }
         }
         // The reading thread is the current thread.
         if (m_client)
             m_client->didGetReadable();
     }
 
     Mutex& mutex() { return m_mutex; }
 
     // The following functions don't use lock. They should be protected by the
     // caller.
     void attachReader(WebDataConsumerHandle::Client* client)
     {
-        ASSERT(!m_readerThread);
-        ASSERT(!m_client);
+        DCHECK(!m_readerThread);
+        DCHECK(!m_client);
         m_readerThread = Platform::current()->currentThread();
         m_client = client;
     }
     void detachReader()
     {
-        ASSERT(m_readerThread && m_readerThread->isCurrentThread());
+        DCHECK(m_readerThread && m_readerThread->isCurrentThread());
         m_readerThread = nullptr;
         m_client = nullptr;
     }
     const std::unique_ptr<Vector<char>>& top() const { return m_queue.first(); }
     bool isEmpty() const { return m_queue.isEmpty(); }
     size_t offset() const { return m_offset; }
     void consume(size_t size)
     {
         const auto& top = m_queue.first();
-        ASSERT(m_offset <= m_offset + size);
-        ASSERT(m_offset + size <= top->size());
+        DCHECK(m_offset <= m_offset + size);
+        DCHECK(m_offset + size <= top->size());
         if (top->size() <= m_offset + size) {
             m_offset = 0;
             m_queue.removeFirst();
         } else {
             m_offset += size;
         }
     }
     Result getResult() { return m_result; }
 
 private:
     DestinationContext()
         : m_result(WebDataConsumerHandle::ShouldWait)
         , m_readerThread(nullptr)
         , m_client(nullptr)
         , m_offset(0)
         , m_isTwoPhaseReadInProgress(false)
     {
     }
 
     void detach()
     {
         MutexLocker locker(m_mutex);
-        ASSERT(!m_client);
-        ASSERT(!m_readerThread);
+        DCHECK(!m_client);
+        DCHECK(!m_readerThread);
         m_queue.clear();
     }
 
     Result m_result;
     Deque<std::unique_ptr<Vector<char>>> m_queue;
     // Note: Holding a WebThread raw pointer is not generally safe, but we can
     // do that in this case because:
     //  1. Destructing a ReaderImpl when the bound thread ends is a user's
     //     responsibility.
     //  2. |m_readerThread| will never be used after the associated reader is
@@ skipping 91 matching lines @@
     {
         suspendIfNeeded();
     }
     ~SourceContext() override
     {
         stopInternal();
     }
 
     void didGetReadable() override
     {
-        ASSERT(m_reader);
+        DCHECK(m_reader);
         Result r = WebDataConsumerHandle::Ok;
         while (true) {
             const void* buffer = nullptr;
             size_t available = 0;
             r = m_reader->beginRead(&buffer, WebDataConsumerHandle::FlagNone, &available);
             if (r == WebDataConsumerHandle::ShouldWait)
                 return;
             if (r != WebDataConsumerHandle::Ok)
                 break;
             m_dest1->enqueue(static_cast<const char*>(buffer), available);
@@ skipping 62 matching lines @@
     }
 
     std::unique_ptr<WebDataConsumerHandle> webDest1, webDest2;
     DataConsumerTee::create(executionContext, static_cast<std::unique_ptr<WebDataConsumerHandle>>(std::move(src)), &webDest1, &webDest2);
     *dest1 = createFetchDataConsumerHandleFromWebHandle(std::move(webDest1));
     *dest2 = createFetchDataConsumerHandleFromWebHandle(std::move(webDest2));
     return;
 }
 
 } // namespace blink