@@ -158,25 +158,30 @@ class ForwardParser
158158 {
159159 static_assert (sizeof (InputType) == 1 ,
160160 " ForwardParser currently only supports byte type buffer" );
161- if (buffer == nullptr || bufferSize == 0 )
161+ if (buffer == nullptr || bufferSize == 0 ) {
162162 return 0 ;
163+ }
164+
163165 size_t position = 0 ;
164166 std::vector<FrameInfo> frames;
165167 do {
166168 FrameInfo entry;
167169
168170 // check the header
169- if (sizeof (HeaderType) + position > bufferSize)
171+ if (sizeof (HeaderType) + position > bufferSize) {
170172 break ;
173+ }
171174 entry.header = reinterpret_cast <const HeaderType*>(buffer + position);
172- if (!checkHeader (*entry.header ))
175+ if (!checkHeader (*entry.header )) {
173176 break ;
177+ }
174178
175179 // extract frame size from header, this is expected to be the
176180 // total frome size including header, payload and optional trailer
177181 auto frameSize = getFrameSize (*entry.header );
178- if (frameSize + position > bufferSize)
182+ if (frameSize + position > bufferSize) {
179183 break ;
184+ }
180185
181186 // payload starts right after the header
182187 entry.payload = reinterpret_cast <typename FrameInfo::PtrT>(entry.header + 1 );
@@ -188,8 +193,9 @@ class ForwardParser
188193 } else {
189194 auto trailerStart = buffer + position + frameSize - tailOffset;
190195 entry.trailer = reinterpret_cast <const TrailerType*>(trailerStart);
191- if (!CheckTrailer (entry, checkTrailer))
196+ if (!CheckTrailer (entry, checkTrailer)) {
192197 break ;
198+ }
193199 }
194200
195201 // store the extracted frame info and continue with remaining buffer
@@ -201,8 +207,9 @@ class ForwardParser
201207 // frames found and format consistent, insert entries to target
202208 // Note: the complete block must be consistent
203209 for (auto entry : frames) {
204- if (!insert (entry))
210+ if (!insert (entry)) {
205211 break ;
212+ }
206213 }
207214 return frames.size ();
208215 } else if (frames.size () == 0 ) {
@@ -332,30 +339,35 @@ class ReverseParser
332339 {
333340 static_assert (sizeof (InputType) == 1 ,
334341 " ReverseParser currently only supports byte type buffer" );
335- if (buffer == nullptr || bufferSize == 0 )
342+ if (buffer == nullptr || bufferSize == 0 ) {
336343 return 0 ;
344+ }
337345 auto position = bufferSize;
338346 std::vector<FrameInfo> frames;
339347 do {
340348 FrameInfo entry;
341349
342350 // start from end, extract and check trailer
343- if (sizeof (TrailerType) > position)
351+ if (sizeof (TrailerType) > position) {
344352 break ;
353+ }
345354 entry.trailer = reinterpret_cast <const TrailerType*>(buffer + position - sizeof (TrailerType));
346- if (!checkTrailer (*entry.trailer ))
355+ if (!checkTrailer (*entry.trailer )) {
347356 break ;
357+ }
348358
349359 // get the total frame size
350360 auto frameSize = getFrameSize (*entry.trailer );
351- if (frameSize > position)
361+ if (frameSize > position) {
352362 break ;
363+ }
353364
354365 // extract and check header
355366 auto headerStart = buffer + position - frameSize;
356367 entry.header = reinterpret_cast <const HeaderType*>(headerStart);
357- if (!checkHeader (*entry.header ))
368+ if (!checkHeader (*entry.header )) {
358369 break ;
370+ }
359371
360372 // payload immediately after header
361373 entry.payload = reinterpret_cast <typename FrameInfo::PtrT>(entry.header + 1 );
@@ -367,8 +379,9 @@ class ReverseParser
367379 if (position == 0 ) {
368380 // frames found and format consistent, the complete block must be consistent
369381 for (auto entry : frames) {
370- if (!insert (entry))
382+ if (!insert (entry)) {
371383 break ;
384+ }
372385 }
373386 return frames.size ();
374387 } else if (frames.size () == 0 ) {
0 commit comments