OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/websockets/websocket_deflate_stream.h" | 5 #include "net/websockets/websocket_deflate_stream.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 #include <deque> | 8 #include <deque> |
9 #include <string> | 9 #include <string> |
10 | 10 |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
61 | 61 |
62 std::string ToString(IOBuffer* buffer, size_t size) { | 62 std::string ToString(IOBuffer* buffer, size_t size) { |
63 return std::string(buffer->data(), size); | 63 return std::string(buffer->data(), size); |
64 } | 64 } |
65 | 65 |
66 std::string ToString(const scoped_refptr<IOBuffer>& buffer, size_t size) { | 66 std::string ToString(const scoped_refptr<IOBuffer>& buffer, size_t size) { |
67 return ToString(buffer.get(), size); | 67 return ToString(buffer.get(), size); |
68 } | 68 } |
69 | 69 |
70 std::string ToString(const WebSocketFrame* frame) { | 70 std::string ToString(const WebSocketFrame* frame) { |
71 return frame->data ? ToString(frame->data, frame->header.payload_length) : ""; | 71 return frame->data.get() ? ToString(frame->data, frame->header.payload_length) |
| 72 : ""; |
72 } | 73 } |
73 | 74 |
74 void AppendTo(ScopedVector<WebSocketFrame>* frames, | 75 void AppendTo(ScopedVector<WebSocketFrame>* frames, |
75 WebSocketFrameHeader::OpCode opcode, | 76 WebSocketFrameHeader::OpCode opcode, |
76 FrameFlag flag, | 77 FrameFlag flag, |
77 const std::string& data) { | 78 const std::string& data) { |
78 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(opcode)); | 79 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(opcode)); |
79 frame->header.final = (flag & kFinal); | 80 frame->header.final = (flag & kFinal); |
80 frame->header.reserved1 = (flag & kReserved1); | 81 frame->header.reserved1 = (flag & kReserved1); |
81 frame->data = ToIOBuffer(data); | 82 frame->data = ToIOBuffer(data); |
(...skipping 1257 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1339 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames(); | 1340 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames(); |
1340 ASSERT_EQ(1u, frames_passed.size()); | 1341 ASSERT_EQ(1u, frames_passed.size()); |
1341 EXPECT_EQ( | 1342 EXPECT_EQ( |
1342 std::string("r\xce(\xca\xcf\xcd,\xcdM\x1c\xe1\xc0\x19\x1a\x0e\0\0", 17), | 1343 std::string("r\xce(\xca\xcf\xcd,\xcdM\x1c\xe1\xc0\x19\x1a\x0e\0\0", 17), |
1343 ToString(frames_passed[0])); | 1344 ToString(frames_passed[0])); |
1344 } | 1345 } |
1345 | 1346 |
1346 } // namespace | 1347 } // namespace |
1347 | 1348 |
1348 } // namespace net | 1349 } // namespace net |
OLD | NEW |