Migrate Timer to TaskRunnerTimer in DOMWebSocket.

third_party/WebKit/Source/modules/websockets/DOMWebSocket.cpp

 /*
  * Copyright (C) 2011 Google Inc.  All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 22 matching lines @@
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptController.h"
 #include "bindings/core/v8/SourceLocation.h"
 #include "bindings/modules/v8/StringOrStringSequence.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMArrayBufferView.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/dom/SecurityContext.h"
+#include "core/dom/TaskRunnerHelper.h"
 #include "core/events/MessageEvent.h"
 #include "core/fileapi/Blob.h"
 #include "core/frame/LocalDOMWindow.h"
 #include "core/frame/LocalFrame.h"
 #include "core/frame/UseCounter.h"
 #include "core/frame/csp/ContentSecurityPolicy.h"
 #include "core/inspector/ConsoleMessage.h"
 #include "modules/websockets/CloseEvent.h"
 #include "platform/Histogram.h"
 #include "platform/blob/BlobData.h"
@@ skipping 10 matching lines @@
 #include "wtf/text/StringBuilder.h"
 
 static const size_t kMaxByteSizeForHistogram = 100 * 1000 * 1000;
 static const int32_t kBucketCountForMessageSizeHistogram = 50;
 
 namespace blink {
 
 DOMWebSocket::EventQueue::EventQueue(EventTarget* target)
     : m_state(Active),
       m_target(target),
-      m_resumeTimer(this, &EventQueue::resumeTimerFired) {}
+      m_resumeTimer(TaskRunnerHelper::get(TaskType::WebSocket,
+                                          target->getExecutionContext()),
+                    this,
+                    &EventQueue::resumeTimerFired) {}
 
 DOMWebSocket::EventQueue::~EventQueue() {
   contextDestroyed();
 }
 
 void DOMWebSocket::EventQueue::dispatch(Event* event) {
   switch (m_state) {
     case Active:
       DCHECK(m_events.isEmpty());
       DCHECK(m_target->getExecutionContext());
@@ skipping 138 matching lines @@
       m_state(kConnecting),
       m_bufferedAmount(0),
       m_consumedBufferedAmount(0),
       m_bufferedAmountAfterClose(0),
       m_binaryType(BinaryTypeBlob),
       m_binaryTypeChangesAfterOpen(0),
       m_subprotocol(""),
       m_extensions(""),
       m_eventQueue(EventQueue::create(this)),
       m_bufferedAmountConsumeTimer(
+          TaskRunnerHelper::get(TaskType::WebSocket, context),
           this,
           &DOMWebSocket::reflectBufferedAmountConsumption) {}
 
 DOMWebSocket::~DOMWebSocket() {
   DCHECK(!m_channel);
 }
 
 void DOMWebSocket::logError(const String& message) {
   if (getExecutionContext())
     getExecutionContext()->addConsoleMessage(
@@ skipping 617 matching lines @@
 
 DEFINE_TRACE(DOMWebSocket) {
   visitor->trace(m_channel);
   visitor->trace(m_eventQueue);
   WebSocketChannelClient::trace(visitor);
   EventTargetWithInlineData::trace(visitor);
   SuspendableObject::trace(visitor);
 }
 
 }  // namespace blink