| 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 |