Remove WebWaitableEvent and replace it with WaitableEvent.

third_party/WebKit/Source/modules/fetch/DataConsumerHandleTestUtil.h

 // 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.
 
 #ifndef DataConsumerHandleTestUtil_h
 #define DataConsumerHandleTestUtil_h
 
 #include "bindings/core/v8/ScriptState.h"
 #include "core/testing/NullExecutionContext.h"
 #include "gin/public/isolate_holder.h"
 #include "modules/fetch/DataConsumerHandleUtil.h"
 #include "modules/fetch/FetchDataConsumerHandle.h"
 #include "modules/fetch/FetchDataLoader.h"
 #include "platform/Task.h"
 #include "platform/ThreadSafeFunctional.h"
+#include "platform/WaitableEvent.h"
 #include "platform/WebThreadSupportingGC.h"
 #include "platform/heap/Handle.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebDataConsumerHandle.h"
 #include "public/platform/WebTraceLocation.h"
-#include "public/platform/WebWaitableEvent.h"
 #include "wtf/Deque.h"
 #include "wtf/Locker.h"
 #include "wtf/OwnPtr.h"
 #include "wtf/PassOwnPtr.h"
 #include "wtf/ThreadSafeRefCounted.h"
 #include "wtf/ThreadingPrimitives.h"
 #include "wtf/Vector.h"
 
 #include <gmock/gmock.h>
 #include <gtest/gtest.h>
@@ skipping 33 matching lines @@
         ExecutionContext* executionContext() { return m_executionContext.get(); }
         ScriptState* scriptState() { return m_scriptState.get(); }
         v8::Isolate* isolate() { return m_isolateHolder->isolate(); }
 
     private:
         void initialize();
         void shutdown();
 
         OwnPtr<WebThreadSupportingGC> m_thread;
         const InitializationPolicy m_initializationPolicy;
-        OwnPtr<WebWaitableEvent> m_waitableEvent;
+        OwnPtr<WaitableEvent> m_waitableEvent;
         RefPtrWillBePersistent<NullExecutionContext> m_executionContext;
         OwnPtr<gin::IsolateHolder> m_isolateHolder;
         RefPtr<ScriptState> m_scriptState;
     };
 
     class ThreadingTestBase : public ThreadSafeRefCounted<ThreadingTestBase> {
     public:
         virtual ~ThreadingTestBase() { }
 
         class ThreadHolder;
@@ skipping 150 matching lines @@
         {
             postTaskToUpdatingThread(location,  task);
             m_waitableEvent->wait();
         }
     protected:
         ThreadingTestBase()
             : m_context(Context::create()) { }
 
         RefPtr<Context> m_context;
         OwnPtr<WebDataConsumerHandle::Reader> m_reader;
-        OwnPtr<WebWaitableEvent> m_waitableEvent;
+        OwnPtr<WaitableEvent> m_waitableEvent;
         NoopClient m_client;
     };
 
     class ThreadingHandleNotificationTest : public ThreadingTestBase, public WebDataConsumerHandle::Client {
     public:
         using Self = ThreadingHandleNotificationTest;
         static PassRefPtr<Self> create() { return adoptRef(new Self); }
 
         void run(PassOwnPtr<WebDataConsumerHandle> handle)
         {
             ThreadHolder holder(this);
-            m_waitableEvent = adoptPtr(Platform::current()->createWaitableEvent());
+            m_waitableEvent = adoptPtr(new WaitableEvent());
             m_handle = handle;
 
             postTaskToReadingThreadAndWait(BLINK_FROM_HERE, new Task(threadSafeBind(&Self::obtainReader, this)));
         }
 
     private:
         ThreadingHandleNotificationTest() = default;
         void obtainReader()
         {
             m_reader = m_handle->obtainReader(this);
         }
         void didGetReadable() override
         {
             postTaskToReadingThread(BLINK_FROM_HERE, new Task(threadSafeBind(&Self::resetReader, this)));
             postTaskToReadingThread(BLINK_FROM_HERE, new Task(threadSafeBind(&Self::signalDone, this)));
         }
 
         OwnPtr<WebDataConsumerHandle> m_handle;
     };
 
     class ThreadingHandleNoNotificationTest : public ThreadingTestBase, public WebDataConsumerHandle::Client {
     public:
         using Self = ThreadingHandleNoNotificationTest;
         static PassRefPtr<Self> create() { return adoptRef(new Self); }
 
         void run(PassOwnPtr<WebDataConsumerHandle> handle)
         {
             ThreadHolder holder(this);
-            m_waitableEvent = adoptPtr(Platform::current()->createWaitableEvent());
+            m_waitableEvent = adoptPtr(new WaitableEvent());
             m_handle = handle;
 
             postTaskToReadingThreadAndWait(BLINK_FROM_HERE, new Task(threadSafeBind(&Self::obtainReader, this)));
         }
 
     private:
         ThreadingHandleNoNotificationTest() = default;
         void obtainReader()
         {
             m_reader = m_handle->obtainReader(this);
@@ skipping 103 matching lines @@
         public:
             static PassRefPtr<Context> create() { return adoptRef(new Context); }
 
             // This function cannot be called after creating a tee.
             void add(const Command&);
             void attachReader(WebDataConsumerHandle::Client*);
             void detachReader();
             void detachHandle();
             Result beginRead(const void** buffer, Flags, size_t* available);
             Result endRead(size_t readSize);
-            WebWaitableEvent* detached() { return m_detached.get(); }
+            WaitableEvent* detached() { return m_detached.get(); }
 
         private:
             Context();
             bool isEmpty() const { return m_commands.isEmpty(); }
             const Command& top();
             void consume(size_t);
             size_t offset() const { return m_offset; }
             void notify();
             void notifyInternal();
 
             Deque<Command> m_commands;
             size_t m_offset;
             WebThread* m_readerThread;
             Client* m_client;
             Result m_result;
             bool m_isHandleAttached;
             Mutex m_mutex;
-            OwnPtr<WebWaitableEvent> m_detached;
+            OwnPtr<WaitableEvent> m_detached;
         };
 
         Context* context() { return m_context.get(); }
 
     private:
         class ReaderImpl;
 
         ReplayingHandle();
         Reader* obtainReaderInternal(Client*) override;
         const char* debugName() const override { return "ReplayingHandle"; }
@@ skipping 51 matching lines @@
     };
 
     // HandleReaderRunner<T> creates a dedicated thread and run T on the thread
     // where T is one of HandleReader and HandleTwophaseReader.
     template <typename T>
     class HandleReaderRunner final {
         STACK_ALLOCATED();
     public:
         explicit HandleReaderRunner(PassOwnPtr<WebDataConsumerHandle> handle)
             : m_thread(adoptPtr(new Thread("reading thread")))
-            , m_event(adoptPtr(Platform::current()->createWaitableEvent()))
+            , m_event(adoptPtr(new WaitableEvent()))
             , m_isDone(false)
         {
             m_thread->thread()->postTask(BLINK_FROM_HERE, new Task(threadSafeBind(&HandleReaderRunner::start, AllowCrossThreadAccess(this), handle)));
         }
         ~HandleReaderRunner()
         {
             wait();
         }
 
         PassOwnPtr<HandleReadResult> wait()
@@ skipping 12 matching lines @@
         }
 
         void onFinished(PassOwnPtr<HandleReadResult> result)
         {
             m_handleReader = nullptr;
             m_result = result;
             m_event->signal();
         }
 
         OwnPtr<Thread> m_thread;
-        OwnPtr<WebWaitableEvent> m_event;
+        OwnPtr<WaitableEvent> m_event;
         OwnPtr<HandleReadResult> m_result;
         bool m_isDone;
 
         OwnPtr<T> m_handleReader;
     };
 };
 
 } // namespace blink
 
 #endif // DataConsumerHandleTestUtil_h