Searched refs:SocketStream (Results 1 - 19 of 19) sorted by last modified time

/external/chromium/net/socket_stream/
H A Dsocket_stream.cc41 SocketStream::ResponseHeaders::ResponseHeaders() : IOBuffer() {}
43 void SocketStream::ResponseHeaders::Realloc(size_t new_size) {
47 SocketStream::ResponseHeaders::~ResponseHeaders() { data_ = NULL; }
49 SocketStream::SocketStream(const GURL& url, Delegate* delegate) function in class:net::SocketStream
62 io_callback_(this, &SocketStream::OnIOCompleted)),
64 read_callback_(this, &SocketStream::OnReadCompleted)),
66 write_callback_(this, &SocketStream::OnWriteCompleted)),
82 SocketStream::UserData* SocketStream
[all...]
H A Dsocket_stream.h41 // SocketStream is used to implement Web Sockets.
47 class SocketStream : public base::RefCountedThreadSafe<SocketStream> { class in namespace:net
50 // information with a SocketStream. Use GetUserData(key) and
62 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* socke
[all...]
H A Dsocket_stream_job.cc24 SocketStream::Delegate* delegate,
44 SocketStream::UserData* SocketStreamJob::GetUserData(const void* key) const {
49 SocketStream::UserData* data) {
H A Dsocket_stream_job.h19 // SocketStreamJob represents full-duplex communication over SocketStream.
21 // over SocketStream, you can implement protocol specific job (e.g.
22 // WebSocketJob) to do some work on data over SocketStream.
29 SocketStream::Delegate* delegate);
36 SocketStream::Delegate* delegate,
40 void InitSocketStream(SocketStream* socket) {
44 virtual SocketStream::UserData* GetUserData(const void* key) const;
45 virtual void SetUserData(const void* key, SocketStream::UserData* data);
70 scoped_refptr<SocketStream> socket_;
H A Dsocket_stream_job_manager.cc23 const GURL& url, SocketStream::Delegate* delegate) const {
28 job->InitSocketStream(new SocketStream(url, delegate));
42 job->InitSocketStream(new SocketStream(url, delegate));
H A Dsocket_stream_job_manager.h26 const GURL& url, SocketStream::Delegate* delegate) const;
H A Dsocket_stream_unittest.cc27 SocketStreamEvent(EventType type, net::SocketStream* socket_stream,
34 net::SocketStream* socket;
40 class SocketStreamEventRecorder : public net::SocketStream::Delegate {
73 virtual void OnConnected(net::SocketStream* socket,
82 virtual void OnSentData(net::SocketStream* socket,
90 virtual void OnReceivedData(net::SocketStream* socket,
98 virtual void OnClose(net::SocketStream* socket) {
107 virtual void OnAuthRequired(net::SocketStream* socket,
243 scoped_refptr<SocketStream> socket_stream(
244 new SocketStream(GUR
[all...]
/external/chromium/net/websockets/
H A Dwebsocket.cc54 socket_stream_ = new SocketStream(request_->url(), this);
145 void WebSocket::OnConnected(SocketStream* socket_stream,
180 void WebSocket::OnSentData(SocketStream* socket_stream, int amount_sent) {
193 void WebSocket::OnReceivedData(SocketStream* socket_stream,
201 void WebSocket::OnClose(SocketStream* socket_stream) {
206 void WebSocket::OnError(const SocketStream* socket_stream, int error) {
H A Dwebsocket.h59 public SocketStream::Delegate {
149 // SocketStream::Delegate methods.
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_;
H A Dwebsocket_job.cc35 const GURL& url, net::SocketStream::Delegate* delegate) {
37 job->InitSocketStream(new net::SocketStream(url, job));
62 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate)
164 SocketStream* socket, CompletionCallback* callback) {
177 SocketStream* socket, int max_pending_send_allowed) {
185 void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) {
214 SocketStream* socket, const char* data, int len) {
238 void WebSocketJob::OnClose(SocketStream* socket) {
245 SocketStream::Delegate* delegate = delegate_;
258 SocketStream* socke
[all...]
H A Dwebsocket_job.h26 // WebSocket protocol specific job on SocketStream.
32 class WebSocketJob : public SocketStreamJob, public SocketStream::Delegate {
34 // This is state of WebSocket, not SocketStream.
43 explicit WebSocketJob(SocketStream::Delegate* delegate);
56 // SocketStream::Delegate methods.
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* socke
[all...]
H A Dwebsocket_job_unittest.cc27 class MockSocketStream : public SocketStream {
29 MockSocketStream(const GURL& url, SocketStream::Delegate* delegate)
30 : SocketStream(url, delegate) {}
54 class MockSocketStreamDelegate : public SocketStream::Delegate {
60 virtual void OnConnected(SocketStream* socket, int max_pending_send_allowed) {
62 virtual void OnSentData(SocketStream* socket, int amount_sent) {
65 virtual void OnReceivedData(SocketStream* socket,
69 virtual void OnClose(SocketStream* socket) {
220 SocketStream* GetSocket(SocketStreamJob* job) {
H A Dwebsocket_throttle.h18 class SocketStream;
H A Dwebsocket_throttle_unittest.cc18 class DummySocketStreamDelegate : public net::SocketStream::Delegate {
23 net::SocketStream* socket, int max_pending_send_allowed) {}
24 virtual void OnSentData(net::SocketStream* socket, int amount_sent) {}
25 virtual void OnReceivedData(net::SocketStream* socket,
27 virtual void OnClose(net::SocketStream* socket) {}
65 SocketStream* socket, struct addrinfo* head) {
67 // In SocketStream::Connect(), it adds reference to socket, which is
68 // balanced with SocketStream::Finish() that is finally called from
69 // SocketStream::Close() or SocketStream
[all...]
/external/chromium/third_party/libjingle/source/talk/base/
H A Dsocketpool.cc153 return new SocketStream(socket);
187 stream_ = new SocketStream(socket);
H A Dsocketpool.h42 class SocketStream;
126 SocketStream* stream_;
H A Dsocketstream.cc32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { function in class:talk_base::SocketStream
36 SocketStream::~SocketStream() {
40 void SocketStream::Attach(AsyncSocket* socket) {
45 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent);
46 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent);
47 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent);
48 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent);
52 AsyncSocket* SocketStream
[all...]
H A Dsocketstream.h39 class SocketStream : public StreamInterface, public sigslot::has_slots<> { class in namespace:talk_base
41 explicit SocketStream(AsyncSocket* socket);
42 virtual ~SocketStream();
67 DISALLOW_EVIL_CONSTRUCTORS(SocketStream);
/external/chromium/third_party/libjingle/source/talk/examples/login/
H A Dxmppsocket.cc66 stream_ = new talk_base::SocketStream(cricket_socket_);

Completed in 127 milliseconds