OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:SocketStream
(Results
1 - 11
of
11
) sorted by null
/external/chromium/net/socket_stream/
socket_stream_throttle.h
16
class
SocketStream
;
18
// Abstract interface to throttle
SocketStream
per URL scheme.
27
virtual int OnStartOpenConnection(
SocketStream
* socket,
38
virtual int OnRead(
SocketStream
* socket, const char* data, int len,
49
virtual int OnWrite(
SocketStream
* socket, const char* data, int len,
57
virtual void OnClose(
SocketStream
* socket) {}
socket_stream.h
39
//
SocketStream
is used to implement Web Sockets.
45
class
SocketStream
: public base::RefCountedThreadSafe<
SocketStream
> {
48
// information with a
SocketStream
. Use GetUserData(key) and
64
virtual void OnConnected(
SocketStream
* socket,
68
virtual void OnSentData(
SocketStream
* socket,
72
virtual void OnReceivedData(
SocketStream
* socket,
76
virtual void OnClose(
SocketStream
* socket) = 0;
81
virtual void OnAuthRequired(
SocketStream
* socket,
90
virtual void OnError(const
SocketStream
* socket, int error) {
[
all
...]
socket_stream.cc
37
void
SocketStream
::ResponseHeaders::Realloc(size_t new_size) {
41
SocketStream
::
SocketStream
(const GURL& url, Delegate* delegate)
51
io_callback_(this, &
SocketStream
::OnIOCompleted)),
53
read_callback_(this, &
SocketStream
::OnReadCompleted)),
55
write_callback_(this, &
SocketStream
::OnWriteCompleted)),
75
SocketStream
::~
SocketStream
() {
80
SocketStream
::UserData*
SocketStream
::GetUserData
[
all
...]
socket_stream_unittest.cc
24
SocketStreamEvent(EventType type, net::
SocketStream
* socket_stream,
31
net::
SocketStream
* socket;
37
class SocketStreamEventRecorder : public net::
SocketStream
::Delegate {
70
virtual void OnConnected(net::
SocketStream
* socket,
79
virtual void OnSentData(net::
SocketStream
* socket,
87
virtual void OnReceivedData(net::
SocketStream
* socket,
95
virtual void OnClose(net::
SocketStream
* socket) {
104
virtual void OnAuthRequired(net::
SocketStream
* socket,
193
scoped_refptr<
SocketStream
> socket_stream =
194
new
SocketStream
(GURL("ws://example.com/demo"), delegate.get())
[
all
...]
/external/chromium/net/websockets/
websocket_throttle.h
24
virtual int OnStartOpenConnection(
SocketStream
* socket,
26
virtual int OnRead(
SocketStream
* socket, const char* data, int len,
28
virtual int OnWrite(
SocketStream
* socket, const char* data, int len,
30
virtual void OnClose(
SocketStream
* socket);
46
void PutInQueue(
SocketStream
* socket, WebSocketState* state);
50
void RemoveFromQueue(
SocketStream
* socket, WebSocketState* state);
websocket_throttle_unittest.cc
17
class DummySocketStreamDelegate : public net::
SocketStream
::Delegate {
22
net::
SocketStream
* socket, int max_pending_send_allowed) {}
23
virtual void OnSentData(net::
SocketStream
* socket, int amount_sent) {}
24
virtual void OnReceivedData(net::
SocketStream
* socket,
26
virtual void OnClose(net::
SocketStream
* socket) {}
63
static void SetAddressList(
SocketStream
* socket, struct addrinfo* head) {
83
scoped_refptr<
SocketStream
> s1 =
84
new
SocketStream
(GURL("ws://host1/"), &delegate);
93
scoped_refptr<
SocketStream
> s2 =
94
new
SocketStream
(GURL("ws://host2/"), &delegate)
[
all
...]
websocket.h
54
public
SocketStream
::Delegate {
139
//
SocketStream
::Delegate methods.
141
virtual void OnConnected(
SocketStream
* socket_stream,
143
virtual void OnSentData(
SocketStream
* socket_stream, int amount_sent);
144
virtual void OnReceivedData(
SocketStream
* socket_stream,
146
virtual void OnClose(
SocketStream
* socket);
147
virtual void OnError(const
SocketStream
* socket, int error);
210
scoped_refptr<
SocketStream
> socket_stream_;
websocket_throttle.cc
44
// State for WebSocket protocol on each
SocketStream
.
45
// This is owned in
SocketStream
as UserData keyed by WebSocketState::kKeyName.
49
class WebSocketThrottle::WebSocketState : public
SocketStream
::UserData {
142
// If true, it will be removed from queue and deleted from the
SocketStream
165
SocketStream
* socket, CompletionCallback* callback) {
171
int WebSocketThrottle::OnRead(
SocketStream
* socket,
188
int WebSocketThrottle::OnWrite(
SocketStream
* socket,
195
void WebSocketThrottle::OnClose(
SocketStream
* socket) {
204
void WebSocketThrottle::PutInQueue(
SocketStream
* socket,
225
void WebSocketThrottle::RemoveFromQueue(
SocketStream
* socket
[
all
...]
websocket.cc
63
socket_stream_ = new
SocketStream
(request_->url(), this);
111
void WebSocket::OnConnected(
SocketStream
* socket_stream,
130
void WebSocket::OnSentData(
SocketStream
* socket_stream, int amount_sent) {
143
void WebSocket::OnReceivedData(
SocketStream
* socket_stream,
151
void WebSocket::OnClose(
SocketStream
* socket_stream) {
156
void WebSocket::OnError(const
SocketStream
* socket_stream, int error) {
/external/chromium/net/url_request/
url_request_context.h
27
class
SocketStream
;
92
RequestTracker<net::
SocketStream
>* socket_stream_tracker() {
151
RequestTracker<net::
SocketStream
> socket_stream_tracker_;
url_request_view_net_internals_job.cc
507
std::vector<net::
SocketStream
*> sockets =
529
RequestTracker<net::
SocketStream
>::RecentRequestInfoList recent =
532
DrawCommandButton("Clear", "clear-
socketstream
-graveyard", out);
548
: SubSection(parent, "
socketstream
", "
SocketStream
") {
585
if (command == "clear-
socketstream
-graveyard") {
655
"clear-
socketstream
-graveyard,"
Completed in 42 milliseconds