Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(193)

Side by Side Diff: net/spdy/spdy_websocket_test_util.cc

Issue 266243004: Clang format slam. Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698