Lines Matching refs:DataSocket
55 ChannelMember::ChannelMember(DataSocket* socket) in ChannelMember()
61 assert(socket->method() == DataSocket::GET); in ChannelMember()
74 bool ChannelMember::is_wait_request(DataSocket* ds) const { in is_wait_request()
104 void ChannelMember::ForwardRequestToPeer(DataSocket* ds, ChannelMember* peer) { in ForwardRequestToPeer()
120 void ChannelMember::OnClosing(DataSocket* ds) { in OnClosing()
133 assert(waiting_socket_->method() == DataSocket::GET); in QueueResponse()
151 void ChannelMember::SetWaitingSocket(DataSocket* ds) { in SetWaitingSocket()
152 assert(ds->method() == DataSocket::GET); in SetWaitingSocket()
169 bool PeerChannel::IsPeerConnection(const DataSocket* ds) { in IsPeerConnection()
171 return (ds->method() == DataSocket::POST && ds->content_length() > 0) || in IsPeerConnection()
172 (ds->method() == DataSocket::GET && ds->PathEquals("/sign_in")); in IsPeerConnection()
175 ChannelMember* PeerChannel::Lookup(DataSocket* ds) const { in Lookup()
178 if (ds->method() != DataSocket::GET && ds->method() != DataSocket::POST) in Lookup()
211 ChannelMember* PeerChannel::IsTargetedRequest(const DataSocket* ds) const { in IsTargetedRequest()
241 bool PeerChannel::AddMember(DataSocket* ds) { in AddMember()
268 void PeerChannel::OnClosing(DataSocket* ds) { in OnClosing()