Index: Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp |
diff --git a/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp b/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp |
index eb36a09cc1dcfebeff9a9e971b1d1f17b1bb4f95..9d8b0828f1f7b06485325e38d5fcf5863016b748 100644 |
--- a/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp |
+++ b/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp |
@@ -54,40 +54,14 @@ PassRefPtrWillBeRawPtr<ThreadableWebSocketChannelClientWrapper> ThreadableWebSoc |
return adoptRefWillBeNoop(new ThreadableWebSocketChannelClientWrapper(client)); |
} |
-String ThreadableWebSocketChannelClientWrapper::subprotocol() const |
-{ |
- if (m_subprotocol.isEmpty()) |
- return emptyString(); |
- return String(m_subprotocol); |
-} |
- |
-void ThreadableWebSocketChannelClientWrapper::setSubprotocol(const String& subprotocol) |
-{ |
- m_subprotocol.clear(); |
- append(m_subprotocol, subprotocol); |
-} |
- |
-String ThreadableWebSocketChannelClientWrapper::extensions() const |
-{ |
- if (m_extensions.isEmpty()) |
- return emptyString(); |
- return String(m_extensions); |
-} |
- |
-void ThreadableWebSocketChannelClientWrapper::setExtensions(const String& extensions) |
-{ |
- m_extensions.clear(); |
- append(m_extensions, extensions); |
-} |
- |
void ThreadableWebSocketChannelClientWrapper::clearClient() |
{ |
m_client = 0; |
} |
-void ThreadableWebSocketChannelClientWrapper::didConnect() |
+void ThreadableWebSocketChannelClientWrapper::didConnect(const String& subprotocol, const String& extensions) |
{ |
- m_pendingTasks.append(createCallbackTask(&didConnectCallback, this)); |
+ m_pendingTasks.append(createCallbackTask(&didConnectCallback, this, subprotocol, extensions)); |
if (!m_suspended) |
processPendingTasks(); |
} |
@@ -155,11 +129,11 @@ void ThreadableWebSocketChannelClientWrapper::processPendingTasks() |
(*iter)->performTask(0); |
} |
-void ThreadableWebSocketChannelClientWrapper::didConnectCallback(ExecutionContext* context, PassRefPtrWillBeRawPtr<ThreadableWebSocketChannelClientWrapper> wrapper) |
+void ThreadableWebSocketChannelClientWrapper::didConnectCallback(ExecutionContext* context, PassRefPtrWillBeRawPtr<ThreadableWebSocketChannelClientWrapper> wrapper, const String& subprotocol, const String& extensions) |
{ |
ASSERT_UNUSED(context, !context); |
if (wrapper->m_client) |
- wrapper->m_client->didConnect(); |
+ wrapper->m_client->didConnect(subprotocol, extensions); |
} |
void ThreadableWebSocketChannelClientWrapper::didReceiveMessageCallback(ExecutionContext* context, PassRefPtrWillBeRawPtr<ThreadableWebSocketChannelClientWrapper> wrapper, const String& message) |