HomeSort by relevance Sort by last modified time
    Searched refs:SocketStream (Results 1 - 11 of 11) sorted by null

  /external/chromium/net/socket_stream/
socket_stream_throttle.h 16 class SocketStream;
18 // Abstract interface to throttle SocketStream per URL scheme.
27 virtual int OnStartOpenConnection(SocketStream* socket,
38 virtual int OnRead(SocketStream* socket, const char* data, int len,
49 virtual int OnWrite(SocketStream* socket, const char* data, int len,
57 virtual void OnClose(SocketStream* socket) {}
socket_stream.h 39 // SocketStream is used to implement Web Sockets.
45 class SocketStream : public base::RefCountedThreadSafe<SocketStream> {
48 // information with a SocketStream. Use GetUserData(key) and
64 virtual void OnConnected(SocketStream* socket,
68 virtual void OnSentData(SocketStream* socket,
72 virtual void OnReceivedData(SocketStream* socket,
76 virtual void OnClose(SocketStream* socket) = 0;
81 virtual void OnAuthRequired(SocketStream* socket,
90 virtual void OnError(const SocketStream* socket, int error) {
    [all...]
socket_stream.cc 37 void SocketStream::ResponseHeaders::Realloc(size_t new_size) {
41 SocketStream::SocketStream(const GURL& url, Delegate* delegate)
51 io_callback_(this, &SocketStream::OnIOCompleted)),
53 read_callback_(this, &SocketStream::OnReadCompleted)),
55 write_callback_(this, &SocketStream::OnWriteCompleted)),
75 SocketStream::~SocketStream() {
80 SocketStream::UserData* SocketStream::GetUserData
    [all...]
socket_stream_unittest.cc 24 SocketStreamEvent(EventType type, net::SocketStream* socket_stream,
31 net::SocketStream* socket;
37 class SocketStreamEventRecorder : public net::SocketStream::Delegate {
70 virtual void OnConnected(net::SocketStream* socket,
79 virtual void OnSentData(net::SocketStream* socket,
87 virtual void OnReceivedData(net::SocketStream* socket,
95 virtual void OnClose(net::SocketStream* socket) {
104 virtual void OnAuthRequired(net::SocketStream* socket,
193 scoped_refptr<SocketStream> socket_stream =
194 new SocketStream(GURL("ws://example.com/demo"), delegate.get())
    [all...]
  /external/chromium/net/websockets/
websocket_throttle.h 24 virtual int OnStartOpenConnection(SocketStream* socket,
26 virtual int OnRead(SocketStream* socket, const char* data, int len,
28 virtual int OnWrite(SocketStream* socket, const char* data, int len,
30 virtual void OnClose(SocketStream* socket);
46 void PutInQueue(SocketStream* socket, WebSocketState* state);
50 void RemoveFromQueue(SocketStream* socket, WebSocketState* state);
websocket_throttle_unittest.cc 17 class DummySocketStreamDelegate : public net::SocketStream::Delegate {
22 net::SocketStream* socket, int max_pending_send_allowed) {}
23 virtual void OnSentData(net::SocketStream* socket, int amount_sent) {}
24 virtual void OnReceivedData(net::SocketStream* socket,
26 virtual void OnClose(net::SocketStream* socket) {}
63 static void SetAddressList(SocketStream* socket, struct addrinfo* head) {
83 scoped_refptr<SocketStream> s1 =
84 new SocketStream(GURL("ws://host1/"), &delegate);
93 scoped_refptr<SocketStream> s2 =
94 new SocketStream(GURL("ws://host2/"), &delegate)
    [all...]
websocket.h 54 public SocketStream::Delegate {
139 // SocketStream::Delegate methods.
141 virtual void OnConnected(SocketStream* socket_stream,
143 virtual void OnSentData(SocketStream* socket_stream, int amount_sent);
144 virtual void OnReceivedData(SocketStream* socket_stream,
146 virtual void OnClose(SocketStream* socket);
147 virtual void OnError(const SocketStream* socket, int error);
210 scoped_refptr<SocketStream> socket_stream_;
websocket_throttle.cc 44 // State for WebSocket protocol on each SocketStream.
45 // This is owned in SocketStream as UserData keyed by WebSocketState::kKeyName.
49 class WebSocketThrottle::WebSocketState : public SocketStream::UserData {
142 // If true, it will be removed from queue and deleted from the SocketStream
165 SocketStream* socket, CompletionCallback* callback) {
171 int WebSocketThrottle::OnRead(SocketStream* socket,
188 int WebSocketThrottle::OnWrite(SocketStream* socket,
195 void WebSocketThrottle::OnClose(SocketStream* socket) {
204 void WebSocketThrottle::PutInQueue(SocketStream* socket,
225 void WebSocketThrottle::RemoveFromQueue(SocketStream* socket
    [all...]
websocket.cc 63 socket_stream_ = new SocketStream(request_->url(), this);
111 void WebSocket::OnConnected(SocketStream* socket_stream,
130 void WebSocket::OnSentData(SocketStream* socket_stream, int amount_sent) {
143 void WebSocket::OnReceivedData(SocketStream* socket_stream,
151 void WebSocket::OnClose(SocketStream* socket_stream) {
156 void WebSocket::OnError(const SocketStream* socket_stream, int error) {
  /external/chromium/net/url_request/
url_request_context.h 27 class SocketStream;
92 RequestTracker<net::SocketStream>* socket_stream_tracker() {
151 RequestTracker<net::SocketStream> socket_stream_tracker_;
url_request_view_net_internals_job.cc 507 std::vector<net::SocketStream*> sockets =
529 RequestTracker<net::SocketStream>::RecentRequestInfoList recent =
532 DrawCommandButton("Clear", "clear-socketstream-graveyard", out);
548 : SubSection(parent, "socketstream", "SocketStream") {
585 if (command == "clear-socketstream-graveyard") {
655 "clear-socketstream-graveyard,"

Completed in 42 milliseconds