Lines Matching refs:WorkerThreadableWebSocketChannel
35 #include "WorkerThreadableWebSocketChannel.h"
52 WorkerThreadableWebSocketChannel::WorkerThreadableWebSocketChannel(WorkerContext* context, WebSocketChannelClient* client, const String& taskMode, const KURL& url, const String& protocol)
59 WorkerThreadableWebSocketChannel::~WorkerThreadableWebSocketChannel()
65 void WorkerThreadableWebSocketChannel::connect()
71 bool WorkerThreadableWebSocketChannel::send(const String& message)
78 unsigned long WorkerThreadableWebSocketChannel::bufferedAmount() const
85 void WorkerThreadableWebSocketChannel::close()
91 void WorkerThreadableWebSocketChannel::disconnect()
97 void WorkerThreadableWebSocketChannel::suspend()
104 void WorkerThreadableWebSocketChannel::resume()
111 WorkerThreadableWebSocketChannel::Peer::Peer(RefPtr<ThreadableWebSocketChannelClientWrapper> clientWrapper, WorkerLoaderProxy& loaderProxy, ScriptExecutionContext* context, const String& taskMode, const KURL& url, const String& protocol)
120 WorkerThreadableWebSocketChannel::Peer::~Peer()
127 void WorkerThreadableWebSocketChannel::Peer::connect()
141 void WorkerThreadableWebSocketChannel::Peer::send(const String& message)
156 void WorkerThreadableWebSocketChannel::Peer::bufferedAmount()
165 void WorkerThreadableWebSocketChannel::Peer::close()
174 void WorkerThreadableWebSocketChannel::Peer::disconnect()
183 void WorkerThreadableWebSocketChannel::Peer::suspend()
191 void WorkerThreadableWebSocketChannel::Peer::resume()
205 void WorkerThreadableWebSocketChannel::Peer::didConnect()
217 void WorkerThreadableWebSocketChannel::Peer::didReceiveMessage(const String& message)
229 void WorkerThreadableWebSocketChannel::Peer::didClose(unsigned long unhandledBufferedAmount)
236 void WorkerThreadableWebSocketChannel::Bridge::setWebSocketChannel(ScriptExecutionContext* context, Bridge* thisPtr, Peer* peer, RefPtr<ThreadableWebSocketChannelClientWrapper> workerClientWrapper)
243 void WorkerThreadableWebSocketChannel::Bridge::mainThreadCreateWebSocketChannel(ScriptExecutionContext* context, Bridge* thisPtr, RefPtr<ThreadableWebSocketChannelClientWrapper> clientWrapper, const String& taskMode, const KURL& url, const String& protocol)
252 WorkerThreadableWebSocketChannel::Bridge::Bridge(PassRefPtr<ThreadableWebSocketChannelClientWrapper> workerClientWrapper, PassRefPtr<WorkerContext> workerContext, const String& taskMode, const KURL& url, const String& protocol)
266 WorkerThreadableWebSocketChannel::Bridge::~Bridge()
271 void WorkerThreadableWebSocketChannel::mainThreadConnect(ScriptExecutionContext* context, Peer* peer)
280 void WorkerThreadableWebSocketChannel::Bridge::connect()
284 m_loaderProxy.postTaskToLoader(createCallbackTask(&WorkerThreadableWebSocketChannel::mainThreadConnect, m_peer));
287 void WorkerThreadableWebSocketChannel::mainThreadSend(ScriptExecutionContext* context, Peer* peer, const String& message)
296 bool WorkerThreadableWebSocketChannel::Bridge::send(const String& message)
302 m_loaderProxy.postTaskToLoader(createCallbackTask(&WorkerThreadableWebSocketChannel::mainThreadSend, m_peer, message));
309 void WorkerThreadableWebSocketChannel::mainThreadBufferedAmount(ScriptExecutionContext* context, Peer* peer)
318 unsigned long WorkerThreadableWebSocketChannel::Bridge::bufferedAmount()
324 m_loaderProxy.postTaskToLoader(createCallbackTask(&WorkerThreadableWebSocketChannel::mainThreadBufferedAmount, m_peer));
333 void WorkerThreadableWebSocketChannel::mainThreadClose(ScriptExecutionContext* context, Peer* peer)
342 void WorkerThreadableWebSocketChannel::Bridge::close()
345 m_loaderProxy.postTaskToLoader(createCallbackTask(&WorkerThreadableWebSocketChannel::mainThreadClose, m_peer));
348 void WorkerThreadableWebSocketChannel::mainThreadDestroy(ScriptExecutionContext* context, Peer* peer)
357 void WorkerThreadableWebSocketChannel::Bridge::disconnect()
368 void WorkerThreadableWebSocketChannel::mainThreadSuspend(ScriptExecutionContext* context, Peer* peer)
377 void WorkerThreadableWebSocketChannel::Bridge::suspend()
380 m_loaderProxy.postTaskToLoader(createCallbackTask(&WorkerThreadableWebSocketChannel::mainThreadSuspend, m_peer));
383 void WorkerThreadableWebSocketChannel::mainThreadResume(ScriptExecutionContext* context, Peer* peer)
392 void WorkerThreadableWebSocketChannel::Bridge::resume()
395 m_loaderProxy.postTaskToLoader(createCallbackTask(&WorkerThreadableWebSocketChannel::mainThreadResume, m_peer));
398 void WorkerThreadableWebSocketChannel::Bridge::clearClientWrapper()
403 void WorkerThreadableWebSocketChannel::Bridge::setMethodNotCompleted()
411 void WorkerThreadableWebSocketChannel::Bridge::waitForMethodCompletion()
