Home
last modified time | relevance | path

Searched refs:SocketStream (Results 1 – 25 of 55) sorted by relevance

123

/external/chromium/third_party/libjingle/source/talk/base/
Dsocketstream.cc32 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 …]
Dsocketstream.h39 class SocketStream : public StreamInterface, public sigslot::has_slots<> {
41 explicit SocketStream(AsyncSocket* socket);
42 virtual ~SocketStream();
67 DISALLOW_EVIL_CONSTRUCTORS(SocketStream);
/external/chromium_org/third_party/libjingle/source/talk/base/
Dsocketstream.cc32 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 …]
Dsocketstream.h39 class SocketStream : public StreamInterface, public sigslot::has_slots<> {
41 explicit SocketStream(AsyncSocket* socket);
42 virtual ~SocketStream();
67 DISALLOW_EVIL_CONSTRUCTORS(SocketStream);
/external/chromium_org/net/socket_stream/
Dsocket_stream.cc52 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 …]
Dsocket_stream.h48 class NET_EXPORT SocketStream
49 : public base::RefCountedThreadSafe<SocketStream> {
62 virtual int OnStartOpenConnection(SocketStream* socket,
70 virtual void OnConnected(SocketStream* socket,
74 virtual void OnSentData(SocketStream* socket,
78 virtual void OnReceivedData(SocketStream* socket,
82 virtual void OnClose(SocketStream* socket) = 0;
87 virtual void OnAuthRequired(SocketStream* socket,
93 virtual void OnSSLCertificateError(SocketStream* socket,
100 virtual void OnError(const SocketStream* socket, int error) {} in OnError()
[all …]
Dsocket_stream_unittest.cc37 SocketStream* socket_stream, in SocketStreamEvent()
46 SocketStream* socket;
53 class SocketStreamEventRecorder : public SocketStream::Delegate {
90 SocketStream* socket, in OnStartOpenConnection()
100 virtual void OnConnected(SocketStream* socket, in OnConnected()
109 virtual void OnSentData(SocketStream* socket, in OnSentData()
117 virtual void OnReceivedData(SocketStream* socket, in OnReceivedData()
125 virtual void OnClose(SocketStream* socket) OVERRIDE { in OnClose()
134 virtual void OnAuthRequired(SocketStream* socket, in OnAuthRequired()
142 virtual void OnError(const SocketStream* socket, int error) OVERRIDE { in OnError()
[all …]
Dsocket_stream_job.h33 SocketStream::Delegate* delegate);
40 SocketStream::Delegate* delegate,
45 void InitSocketStream(SocketStream* socket) { in InitSocketStream()
49 virtual SocketStream::UserData* GetUserData(const void* key) const;
50 virtual void SetUserData(const void* key, SocketStream::UserData* data);
81 scoped_refptr<SocketStream> socket_;
Dsocket_stream_job_manager.cc23 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()
/external/chromium/net/socket_stream/
Dsocket_stream.cc41 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 …]
Dsocket_stream.h47 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 …]
Dsocket_stream_job.h29 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_;
Dsocket_stream_unittest.cc27 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 …]
Dsocket_stream_job_manager.cc23 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()
/external/chromium/net/websockets/
Dwebsocket_job.h32 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 …]
Dwebsocket_throttle_unittest.cc18 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 …]
Dwebsocket.h59 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_;
Dwebsocket_job.cc35 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 …]
/external/chromium_org/net/websockets/
Dwebsocket_throttle_test.cc19 class DummySocketStreamDelegate : public net::SocketStream::Delegate {
24 net::SocketStream* socket, int max_pending_send_allowed) OVERRIDE {} in OnConnected()
25 virtual void OnSentData(net::SocketStream* socket, in OnSentData()
27 virtual void OnReceivedData(net::SocketStream* socket, in OnReceivedData()
29 virtual void OnClose(net::SocketStream* socket) OVERRIDE {} in OnClose()
46 SocketStream* socket, const AddressList& list) { in MockSocketStreamConnect()
58 DCHECK_EQ(socket->next_state_, SocketStream::STATE_NONE); in MockSocketStreamConnect()
75 scoped_refptr<SocketStream> s1( in TEST_F()
76 new SocketStream(GURL("ws://host1/"), w1.get())); in TEST_F()
96 scoped_refptr<SocketStream> s2( in TEST_F()
[all …]
Dwebsocket_job.h36 public SocketStream::Delegate,
48 explicit WebSocketJob(SocketStream::Delegate* delegate);
65 SocketStream* socket, const CompletionCallback& callback) OVERRIDE;
66 virtual void OnConnected(SocketStream* socket,
68 virtual void OnSentData(SocketStream* socket, int amount_sent) OVERRIDE;
69 virtual void OnReceivedData(SocketStream* socket,
72 virtual void OnClose(SocketStream* socket) OVERRIDE;
74 SocketStream* socket, AuthChallengeInfo* auth_info) OVERRIDE;
75 virtual void OnSSLCertificateError(SocketStream* socket,
78 virtual void OnError(const SocketStream* socket, int error) OVERRIDE;
[all …]
Dwebsocket_job.cc39 const GURL& url, net::SocketStream::Delegate* delegate) { in WebSocketJobFactory()
41 job->InitSocketStream(new net::SocketStream(url, job)); in WebSocketJobFactory()
73 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate) in WebSocketJob()
168 SocketStream* socket, const CompletionCallback& callback) { in OnStartOpenConnection()
192 SocketStream* socket, int max_pending_send_allowed) { in OnConnected()
200 void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) { in OnSentData()
236 SocketStream* socket, const char* data, int len) { in OnReceivedData()
249 void WebSocketJob::OnClose(SocketStream* socket) { in OnClose()
256 SocketStream::Delegate* delegate = delegate_; in OnClose()
269 SocketStream* socket, AuthChallengeInfo* auth_info) { in OnAuthRequired()
[all …]
/external/chromium_org/content/browser/renderer_host/
Dsocket_stream_dispatcher_host.h32 public net::SocketStream::Delegate,
51 virtual void OnConnected(net::SocketStream* socket,
53 virtual void OnSentData(net::SocketStream* socket, int amount_sent) OVERRIDE;
54 virtual void OnReceivedData(net::SocketStream* socket,
56 virtual void OnClose(net::SocketStream* socket) OVERRIDE;
57 virtual void OnError(const net::SocketStream* socket, int error) OVERRIDE;
58 virtual void OnSSLCertificateError(net::SocketStream* socket,
61 virtual bool CanGetCookies(net::SocketStream* socket,
63 virtual bool CanSetCookie(net::SocketStream* request,
Dsocket_stream_dispatcher_host.cc59 void SocketStreamDispatcherHost::OnConnected(net::SocketStream* socket, in OnConnected()
75 void SocketStreamDispatcherHost::OnSentData(net::SocketStream* socket, in OnSentData()
91 net::SocketStream* socket, const char* data, int len) { in OnReceivedData()
106 void SocketStreamDispatcherHost::OnClose(net::SocketStream* socket) { in OnClose()
116 void SocketStreamDispatcherHost::OnError(const net::SocketStream* socket, in OnError()
134 net::SocketStream* socket, const net::SSLInfo& ssl_info, bool fatal) { in OnSSLCertificateError()
151 bool SocketStreamDispatcherHost::CanGetCookies(net::SocketStream* socket, in CanGetCookies()
157 bool SocketStreamDispatcherHost::CanSetCookie(net::SocketStream* request, in CanSetCookie()
Dsocket_stream_host.cc17 class SocketStreamId : public net::SocketStream::UserData {
30 net::SocketStream::Delegate* delegate, in SocketStreamHost()
43 const net::SocketStream* socket) { in SocketIdFromSocketStream()
44 net::SocketStream::UserData* d = socket->GetUserData(kSocketIdKey); in SocketIdFromSocketStream()
Dsocket_stream_host.h31 SocketStreamHost(net::SocketStream::Delegate* delegate,
37 static int SocketIdFromSocketStream(const net::SocketStream* socket);
68 net::SocketStream::Delegate* delegate_;

123