OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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/spdy/spdy_websocket_test_util.h" | 5 #include "net/spdy/spdy_websocket_test_util.h" |
6 | 6 |
7 #include "net/spdy/buffered_spdy_framer.h" | 7 #include "net/spdy/buffered_spdy_framer.h" |
8 #include "net/spdy/spdy_http_utils.h" | 8 #include "net/spdy/spdy_http_utils.h" |
9 | 9 |
10 namespace net { | 10 namespace net { |
11 | 11 |
12 const int kDefaultAssociatedStreamId = 0; | 12 const int kDefaultAssociatedStreamId = 0; |
13 const bool kDefaultCompressed = false; | 13 const bool kDefaultCompressed = false; |
14 const char* const kDefaultDataPointer = NULL; | 14 const char* const kDefaultDataPointer = NULL; |
15 const uint32 kDefaultDataLength = 0; | 15 const uint32 kDefaultDataLength = 0; |
16 | 16 |
17 SpdyWebSocketTestUtil::SpdyWebSocketTestUtil( | 17 SpdyWebSocketTestUtil::SpdyWebSocketTestUtil(NextProto protocol) |
18 NextProto protocol) : spdy_util_(protocol) {} | 18 : spdy_util_(protocol) { |
| 19 } |
19 | 20 |
20 std::string SpdyWebSocketTestUtil::GetHeader(const SpdyHeaderBlock& headers, | 21 std::string SpdyWebSocketTestUtil::GetHeader(const SpdyHeaderBlock& headers, |
21 const std::string& key) const { | 22 const std::string& key) const { |
22 SpdyHeaderBlock::const_iterator it = headers.find(GetHeaderKey(key)); | 23 SpdyHeaderBlock::const_iterator it = headers.find(GetHeaderKey(key)); |
23 return (it == headers.end()) ? "" : it->second; | 24 return (it == headers.end()) ? "" : it->second; |
24 } | 25 } |
25 | 26 |
26 void SpdyWebSocketTestUtil::SetHeader( | 27 void SpdyWebSocketTestUtil::SetHeader(const std::string& key, |
27 const std::string& key, | 28 const std::string& value, |
28 const std::string& value, | 29 SpdyHeaderBlock* headers) const { |
29 SpdyHeaderBlock* headers) const { | |
30 (*headers)[GetHeaderKey(key)] = value; | 30 (*headers)[GetHeaderKey(key)] = value; |
31 } | 31 } |
32 | 32 |
33 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketSynStream( | 33 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketSynStream( |
34 int stream_id, | 34 int stream_id, |
35 const char* path, | 35 const char* path, |
36 const char* host, | 36 const char* host, |
37 const char* origin) { | 37 const char* origin) { |
38 scoped_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock()); | 38 scoped_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock()); |
39 SetHeader("path", path, headers.get()); | 39 SetHeader("path", path, headers.get()); |
(...skipping 22 matching lines...) Expand all Loading... |
62 CONTROL_FLAG_NONE, | 62 CONTROL_FLAG_NONE, |
63 0); | 63 0); |
64 } | 64 } |
65 | 65 |
66 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketHandshakeRequestFrame( | 66 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketHandshakeRequestFrame( |
67 scoped_ptr<SpdyHeaderBlock> headers, | 67 scoped_ptr<SpdyHeaderBlock> headers, |
68 SpdyStreamId stream_id, | 68 SpdyStreamId stream_id, |
69 RequestPriority request_priority) { | 69 RequestPriority request_priority) { |
70 // SPDY SYN_STREAM control frame header. | 70 // SPDY SYN_STREAM control frame header. |
71 const SpdyHeaderInfo kSynStreamHeader = { | 71 const SpdyHeaderInfo kSynStreamHeader = { |
72 SYN_STREAM, | 72 SYN_STREAM, |
73 stream_id, | 73 stream_id, |
74 kDefaultAssociatedStreamId, | 74 kDefaultAssociatedStreamId, |
75 ConvertRequestPriorityToSpdyPriority(request_priority, SPDY2), | 75 ConvertRequestPriorityToSpdyPriority(request_priority, SPDY2), |
76 kSpdyCredentialSlotUnused, | 76 kSpdyCredentialSlotUnused, |
77 CONTROL_FLAG_NONE, | 77 CONTROL_FLAG_NONE, |
78 kDefaultCompressed, | 78 kDefaultCompressed, |
79 RST_STREAM_INVALID, | 79 RST_STREAM_INVALID, |
80 kDefaultDataPointer, | 80 kDefaultDataPointer, |
81 kDefaultDataLength, | 81 kDefaultDataLength, |
82 DATA_FLAG_NONE | 82 DATA_FLAG_NONE}; |
83 }; | |
84 | 83 |
85 // Construct SPDY SYN_STREAM control frame. | 84 // Construct SPDY SYN_STREAM control frame. |
86 return spdy_util_.ConstructSpdyFrame( | 85 return spdy_util_.ConstructSpdyFrame(kSynStreamHeader, headers.Pass()); |
87 kSynStreamHeader, | |
88 headers.Pass()); | |
89 } | 86 } |
90 | 87 |
91 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketHandshakeResponseFrame( | 88 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketHandshakeResponseFrame( |
92 scoped_ptr<SpdyHeaderBlock> headers, | 89 scoped_ptr<SpdyHeaderBlock> headers, |
93 SpdyStreamId stream_id, | 90 SpdyStreamId stream_id, |
94 RequestPriority request_priority) { | 91 RequestPriority request_priority) { |
95 // SPDY SYN_REPLY control frame header. | 92 // SPDY SYN_REPLY control frame header. |
96 const SpdyHeaderInfo kSynReplyHeader = { | 93 const SpdyHeaderInfo kSynReplyHeader = { |
97 SYN_REPLY, | 94 SYN_REPLY, |
98 stream_id, | 95 stream_id, |
99 kDefaultAssociatedStreamId, | 96 kDefaultAssociatedStreamId, |
100 ConvertRequestPriorityToSpdyPriority(request_priority, SPDY2), | 97 ConvertRequestPriorityToSpdyPriority(request_priority, SPDY2), |
101 kSpdyCredentialSlotUnused, | 98 kSpdyCredentialSlotUnused, |
102 CONTROL_FLAG_NONE, | 99 CONTROL_FLAG_NONE, |
103 kDefaultCompressed, | 100 kDefaultCompressed, |
104 RST_STREAM_INVALID, | 101 RST_STREAM_INVALID, |
105 kDefaultDataPointer, | 102 kDefaultDataPointer, |
106 kDefaultDataLength, | 103 kDefaultDataLength, |
107 DATA_FLAG_NONE | 104 DATA_FLAG_NONE}; |
108 }; | |
109 | 105 |
110 // Construct SPDY SYN_REPLY control frame. | 106 // Construct SPDY SYN_REPLY control frame. |
111 return spdy_util_.ConstructSpdyFrame( | 107 return spdy_util_.ConstructSpdyFrame(kSynReplyHeader, headers.Pass()); |
112 kSynReplyHeader, | |
113 headers.Pass()); | |
114 } | 108 } |
115 | 109 |
116 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketHeadersFrame( | 110 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketHeadersFrame( |
117 int stream_id, | 111 int stream_id, |
118 const char* length, | 112 const char* length, |
119 bool fin) { | 113 bool fin) { |
120 scoped_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock()); | 114 scoped_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock()); |
121 SetHeader("opcode", "1", headers.get()); // text frame | 115 SetHeader("opcode", "1", headers.get()); // text frame |
122 SetHeader("length", length, headers.get()); | 116 SetHeader("length", length, headers.get()); |
123 SetHeader("fin", fin ? "1" : "0", headers.get()); | 117 SetHeader("fin", fin ? "1" : "0", headers.get()); |
124 return spdy_util_.ConstructSpdyControlFrame(headers.Pass(), | 118 return spdy_util_.ConstructSpdyControlFrame(headers.Pass(), |
125 /*compression*/ false, | 119 /*compression*/ false, |
126 stream_id, | 120 stream_id, |
127 LOWEST, | 121 LOWEST, |
128 HEADERS, | 122 HEADERS, |
129 CONTROL_FLAG_NONE, | 123 CONTROL_FLAG_NONE, |
130 0); | 124 0); |
131 } | 125 } |
132 | 126 |
133 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketDataFrame( | 127 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdyWebSocketDataFrame( |
134 const char* data, | 128 const char* data, |
135 int len, | 129 int len, |
136 SpdyStreamId stream_id, | 130 SpdyStreamId stream_id, |
137 bool fin) { | 131 bool fin) { |
138 | |
139 // Construct SPDY data frame. | 132 // Construct SPDY data frame. |
140 BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); | 133 BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); |
141 return framer.CreateDataFrame( | 134 return framer.CreateDataFrame( |
142 stream_id, | 135 stream_id, data, len, fin ? DATA_FLAG_FIN : DATA_FLAG_NONE); |
143 data, | |
144 len, | |
145 fin ? DATA_FLAG_FIN : DATA_FLAG_NONE); | |
146 } | 136 } |
147 | 137 |
148 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdySettings( | 138 SpdyFrame* SpdyWebSocketTestUtil::ConstructSpdySettings( |
149 const SettingsMap& settings) const { | 139 const SettingsMap& settings) const { |
150 return spdy_util_.ConstructSpdySettings(settings); | 140 return spdy_util_.ConstructSpdySettings(settings); |
151 } | 141 } |
152 | 142 |
153 SpdyMajorVersion SpdyWebSocketTestUtil::spdy_version() const { | 143 SpdyMajorVersion SpdyWebSocketTestUtil::spdy_version() const { |
154 return spdy_util_.spdy_version(); | 144 return spdy_util_.spdy_version(); |
155 } | 145 } |
156 | 146 |
157 std::string SpdyWebSocketTestUtil::GetHeaderKey( | 147 std::string SpdyWebSocketTestUtil::GetHeaderKey(const std::string& key) const { |
158 const std::string& key) const { | |
159 return (spdy_util_.is_spdy2() ? "" : ":") + key; | 148 return (spdy_util_.is_spdy2() ? "" : ":") + key; |
160 } | 149 } |
161 | 150 |
162 } // namespace net | 151 } // namespace net |
OLD | NEW |