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),
31 net::WebSocket* socket;
61 virtual void OnOpen(net::WebSocket* socket) {
69 virtual void OnMessage(net::WebSocket* socket, const std::string& msg) {
75 virtual void OnError(net::WebSocket* socket) {
82 virtual void OnClose(net::WebSocket* socket, bool was_clean) {
115 void InitReadBuf(WebSocket* websocket) {
117 websocket->current_read_buf_ = new GrowableIOBuffer();
119 void SetReadConsumed(WebSocket* websocket, int consumed) {
120 websocket->read_consumed_len_ = consumed;
122 void AddToReadBuf(WebSocket* websocket, const char* data, int len) {
123 websocket->AddToReadBuffer(data, len);
126 void TestProcessFrameData(WebSocket* websocket,
129 websocket->ProcessFrameData();
132 websocket->current_read_buf_->StartOfBuffer()
133 + websocket->read_consumed_len_;
135 websocket->current_read_buf_->offset() - websocket->read_consumed_len_;
147 "Upgrade: WebSocket\r\n"
149 "WebSocket-Origin: http://example.com\r\n"
150 "WebSocket-Location: ws://example.com/demo\r\n"
151 "WebSocket-Protocol: sample\r\n"
158 "Upgrade: WebSocket\r\n"
162 "WebSocket-Protocol: sample\r\n"
170 WebSocket::Request* request(
171 new WebSocket::Request(GURL("ws://example.com/demo"),
175 WebSocket::DRAFT75,
187 scoped_refptr<WebSocket> websocket(
188 new WebSocket(request, delegate.get()));
190 EXPECT_EQ(WebSocket::INITIALIZED, websocket->ready_state());
191 websocket->Connect();
209 "Upgrade: WebSocket\r\n"
211 "WebSocket-Origin: http://example.com\r\n"
212 "WebSocket-Location: ws://example.com/demo\r\n"
213 "WebSocket-Protocol: sample\r\n"
221 "Upgrade: WebSocket\r\n"
225 "WebSocket-Protocol: sample\r\n"
233 WebSocket::Request* request(
234 new WebSocket::Request(GURL("ws://example.com/demo"),
238 WebSocket::DRAFT75,
250 scoped_refptr<WebSocket> websocket(
251 new WebSocket(request, delegate.get()));
253 EXPECT_EQ(WebSocket::INITIALIZED, websocket->ready_state());
254 websocket->Connect();
268 WebSocket::Request* request(
269 new WebSocket::Request(GURL("ws://example.com/demo"),
273 WebSocket::DRAFT75,
279 scoped_refptr<WebSocket> websocket(
280 new WebSocket(request, delegate.get()));
287 InitReadBuf(websocket.get());
288 AddToReadBuf(websocket.get(), kTestLengthFrame, kTestLengthFrameLength);
289 SetReadConsumed(websocket.get(), 0);
294 TestProcessFrameData(websocket.get(),
302 websocket->DetachDelegate();
306 WebSocket::Request* request(
307 new WebSocket::Request(GURL("ws://example.com/demo"),
311 WebSocket::DRAFT75,
317 scoped_refptr<WebSocket> websocket(
318 new WebSocket(request, delegate.get()));
323 InitReadBuf(websocket.get());
324 AddToReadBuf(websocket.get(), kTestUnterminatedFrame,
326 SetReadConsumed(websocket.get(), 0);
327 TestProcessFrameData(websocket.get(),
337 AddToReadBuf(websocket.get(), kTestTerminateFrame,
339 TestProcessFrameData(websocket.get(), "", 0);
351 websocket->DetachDelegate();
