Home | History | Annotate | Download | only in websockets

Lines Matching defs:clientWrapper

111 WorkerThreadableWebSocketChannel::Peer::Peer(RefPtr<ThreadableWebSocketChannelClientWrapper> clientWrapper, WorkerLoaderProxy& loaderProxy, ScriptExecutionContext* context, const String& taskMode, const KURL& url, const String& protocol)
112 : m_workerClientWrapper(clientWrapper)
243 void WorkerThreadableWebSocketChannel::Bridge::mainThreadCreateWebSocketChannel(ScriptExecutionContext* context, Bridge* thisPtr, RefPtr<ThreadableWebSocketChannelClientWrapper> clientWrapper, const String& taskMode, const KURL& url, const String& protocol)
248 Peer* peer = Peer::create(clientWrapper, thisPtr->m_loaderProxy, context, taskMode, url, protocol);
249 thisPtr->m_loaderProxy.postTaskForModeToWorkerContext(createCallbackTask(&Bridge::setWebSocketChannel, thisPtr, peer, clientWrapper), taskMode);
305 ThreadableWebSocketChannelClientWrapper* clientWrapper = m_workerClientWrapper.get();
306 return clientWrapper && clientWrapper->sent();
327 ThreadableWebSocketChannelClientWrapper* clientWrapper = m_workerClientWrapper.get();
328 if (clientWrapper)
329 return clientWrapper->bufferedAmount();
417 ThreadableWebSocketChannelClientWrapper* clientWrapper = m_workerClientWrapper.get();
418 while (m_workerContext && clientWrapper && !clientWrapper->syncMethodDone() && result != MessageQueueTerminated) {
420 clientWrapper = m_workerClientWrapper.get();