Searched refs:DataSocket (Results 1 – 5 of 5) sorted by relevance
38 class DataSocket; variable43 explicit ChannelMember(DataSocket* socket);49 bool is_wait_request(DataSocket* ds) const;61 void ForwardRequestToPeer(DataSocket* ds, ChannelMember* peer);63 void OnClosing(DataSocket* ds);68 void SetWaitingSocket(DataSocket* ds);75 DataSocket* waiting_socket_;100 static bool IsPeerConnection(const DataSocket* ds);103 ChannelMember* Lookup(DataSocket* ds) const;107 ChannelMember* IsTargetedRequest(const DataSocket* ds) const;[all …]
70 ChannelMember::ChannelMember(DataSocket* socket) in ChannelMember()74 assert(socket->method() == DataSocket::GET); in ChannelMember()88 bool ChannelMember::is_wait_request(DataSocket* ds) const { in is_wait_request()116 void ChannelMember::ForwardRequestToPeer(DataSocket* ds, ChannelMember* peer) { in ForwardRequestToPeer()134 void ChannelMember::OnClosing(DataSocket* ds) { in OnClosing()147 assert(waiting_socket_->method() == DataSocket::GET); in QueueResponse()165 void ChannelMember::SetWaitingSocket(DataSocket* ds) { in SetWaitingSocket()166 assert(ds->method() == DataSocket::GET); in SetWaitingSocket()183 bool PeerChannel::IsPeerConnection(const DataSocket* ds) { in IsPeerConnection()185 return (ds->method() == DataSocket::POST && ds->content_length() > 0) || in IsPeerConnection()[all …]
44 const char DataSocket::kCrossOriginAllowHeaders[] =88 std::string DataSocket::request_arguments() const { in request_arguments()95 bool DataSocket::PathEquals(const char* path) const { in PathEquals()103 bool DataSocket::OnDataAvailable(bool* close_socket) { in OnDataAvailable()134 bool DataSocket::Send(const std::string& data) const { in Send()139 bool DataSocket::Send(const std::string& status, bool connection_close, in Send()172 void DataSocket::Clear() { in Clear()181 bool DataSocket::ParseHeaders() { in ParseHeaders()204 bool DataSocket::ParseMethodAndPath(const char* begin, size_t len) { in ParseMethodAndPath()241 bool DataSocket::ParseContentLengthAndType(const char* headers, size_t length) { in ParseContentLengthAndType()[all …]
44 void HandleBrowserRequest(DataSocket* ds, bool* quit) { in HandleBrowserRequest()55 } else if (ds->method() == DataSocket::OPTIONS) { in HandleBrowserRequest()95 typedef std::vector<DataSocket*> SocketArray; in main()114 DataSocket* s = *i; in main()174 DataSocket* s = listener.Accept(); in main()
69 class DataSocket : public SocketBase {78 explicit DataSocket(int socket) in DataSocket() function84 ~DataSocket() { in ~DataSocket()165 DataSocket* Accept() const;