Lines Matching defs:Peer
60 typedef WorkerThreadableWebSocketChannel::Peer Peer;
188 Peer::Peer(Bridge* bridge, WorkerLoaderProxy& loaderProxy, ThreadableWebSocketChannelSyncHelper* syncHelper)
197 Peer::~Peer()
202 void Peer::initializeInternal(ExecutionContext* context, const String& sourceURL, unsigned lineNumber)
214 void Peer::connect(const KURL& url, const String& protocol)
227 void Peer::send(const String& message)
234 void Peer::sendArrayBuffer(PassOwnPtr<Vector<char> > data)
241 void Peer::sendBlob(PassRefPtr<BlobDataHandle> blobData)
248 void Peer::close(int code, const String& reason)
257 void Peer::fail(const String& reason, MessageLevel level, const String& sourceURL, unsigned lineNumber)
266 void Peer::disconnect()
284 void Peer::didConnect(const String& subprotocol, const String& extensions)
297 void Peer::didReceiveMessage(const String& message)
310 void Peer::didReceiveBinaryData(PassOwnPtr<Vector<char> > binaryData)
323 void Peer::didConsumeBufferedAmount(unsigned long consumed)
336 void Peer::didStartClosingHandshake()
349 void Peer::didClose(ClosingHandshakeCompletionStatus closingHandshakeCompletion, unsigned short code, const String& reason)
366 void Peer::didReceiveMessageError()
372 void Peer::trace(Visitor* visitor)
385 , m_peer(new Peer(this, m_loaderProxy, m_syncHelper))
396 if (!waitForMethodCompletion(createCrossThreadTask(&Peer::initialize, AllowCrossThreadAccess(m_peer.get()), sourceURL, lineNumber))) {
407 if (!waitForMethodCompletion(createCrossThreadTask(&Peer::connect, m_peer.get(), url, protocol)))
416 m_loaderProxy.postTaskToLoader(createCrossThreadTask(&Peer::send, m_peer.get(), message));
427 m_loaderProxy.postTaskToLoader(createCrossThreadTask(&Peer::sendArrayBuffer, m_peer.get(), data.release()));
433 m_loaderProxy.postTaskToLoader(createCrossThreadTask(&Peer::sendBlob, m_peer.get(), data));
439 m_loaderProxy.postTaskToLoader(createCrossThreadTask(&Peer::close, m_peer.get(), code, reason));
445 m_loaderProxy.postTaskToLoader(createCrossThreadTask(&Peer::fail, m_peer.get(), reason, level, sourceURL, lineNumber));
453 waitForMethodCompletion(createCrossThreadTask(&Peer::disconnect, m_peer.get()));