| /external/chromium/third_party/libjingle/source/talk/base/ |
| D | socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { in SocketStream() function in talk_base::SocketStream
36 SocketStream::~SocketStream() { in ~SocketStream()
40 void SocketStream::Attach(AsyncSocket* socket) { in Attach()
45 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent); in Attach()
46 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent); in Attach()
47 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent); in Attach()
48 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent); in Attach()
52 AsyncSocket* SocketStream::Detach() { in Detach()
64 StreamState SocketStream::GetState() const { in GetState()
77 StreamResult SocketStream::Read(void* buffer, size_t buffer_len, in Read()
[all …]
|
| D | socketstream.h | 39 class SocketStream : public StreamInterface, public sigslot::has_slots<> {
41 explicit SocketStream(AsyncSocket* socket);
42 virtual ~SocketStream();
67 DISALLOW_EVIL_CONSTRUCTORS(SocketStream);
|
| D | socketpool.h | 42 class SocketStream; variable
126 SocketStream* stream_;
|
| D | socketpool.cc | 153 return new SocketStream(socket); in RequestConnectedStream()
187 stream_ = new SocketStream(socket); in RequestConnectedStream()
|
| /external/chromium/net/socket_stream/ |
| D | socket_stream.cc | 41 SocketStream::ResponseHeaders::ResponseHeaders() : IOBuffer() {} in ResponseHeaders()
43 void SocketStream::ResponseHeaders::Realloc(size_t new_size) { in Realloc()
47 SocketStream::ResponseHeaders::~ResponseHeaders() { data_ = NULL; } in ~ResponseHeaders()
49 SocketStream::SocketStream(const GURL& url, Delegate* delegate) in SocketStream() function in net::SocketStream
62 io_callback_(this, &SocketStream::OnIOCompleted)), in SocketStream()
64 read_callback_(this, &SocketStream::OnReadCompleted)), in SocketStream()
66 write_callback_(this, &SocketStream::OnWriteCompleted)), in SocketStream()
82 SocketStream::UserData* SocketStream::GetUserData( in GetUserData()
90 void SocketStream::SetUserData(const void* key, UserData* data) { in SetUserData()
94 bool SocketStream::is_secure() const { in is_secure()
[all …]
|
| D | socket_stream.h | 47 class SocketStream : public base::RefCountedThreadSafe<SocketStream> {
62 virtual int OnStartOpenConnection(SocketStream* socket, in OnStartOpenConnection()
71 virtual void OnConnected(SocketStream* socket,
75 virtual void OnSentData(SocketStream* socket,
79 virtual void OnReceivedData(SocketStream* socket,
83 virtual void OnClose(SocketStream* socket) = 0;
88 virtual void OnAuthRequired(SocketStream* socket, in OnAuthRequired()
97 virtual void OnError(const SocketStream* socket, int error) {} in OnError()
100 SocketStream(const GURL& url, Delegate* delegate);
153 friend class base::RefCountedThreadSafe<SocketStream>;
[all …]
|
| D | socket_stream_job.h | 29 SocketStream::Delegate* delegate);
36 SocketStream::Delegate* delegate,
40 void InitSocketStream(SocketStream* socket) { in InitSocketStream()
44 virtual SocketStream::UserData* GetUserData(const void* key) const;
45 virtual void SetUserData(const void* key, SocketStream::UserData* data);
70 scoped_refptr<SocketStream> socket_;
|
| D | socket_stream_unittest.cc | 27 SocketStreamEvent(EventType type, net::SocketStream* socket_stream, in SocketStreamEvent()
34 net::SocketStream* socket;
40 class SocketStreamEventRecorder : public net::SocketStream::Delegate {
73 virtual void OnConnected(net::SocketStream* socket, in OnConnected()
82 virtual void OnSentData(net::SocketStream* socket, in OnSentData()
90 virtual void OnReceivedData(net::SocketStream* socket, in OnReceivedData()
98 virtual void OnClose(net::SocketStream* socket) { in OnClose()
107 virtual void OnAuthRequired(net::SocketStream* socket, in OnAuthRequired()
243 scoped_refptr<SocketStream> socket_stream( in TEST_F()
244 new SocketStream(GURL("ws://example.com/demo"), delegate.get())); in TEST_F()
[all …]
|
| D | socket_stream_job_manager.cc | 23 const GURL& url, SocketStream::Delegate* delegate) const { in CreateJob()
28 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
42 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
|
| D | socket_stream_job.cc | 24 SocketStream::Delegate* delegate, in CreateSocketStreamJob()
44 SocketStream::UserData* SocketStreamJob::GetUserData(const void* key) const { in GetUserData()
49 SocketStream::UserData* data) { in SetUserData()
|
| D | socket_stream_job_manager.h | 26 const GURL& url, SocketStream::Delegate* delegate) const;
|
| /external/chromium/net/websockets/ |
| D | websocket_job.h | 32 class WebSocketJob : public SocketStreamJob, public SocketStream::Delegate {
43 explicit WebSocketJob(SocketStream::Delegate* delegate);
58 SocketStream* socket, CompletionCallback* callback);
60 SocketStream* socket, int max_pending_send_allowed);
62 SocketStream* socket, int amount_sent);
64 SocketStream* socket, const char* data, int len);
65 virtual void OnClose(SocketStream* socket);
67 SocketStream* socket, AuthChallengeInfo* auth_info);
69 const SocketStream* socket, int error);
80 void OnSentHandshakeRequest(SocketStream* socket, int amount_sent);
[all …]
|
| D | websocket_throttle_unittest.cc | 18 class DummySocketStreamDelegate : public net::SocketStream::Delegate {
23 net::SocketStream* socket, int max_pending_send_allowed) {} in OnConnected()
24 virtual void OnSentData(net::SocketStream* socket, int amount_sent) {} in OnSentData()
25 virtual void OnReceivedData(net::SocketStream* socket, in OnReceivedData()
27 virtual void OnClose(net::SocketStream* socket) {} in OnClose()
65 SocketStream* socket, struct addrinfo* head) { in MockSocketStreamConnect()
75 DCHECK_EQ(socket->next_state_, SocketStream::STATE_NONE); in MockSocketStreamConnect()
87 scoped_refptr<SocketStream> s1( in TEST_F()
88 new SocketStream(GURL("ws://host1/"), w1.get())); in TEST_F()
107 scoped_refptr<SocketStream> s2( in TEST_F()
[all …]
|
| D | websocket.h | 59 public SocketStream::Delegate {
151 virtual void OnConnected(SocketStream* socket_stream,
153 virtual void OnSentData(SocketStream* socket_stream, int amount_sent);
154 virtual void OnReceivedData(SocketStream* socket_stream,
156 virtual void OnClose(SocketStream* socket);
157 virtual void OnError(const SocketStream* socket, int error);
197 scoped_refptr<SocketStream> socket_stream_;
|
| D | websocket_job.cc | 35 const GURL& url, net::SocketStream::Delegate* delegate) { in WebSocketJobFactory()
37 job->InitSocketStream(new net::SocketStream(url, job)); in WebSocketJobFactory()
62 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate) in WebSocketJob()
164 SocketStream* socket, CompletionCallback* callback) { in OnStartOpenConnection()
177 SocketStream* socket, int max_pending_send_allowed) { in OnConnected()
185 void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) { in OnSentData()
214 SocketStream* socket, const char* data, int len) { in OnReceivedData()
238 void WebSocketJob::OnClose(SocketStream* socket) { in OnClose()
245 SocketStream::Delegate* delegate = delegate_; in OnClose()
258 SocketStream* socket, AuthChallengeInfo* auth_info) { in OnAuthRequired()
[all …]
|
| D | websocket_job_unittest.cc | 27 class MockSocketStream : public SocketStream {
29 MockSocketStream(const GURL& url, SocketStream::Delegate* delegate) in MockSocketStream()
30 : SocketStream(url, delegate) {} in MockSocketStream()
54 class MockSocketStreamDelegate : public SocketStream::Delegate {
60 virtual void OnConnected(SocketStream* socket, int max_pending_send_allowed) { in OnConnected()
62 virtual void OnSentData(SocketStream* socket, int amount_sent) { in OnSentData()
65 virtual void OnReceivedData(SocketStream* socket, in OnReceivedData()
69 virtual void OnClose(SocketStream* socket) { in OnClose()
220 SocketStream* GetSocket(SocketStreamJob* job) { in GetSocket()
|
| D | websocket.cc | 54 socket_stream_ = new SocketStream(request_->url(), this); in Connect()
145 void WebSocket::OnConnected(SocketStream* socket_stream, in OnConnected()
180 void WebSocket::OnSentData(SocketStream* socket_stream, int amount_sent) { in OnSentData()
193 void WebSocket::OnReceivedData(SocketStream* socket_stream, in OnReceivedData()
201 void WebSocket::OnClose(SocketStream* socket_stream) { in OnClose()
206 void WebSocket::OnError(const SocketStream* socket_stream, int error) { in OnError()
|
| D | websocket_throttle.h | 18 class SocketStream; variable
|
| /external/chromium/third_party/libjingle/source/talk/examples/login/ |
| D | xmppsocket.cc | 66 stream_ = new talk_base::SocketStream(cricket_socket_); in XmppSocket()
|
| /external/webkit/Source/WebCore/ |
| D | ChangeLog-2010-12-06 | 27854 [WIN] Add stubs for SocketStream classes
117621 [BREWMP] Port SocketStream
117624 Port SocketStream with BREW MP's ISocket interface.
|
| D | ChangeLog-2010-01-29 | 23450 … (WebCore::SocketStreamHandle::readStreamCallback): This will no longer happen with SocketStream,
56582 Add stubs for SocketStream classes added in @r47788, which
|