1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4 
5 #include "quiche/http2/test_tools/frame_parts_collector_listener.h"
6 
7 #include "quiche/common/platform/api/quiche_logging.h"
8 #include "quiche/common/platform/api/quiche_test.h"
9 
10 namespace http2 {
11 namespace test {
12 
OnFrameHeader(const Http2FrameHeader & header)13 bool FramePartsCollectorListener::OnFrameHeader(
14     const Http2FrameHeader& header) {
15   QUICHE_VLOG(1) << "OnFrameHeader: " << header;
16   ExpectFrameHeader(header);
17   return true;
18 }
19 
OnDataStart(const Http2FrameHeader & header)20 void FramePartsCollectorListener::OnDataStart(const Http2FrameHeader& header) {
21   QUICHE_VLOG(1) << "OnDataStart: " << header;
22   StartFrame(header)->OnDataStart(header);
23 }
24 
OnDataPayload(const char * data,size_t len)25 void FramePartsCollectorListener::OnDataPayload(const char* data, size_t len) {
26   QUICHE_VLOG(1) << "OnDataPayload: len=" << len;
27   CurrentFrame()->OnDataPayload(data, len);
28 }
29 
OnDataEnd()30 void FramePartsCollectorListener::OnDataEnd() {
31   QUICHE_VLOG(1) << "OnDataEnd";
32   EndFrame()->OnDataEnd();
33 }
34 
OnHeadersStart(const Http2FrameHeader & header)35 void FramePartsCollectorListener::OnHeadersStart(
36     const Http2FrameHeader& header) {
37   QUICHE_VLOG(1) << "OnHeadersStart: " << header;
38   StartFrame(header)->OnHeadersStart(header);
39 }
40 
OnHeadersPriority(const Http2PriorityFields & priority)41 void FramePartsCollectorListener::OnHeadersPriority(
42     const Http2PriorityFields& priority) {
43   QUICHE_VLOG(1) << "OnHeadersPriority: " << priority;
44   CurrentFrame()->OnHeadersPriority(priority);
45 }
46 
OnHpackFragment(const char * data,size_t len)47 void FramePartsCollectorListener::OnHpackFragment(const char* data,
48                                                   size_t len) {
49   QUICHE_VLOG(1) << "OnHpackFragment: len=" << len;
50   CurrentFrame()->OnHpackFragment(data, len);
51 }
52 
OnHeadersEnd()53 void FramePartsCollectorListener::OnHeadersEnd() {
54   QUICHE_VLOG(1) << "OnHeadersEnd";
55   EndFrame()->OnHeadersEnd();
56 }
57 
OnPriorityFrame(const Http2FrameHeader & header,const Http2PriorityFields & priority_fields)58 void FramePartsCollectorListener::OnPriorityFrame(
59     const Http2FrameHeader& header,
60     const Http2PriorityFields& priority_fields) {
61   QUICHE_VLOG(1) << "OnPriority: " << header << "; " << priority_fields;
62   StartAndEndFrame(header)->OnPriorityFrame(header, priority_fields);
63 }
64 
OnContinuationStart(const Http2FrameHeader & header)65 void FramePartsCollectorListener::OnContinuationStart(
66     const Http2FrameHeader& header) {
67   QUICHE_VLOG(1) << "OnContinuationStart: " << header;
68   StartFrame(header)->OnContinuationStart(header);
69 }
70 
OnContinuationEnd()71 void FramePartsCollectorListener::OnContinuationEnd() {
72   QUICHE_VLOG(1) << "OnContinuationEnd";
73   EndFrame()->OnContinuationEnd();
74 }
75 
OnPadLength(size_t pad_length)76 void FramePartsCollectorListener::OnPadLength(size_t pad_length) {
77   QUICHE_VLOG(1) << "OnPadLength: " << pad_length;
78   CurrentFrame()->OnPadLength(pad_length);
79 }
80 
OnPadding(const char * padding,size_t skipped_length)81 void FramePartsCollectorListener::OnPadding(const char* padding,
82                                             size_t skipped_length) {
83   QUICHE_VLOG(1) << "OnPadding: " << skipped_length;
84   CurrentFrame()->OnPadding(padding, skipped_length);
85 }
86 
OnRstStream(const Http2FrameHeader & header,Http2ErrorCode error_code)87 void FramePartsCollectorListener::OnRstStream(const Http2FrameHeader& header,
88                                               Http2ErrorCode error_code) {
89   QUICHE_VLOG(1) << "OnRstStream: " << header << "; error_code=" << error_code;
90   StartAndEndFrame(header)->OnRstStream(header, error_code);
91 }
92 
OnSettingsStart(const Http2FrameHeader & header)93 void FramePartsCollectorListener::OnSettingsStart(
94     const Http2FrameHeader& header) {
95   QUICHE_VLOG(1) << "OnSettingsStart: " << header;
96   EXPECT_EQ(Http2FrameType::SETTINGS, header.type) << header;
97   EXPECT_EQ(Http2FrameFlag(), header.flags) << header;
98   StartFrame(header)->OnSettingsStart(header);
99 }
100 
OnSetting(const Http2SettingFields & setting_fields)101 void FramePartsCollectorListener::OnSetting(
102     const Http2SettingFields& setting_fields) {
103   QUICHE_VLOG(1) << "Http2SettingFields: setting_fields=" << setting_fields;
104   CurrentFrame()->OnSetting(setting_fields);
105 }
106 
OnSettingsEnd()107 void FramePartsCollectorListener::OnSettingsEnd() {
108   QUICHE_VLOG(1) << "OnSettingsEnd";
109   EndFrame()->OnSettingsEnd();
110 }
111 
OnSettingsAck(const Http2FrameHeader & header)112 void FramePartsCollectorListener::OnSettingsAck(
113     const Http2FrameHeader& header) {
114   QUICHE_VLOG(1) << "OnSettingsAck: " << header;
115   StartAndEndFrame(header)->OnSettingsAck(header);
116 }
117 
OnPushPromiseStart(const Http2FrameHeader & header,const Http2PushPromiseFields & promise,size_t total_padding_length)118 void FramePartsCollectorListener::OnPushPromiseStart(
119     const Http2FrameHeader& header, const Http2PushPromiseFields& promise,
120     size_t total_padding_length) {
121   QUICHE_VLOG(1) << "OnPushPromiseStart header: " << header
122                  << "  promise: " << promise
123                  << "  total_padding_length: " << total_padding_length;
124   EXPECT_EQ(Http2FrameType::PUSH_PROMISE, header.type);
125   StartFrame(header)->OnPushPromiseStart(header, promise, total_padding_length);
126 }
127 
OnPushPromiseEnd()128 void FramePartsCollectorListener::OnPushPromiseEnd() {
129   QUICHE_VLOG(1) << "OnPushPromiseEnd";
130   EndFrame()->OnPushPromiseEnd();
131 }
132 
OnPing(const Http2FrameHeader & header,const Http2PingFields & ping)133 void FramePartsCollectorListener::OnPing(const Http2FrameHeader& header,
134                                          const Http2PingFields& ping) {
135   QUICHE_VLOG(1) << "OnPing: " << header << "; " << ping;
136   StartAndEndFrame(header)->OnPing(header, ping);
137 }
138 
OnPingAck(const Http2FrameHeader & header,const Http2PingFields & ping)139 void FramePartsCollectorListener::OnPingAck(const Http2FrameHeader& header,
140                                             const Http2PingFields& ping) {
141   QUICHE_VLOG(1) << "OnPingAck: " << header << "; " << ping;
142   StartAndEndFrame(header)->OnPingAck(header, ping);
143 }
144 
OnGoAwayStart(const Http2FrameHeader & header,const Http2GoAwayFields & goaway)145 void FramePartsCollectorListener::OnGoAwayStart(
146     const Http2FrameHeader& header, const Http2GoAwayFields& goaway) {
147   QUICHE_VLOG(1) << "OnGoAwayStart header: " << header
148                  << "; goaway: " << goaway;
149   StartFrame(header)->OnGoAwayStart(header, goaway);
150 }
151 
OnGoAwayOpaqueData(const char * data,size_t len)152 void FramePartsCollectorListener::OnGoAwayOpaqueData(const char* data,
153                                                      size_t len) {
154   QUICHE_VLOG(1) << "OnGoAwayOpaqueData: len=" << len;
155   CurrentFrame()->OnGoAwayOpaqueData(data, len);
156 }
157 
OnGoAwayEnd()158 void FramePartsCollectorListener::OnGoAwayEnd() {
159   QUICHE_VLOG(1) << "OnGoAwayEnd";
160   EndFrame()->OnGoAwayEnd();
161 }
162 
OnWindowUpdate(const Http2FrameHeader & header,uint32_t window_size_increment)163 void FramePartsCollectorListener::OnWindowUpdate(
164     const Http2FrameHeader& header, uint32_t window_size_increment) {
165   QUICHE_VLOG(1) << "OnWindowUpdate: " << header
166                  << "; window_size_increment=" << window_size_increment;
167   EXPECT_EQ(Http2FrameType::WINDOW_UPDATE, header.type);
168   StartAndEndFrame(header)->OnWindowUpdate(header, window_size_increment);
169 }
170 
OnAltSvcStart(const Http2FrameHeader & header,size_t origin_length,size_t value_length)171 void FramePartsCollectorListener::OnAltSvcStart(const Http2FrameHeader& header,
172                                                 size_t origin_length,
173                                                 size_t value_length) {
174   QUICHE_VLOG(1) << "OnAltSvcStart header: " << header
175                  << "; origin_length=" << origin_length
176                  << "; value_length=" << value_length;
177   StartFrame(header)->OnAltSvcStart(header, origin_length, value_length);
178 }
179 
OnAltSvcOriginData(const char * data,size_t len)180 void FramePartsCollectorListener::OnAltSvcOriginData(const char* data,
181                                                      size_t len) {
182   QUICHE_VLOG(1) << "OnAltSvcOriginData: len=" << len;
183   CurrentFrame()->OnAltSvcOriginData(data, len);
184 }
185 
OnAltSvcValueData(const char * data,size_t len)186 void FramePartsCollectorListener::OnAltSvcValueData(const char* data,
187                                                     size_t len) {
188   QUICHE_VLOG(1) << "OnAltSvcValueData: len=" << len;
189   CurrentFrame()->OnAltSvcValueData(data, len);
190 }
191 
OnAltSvcEnd()192 void FramePartsCollectorListener::OnAltSvcEnd() {
193   QUICHE_VLOG(1) << "OnAltSvcEnd";
194   EndFrame()->OnAltSvcEnd();
195 }
196 
OnPriorityUpdateStart(const Http2FrameHeader & header,const Http2PriorityUpdateFields & priority_update)197 void FramePartsCollectorListener::OnPriorityUpdateStart(
198     const Http2FrameHeader& header,
199     const Http2PriorityUpdateFields& priority_update) {
200   QUICHE_VLOG(1) << "OnPriorityUpdateStart header: " << header
201                  << "; priority_update=" << priority_update;
202   StartFrame(header)->OnPriorityUpdateStart(header, priority_update);
203 }
204 
OnPriorityUpdatePayload(const char * data,size_t len)205 void FramePartsCollectorListener::OnPriorityUpdatePayload(const char* data,
206                                                           size_t len) {
207   QUICHE_VLOG(1) << "OnPriorityUpdatePayload: len=" << len;
208   CurrentFrame()->OnPriorityUpdatePayload(data, len);
209 }
210 
OnPriorityUpdateEnd()211 void FramePartsCollectorListener::OnPriorityUpdateEnd() {
212   QUICHE_VLOG(1) << "OnPriorityUpdateEnd";
213   EndFrame()->OnPriorityUpdateEnd();
214 }
215 
OnUnknownStart(const Http2FrameHeader & header)216 void FramePartsCollectorListener::OnUnknownStart(
217     const Http2FrameHeader& header) {
218   QUICHE_VLOG(1) << "OnUnknownStart: " << header;
219   StartFrame(header)->OnUnknownStart(header);
220 }
221 
OnUnknownPayload(const char * data,size_t len)222 void FramePartsCollectorListener::OnUnknownPayload(const char* data,
223                                                    size_t len) {
224   QUICHE_VLOG(1) << "OnUnknownPayload: len=" << len;
225   CurrentFrame()->OnUnknownPayload(data, len);
226 }
227 
OnUnknownEnd()228 void FramePartsCollectorListener::OnUnknownEnd() {
229   QUICHE_VLOG(1) << "OnUnknownEnd";
230   EndFrame()->OnUnknownEnd();
231 }
232 
OnPaddingTooLong(const Http2FrameHeader & header,size_t missing_length)233 void FramePartsCollectorListener::OnPaddingTooLong(
234     const Http2FrameHeader& header, size_t missing_length) {
235   QUICHE_VLOG(1) << "OnPaddingTooLong: " << header
236                  << "    missing_length: " << missing_length;
237   EndFrame()->OnPaddingTooLong(header, missing_length);
238 }
239 
OnFrameSizeError(const Http2FrameHeader & header)240 void FramePartsCollectorListener::OnFrameSizeError(
241     const Http2FrameHeader& header) {
242   QUICHE_VLOG(1) << "OnFrameSizeError: " << header;
243   FrameError(header)->OnFrameSizeError(header);
244 }
245 
246 }  // namespace test
247 }  // namespace http2
248