Lines Matching refs:websocket
15 #include "net/websockets/websocket.h"
25 WebSocketEvent(EventType type, net::WebSocket* websocket,
27 : event_type(type), socket(websocket), msg(websocket_msg) {}
30 net::WebSocket* socket;
57 virtual void OnOpen(net::WebSocket* socket) {
64 virtual void OnMessage(net::WebSocket* socket, const std::string& msg) {
70 virtual void OnClose(net::WebSocket* socket) {
101 void InitReadBuf(WebSocket* websocket) {
103 websocket->current_read_buf_ = new GrowableIOBuffer();
105 void SetReadConsumed(WebSocket* websocket, int consumed) {
106 websocket->read_consumed_len_ = consumed;
108 void AddToReadBuf(WebSocket* websocket, const char* data, int len) {
109 websocket->AddToReadBuffer(data, len);
112 void TestProcessFrameData(WebSocket* websocket,
115 websocket->ProcessFrameData();
118 websocket->current_read_buf_->StartOfBuffer()
119 + websocket->read_consumed_len_;
121 websocket->current_read_buf_->offset() - websocket->read_consumed_len_;
133 "Upgrade: WebSocket\r\n"
135 "WebSocket-Origin: http://example.com\r\n"
136 "WebSocket-Location: ws://example.com/demo\r\n"
137 "WebSocket-Protocol: sample\r\n"
144 "Upgrade: WebSocket\r\n"
148 "WebSocket-Protocol: sample\r\n"
154 WebSocket::Request* request(
155 new WebSocket::Request(GURL("ws://example.com/demo"),
170 scoped_refptr<WebSocket> websocket(
171 new WebSocket(request, delegate.get()));
173 EXPECT_EQ(WebSocket::INITIALIZED, websocket->ready_state());
174 websocket->Connect();
192 "Upgrade: WebSocket\r\n"
194 "WebSocket-Origin: http://example.com\r\n"
195 "WebSocket-Location: ws://example.com/demo\r\n"
196 "WebSocket-Protocol: sample\r\n"
204 "Upgrade: WebSocket\r\n"
208 "WebSocket-Protocol: sample\r\n"
214 WebSocket::Request* request(
215 new WebSocket::Request(GURL("ws://example.com/demo"),
230 scoped_refptr<WebSocket> websocket(
231 new WebSocket(request, delegate.get()));
233 EXPECT_EQ(WebSocket::INITIALIZED, websocket->ready_state());
234 websocket->Connect();
248 WebSocket::Request* request(
249 new WebSocket::Request(GURL("ws://example.com/demo"),
258 scoped_refptr<WebSocket> websocket(
259 new WebSocket(request, delegate.get()));
266 InitReadBuf(websocket.get());
267 AddToReadBuf(websocket.get(), kTestLengthFrame, kTestLengthFrameLength);
268 SetReadConsumed(websocket.get(), 0);
273 TestProcessFrameData(websocket.get(),
279 websocket->DetachDelegate();
283 WebSocket::Request* request(
284 new WebSocket::Request(GURL("ws://example.com/demo"),
293 scoped_refptr<WebSocket> websocket(
294 new WebSocket(request, delegate.get()));
299 InitReadBuf(websocket.get());
300 AddToReadBuf(websocket.get(), kTestUnterminatedFrame,
302 SetReadConsumed(websocket.get(), 0);
303 TestProcessFrameData(websocket.get(),
313 AddToReadBuf(websocket.get(), kTestTerminateFrame,
315 TestProcessFrameData(websocket.get(), "", 0);
327 websocket->DetachDelegate();
331 WebSocket::Request request(GURL("ws://example.com/demo"),
341 WebSocket::Request request(GURL("wss://example.com/demo"),
350 WebSocket::Request request(GURL("ws://example.com/demo"),
356 "Upgrade: WebSocket\r\n"
360 "WebSocket-Protocol: sample\r\n"
366 WebSocket::Request request(GURL("ws://example.com/Test?q=xxx&p=%20"),
377 WebSocket::Request request(GURL("ws://Example.Com/demo"),
390 WebSocket::Request request(GURL("ws://example.com:80/demo"),
401 WebSocket::Request request(GURL("wss://example.com:443/demo"),
412 WebSocket::Request request(GURL("ws://example.com:8080/demo"),
423 WebSocket::Request request(GURL("wss://example.com:4443/demo"),
434 WebSocket::Request request(GURL("ws://example.com:443/demo"),
445 WebSocket::Request request(GURL("wss://example.com:80/demo"),
