| /development/tools/emulator/opengl/shared/OpenglCodecCommon/ |
| UnixStream.h | 19 #include "SocketStream.h"
21 class UnixStream : public SocketStream {
25 virtual SocketStream *accept();
|
| SocketStream.h | 22 class SocketStream : public IOStream {
26 explicit SocketStream(size_t bufsize = 10000);
27 virtual ~SocketStream();
30 virtual SocketStream *accept() = 0;
47 SocketStream(int sock, size_t bufSize);
|
| TcpStream.h | 19 #include "SocketStream.h"
21 class TcpStream : public SocketStream {
25 virtual SocketStream *accept();
|
| SocketStream.cpp | 16 #include "SocketStream.h"
32 SocketStream::SocketStream(size_t bufSize) :
40 SocketStream::SocketStream(int sock, size_t bufSize) :
48 SocketStream::~SocketStream()
64 void *SocketStream::allocBuffer(size_t minSize)
86 int SocketStream::commitBuffer(size_t size)
91 int SocketStream::writeFully(const void* buffer, size_t size
[all...] |
| Win32PipeStream.h | 19 #include "SocketStream.h"
22 class Win32PipeStream : public SocketStream {
27 virtual SocketStream *accept();
|
| TcpStream.cpp | 32 SocketStream(bufSize)
37 SocketStream(sock, bufSize)
58 SocketStream * TcpStream::accept()
|
| UnixStream.cpp | 38 SocketStream(bufSize)
43 SocketStream(sock, bufSize)
103 SocketStream * UnixStream::accept()
|
| /external/chromium/third_party/libjingle/source/talk/base/ |
| socketstream.cc | 28 #include "talk/base/socketstream.h"
32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
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)
[all...] |
| socketstream.h | 39 class SocketStream : public StreamInterface, public sigslot::has_slots<> {
41 explicit SocketStream(AsyncSocket* socket);
42 virtual ~SocketStream();
67 DISALLOW_EVIL_CONSTRUCTORS(SocketStream);
|
| /external/chromium/net/socket_stream/ |
| socket_stream_job.h | 19 // 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_;
|
| socket_stream.h | 41 // SocketStream is used to implement Web Sockets.
47 class SocketStream : public base::RefCountedThreadSafe<SocketStream> {
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* socket
[all...] |
| socket_stream.cc | 41 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)
62 io_callback_(this, &SocketStream::OnIOCompleted)),
64 read_callback_(this, &SocketStream::OnReadCompleted)),
66 write_callback_(this, &SocketStream::OnWriteCompleted)),
82 SocketStream::UserData* SocketStream::GetUserData
[all...] |
| socket_stream_job.cc | 24 SocketStream::Delegate* delegate,
44 SocketStream::UserData* SocketStreamJob::GetUserData(const void* key) const {
49 SocketStream::UserData* data) {
|
| socket_stream_job_manager.cc | 23 const GURL& url, SocketStream::Delegate* delegate) const {
28 job->InitSocketStream(new SocketStream(url, delegate));
42 job->InitSocketStream(new SocketStream(url, delegate));
|
| socket_stream_unittest.cc | 27 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(GURL("ws://example.com/demo"), delegate.get()))
[all...] |
| socket_stream_job_manager.h | 26 const GURL& url, SocketStream::Delegate* delegate) const;
|
| /external/chromium/net/websockets/ |
| websocket_job.h | 26 // 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* socket)
[all...] |
| websocket_throttle_unittest.cc | 18 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::DetachDelegate(), whe
[all...] |
| websocket_throttle.h | 18 class SocketStream;
|
| websocket.h | 59 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_;
|
| websocket_job.cc | 35 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* socket, AuthChallengeInfo* auth_info)
[all...] |
| /development/tools/emulator/opengl/tests/ut_renderer/ |
| ReadBuffer.h | 19 #include "SocketStream.h"
23 ReadBuffer(SocketStream *stream, size_t bufSize);
34 SocketStream *m_stream;
|
| ReadBuffer.cpp | 20 ReadBuffer::ReadBuffer(SocketStream *stream, size_t bufsize)
|
| ut_renderer.cpp | 49 SocketStream *glStream = socket->accept();
|
| /development/tools/emulator/opengl/host/libs/libOpenglRender/ |
| RenderServer.h | 19 #include "SocketStream.h"
34 SocketStream *m_listenSock;
|
