Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(112)

Unified Diff: Source/modules/websockets/WorkerThreadableWebSocketChannel.cpp

Issue 333223002: ThreadableWebSocketChannelClientWrapper don't need suspend / resume code. (Closed) Base URL: https://chromium.googlesource.com/chromium/blink.git@master
Patch Set: rebase Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « Source/modules/websockets/WorkerThreadableWebSocketChannel.h ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: Source/modules/websockets/WorkerThreadableWebSocketChannel.cpp
diff --git a/Source/modules/websockets/WorkerThreadableWebSocketChannel.cpp b/Source/modules/websockets/WorkerThreadableWebSocketChannel.cpp
index 208deb0ad4e829f299c2fb4070aa55fac665f064..bb39f5c5281fda2a9b2fef87d2158f03a26bce29 100644
--- a/Source/modules/websockets/WorkerThreadableWebSocketChannel.cpp
+++ b/Source/modules/websockets/WorkerThreadableWebSocketChannel.cpp
@@ -204,20 +204,6 @@ void WorkerThreadableWebSocketChannel::disconnect()
m_bridge.clear();
}
-void WorkerThreadableWebSocketChannel::suspend()
-{
- m_workerClientWrapper->suspend();
- if (m_bridge)
- m_bridge->suspend();
-}
-
-void WorkerThreadableWebSocketChannel::resume()
-{
- m_workerClientWrapper->resume();
- if (m_bridge)
- m_bridge->resume();
-}
-
void WorkerThreadableWebSocketChannel::trace(Visitor* visitor)
{
visitor->trace(m_workerClientWrapper);
@@ -348,22 +334,6 @@ void WorkerThreadableWebSocketChannel::Peer::disconnect()
m_mainWebSocketChannel = nullptr;
}
-void WorkerThreadableWebSocketChannel::Peer::suspend()
-{
- ASSERT(isMainThread());
- if (!m_mainWebSocketChannel)
- return;
- m_mainWebSocketChannel->suspend();
-}
-
-void WorkerThreadableWebSocketChannel::Peer::resume()
-{
- ASSERT(isMainThread());
- if (!m_mainWebSocketChannel)
- return;
- m_mainWebSocketChannel->resume();
-}
-
static void workerGlobalScopeDidConnect(ExecutionContext* context, PassRefPtrWillBeRawPtr<ThreadableWebSocketChannelClientWrapper> workerClientWrapper, const String& subprotocol, const String& extensions)
{
ASSERT_UNUSED(context, context->isWorkerGlobalScope());
@@ -566,22 +536,6 @@ void WorkerThreadableWebSocketChannel::Bridge::disconnect()
terminatePeer();
}
-void WorkerThreadableWebSocketChannel::Bridge::suspend()
-{
- if (hasTerminatedPeer())
- return;
-
- m_loaderProxy.postTaskToLoader(CallClosureTask::create(bind(&Peer::suspend, m_peer)));
-}
-
-void WorkerThreadableWebSocketChannel::Bridge::resume()
-{
- if (hasTerminatedPeer())
- return;
-
- m_loaderProxy.postTaskToLoader(CallClosureTask::create(bind(&Peer::resume, m_peer)));
-}
-
void WorkerThreadableWebSocketChannel::Bridge::clearClientWrapper()
{
m_workerClientWrapper->clearClient();
« no previous file with comments | « Source/modules/websockets/WorkerThreadableWebSocketChannel.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698