| /external/chromium_org/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()
192 stream_ = new SocketStream(socket); in RequestConnectedStream()
|
| /external/chromium_org/third_party/webrtc/base/ |
| D | socketstream.cc | 15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { in SocketStream() function in rtc::SocketStream
19 SocketStream::~SocketStream() { in ~SocketStream()
23 void SocketStream::Attach(AsyncSocket* socket) { in Attach()
28 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent); in Attach()
29 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent); in Attach()
30 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent); in Attach()
31 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent); in Attach()
35 AsyncSocket* SocketStream::Detach() { in Detach()
47 StreamState SocketStream::GetState() const { in GetState()
60 StreamResult SocketStream::Read(void* buffer, size_t buffer_len, in Read()
[all …]
|
| D | socketstream.h | 22 class SocketStream : public StreamInterface, public sigslot::has_slots<> {
24 explicit SocketStream(AsyncSocket* socket);
25 virtual ~SocketStream();
50 DISALLOW_EVIL_CONSTRUCTORS(SocketStream);
|
| D | socketpool.h | 25 class SocketStream; variable
109 SocketStream* stream_;
|
| /external/chromium_org/net/socket_stream/ |
| D | socket_stream.cc | 52 int SocketStream::Delegate::OnStartOpenConnection( in OnStartOpenConnection()
53 SocketStream* socket, const CompletionCallback& callback) { in OnStartOpenConnection()
57 void SocketStream::Delegate::OnAuthRequired(SocketStream* socket, in OnAuthRequired()
63 void SocketStream::Delegate::OnSSLCertificateError( in OnSSLCertificateError()
64 SocketStream* socket, in OnSSLCertificateError()
70 bool SocketStream::Delegate::CanGetCookies(SocketStream* socket, in CanGetCookies()
75 bool SocketStream::Delegate::CanSetCookie(SocketStream* request, in CanSetCookie()
82 SocketStream::ResponseHeaders::ResponseHeaders() : IOBuffer() {} in ResponseHeaders()
84 void SocketStream::ResponseHeaders::Realloc(size_t new_size) { in Realloc()
88 SocketStream::ResponseHeaders::~ResponseHeaders() { data_ = NULL; } in ~ResponseHeaders()
[all …]
|
| D | socket_stream.h | 49 class NET_EXPORT SocketStream
50 : public base::RefCountedThreadSafe<SocketStream> {
63 virtual int OnStartOpenConnection(SocketStream* socket,
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,
94 virtual void OnSSLCertificateError(SocketStream* socket,
101 virtual void OnError(const SocketStream* socket, int error) {} in OnError()
[all …]
|
| D | socket_stream_unittest.cc | 39 SocketStream* socket_stream, in SocketStreamEvent()
48 SocketStream* socket;
55 class SocketStreamEventRecorder : public SocketStream::Delegate {
92 SocketStream* socket, in OnStartOpenConnection()
102 virtual void OnConnected(SocketStream* socket, in OnConnected()
111 virtual void OnSentData(SocketStream* socket, in OnSentData()
119 virtual void OnReceivedData(SocketStream* socket, in OnReceivedData()
127 virtual void OnClose(SocketStream* socket) OVERRIDE { in OnClose()
136 virtual void OnAuthRequired(SocketStream* socket, in OnAuthRequired()
144 virtual void OnError(const SocketStream* socket, int error) OVERRIDE { in OnError()
[all …]
|
| D | socket_stream_job.h | 34 SocketStream::Delegate* delegate,
43 SocketStream::Delegate* delegate,
50 void InitSocketStream(SocketStream* socket) { in InitSocketStream()
54 virtual SocketStream::UserData* GetUserData(const void* key) const;
55 virtual void SetUserData(const void* key, SocketStream::UserData* data);
87 scoped_refptr<SocketStream> socket_;
|
| D | socket_stream_job_manager.cc | 23 const GURL& url, SocketStream::Delegate* delegate, in CreateJob()
29 job->InitSocketStream(new SocketStream(url, delegate, context, in CreateJob()
44 job->InitSocketStream(new SocketStream(url, delegate, context, cookie_store)); in CreateJob()
|
| D | socket_stream_job.cc | 25 SocketStream::Delegate* delegate, in CreateSocketStreamJob()
45 SocketStream::UserData* SocketStreamJob::GetUserData(const void* key) const { in GetUserData()
50 SocketStream::UserData* data) { in SetUserData()
|
| D | socket_stream_job_manager.h | 25 const GURL& url, SocketStream::Delegate* delegate,
|
| /external/chromium_org/net/websockets/ |
| D | websocket_throttle_test.cc | 23 class DummySocketStreamDelegate : public SocketStream::Delegate {
28 SocketStream* socket, int max_pending_send_allowed) OVERRIDE {} in OnConnected()
29 virtual void OnSentData(SocketStream* socket, in OnSentData()
31 virtual void OnReceivedData(SocketStream* socket, in OnReceivedData()
33 virtual void OnClose(SocketStream* socket) OVERRIDE {} in OnClose()
60 SocketStream* socket, const AddressList& list) { in MockSocketStreamConnect()
72 DCHECK_EQ(socket->next_state_, SocketStream::STATE_NONE); in MockSocketStreamConnect()
88 scoped_refptr<SocketStream> s1( in TEST_F()
89 new SocketStream(GURL("ws://host1/"), w1.get(), &context, NULL)); in TEST_F()
108 scoped_refptr<SocketStream> s2( in TEST_F()
[all …]
|
| D | websocket_job.h | 36 public SocketStream::Delegate,
48 explicit WebSocketJob(SocketStream::Delegate* delegate);
61 SocketStream* socket, const CompletionCallback& callback) OVERRIDE;
62 virtual void OnConnected(SocketStream* socket,
64 virtual void OnSentData(SocketStream* socket, int amount_sent) OVERRIDE;
65 virtual void OnReceivedData(SocketStream* socket,
68 virtual void OnClose(SocketStream* socket) OVERRIDE;
70 SocketStream* socket, AuthChallengeInfo* auth_info) OVERRIDE;
71 virtual void OnSSLCertificateError(SocketStream* socket,
74 virtual void OnError(const SocketStream* socket, int error) OVERRIDE;
[all …]
|
| D | websocket_job.cc | 39 const GURL& url, net::SocketStream::Delegate* delegate, in WebSocketJobFactory()
42 job->InitSocketStream(new net::SocketStream(url, job, context, cookie_store)); in WebSocketJobFactory()
67 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate) in WebSocketJob()
162 SocketStream* socket, const CompletionCallback& callback) { in OnStartOpenConnection()
186 SocketStream* socket, int max_pending_send_allowed) { in OnConnected()
194 void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) { in OnSentData()
230 SocketStream* socket, const char* data, int len) { in OnReceivedData()
243 void WebSocketJob::OnClose(SocketStream* socket) { in OnClose()
250 SocketStream::Delegate* delegate = delegate_; in OnClose()
263 SocketStream* socket, AuthChallengeInfo* auth_info) { in OnAuthRequired()
[all …]
|
| D | websocket_job_test.cc | 42 class MockSocketStream : public SocketStream {
44 MockSocketStream(const GURL& url, SocketStream::Delegate* delegate, in MockSocketStream()
46 : SocketStream(url, delegate, context, cookie_store) {} in MockSocketStream()
74 class MockSocketStreamDelegate : public SocketStream::Delegate {
100 SocketStream* socket, in OnStartOpenConnection()
106 virtual void OnConnected(SocketStream* socket, in OnConnected()
111 virtual void OnSentData(SocketStream* socket, in OnSentData()
117 virtual void OnReceivedData(SocketStream* socket, in OnReceivedData()
123 virtual void OnClose(SocketStream* socket) OVERRIDE { in OnClose()
127 virtual bool CanGetCookies(SocketStream* socket, in CanGetCookies()
[all …]
|
| D | websocket_throttle.h | 20 class SocketStream; variable
|
| /external/chromium_org/content/browser/renderer_host/ |
| D | socket_stream_dispatcher_host.h | 32 public net::SocketStream::Delegate,
50 virtual void OnConnected(net::SocketStream* socket,
52 virtual void OnSentData(net::SocketStream* socket, int amount_sent) OVERRIDE;
53 virtual void OnReceivedData(net::SocketStream* socket,
55 virtual void OnClose(net::SocketStream* socket) OVERRIDE;
56 virtual void OnError(const net::SocketStream* socket, int error) OVERRIDE;
57 virtual void OnSSLCertificateError(net::SocketStream* socket,
60 virtual bool CanGetCookies(net::SocketStream* socket,
62 virtual bool CanSetCookie(net::SocketStream* request,
|
| D | socket_stream_dispatcher_host.cc | 60 void SocketStreamDispatcherHost::OnConnected(net::SocketStream* socket, in OnConnected()
76 void SocketStreamDispatcherHost::OnSentData(net::SocketStream* socket, in OnSentData()
92 net::SocketStream* socket, const char* data, int len) { in OnReceivedData()
107 void SocketStreamDispatcherHost::OnClose(net::SocketStream* socket) { in OnClose()
117 void SocketStreamDispatcherHost::OnError(const net::SocketStream* socket, in OnError()
135 net::SocketStream* socket, const net::SSLInfo& ssl_info, bool fatal) { in OnSSLCertificateError()
152 bool SocketStreamDispatcherHost::CanGetCookies(net::SocketStream* socket, in CanGetCookies()
169 bool SocketStreamDispatcherHost::CanSetCookie(net::SocketStream* request, in CanSetCookie()
|
| D | socket_stream_host.cc | 18 class SocketStreamId : public net::SocketStream::UserData {
31 net::SocketStream::Delegate* delegate, in SocketStreamHost()
46 const net::SocketStream* socket) { in SocketIdFromSocketStream()
47 net::SocketStream::UserData* d = socket->GetUserData(kSocketIdKey); in SocketIdFromSocketStream()
|
| D | socket_stream_host.h | 31 SocketStreamHost(net::SocketStream::Delegate* delegate,
38 static int SocketIdFromSocketStream(const net::SocketStream* socket);
69 net::SocketStream::Delegate* delegate_;
|
| /external/chromium_org/net/base/ |
| D | network_delegate.h | 38 class SocketStream; variable
96 int NotifyBeforeSocketStreamConnect(SocketStream* socket,
238 SocketStream* socket, const CompletionCallback& callback);
|
| D | network_delegate.cc | 101 SocketStream* socket, in NotifyBeforeSocketStreamConnect()
223 SocketStream* socket, in OnBeforeSocketStreamConnect()
|