From: Alexander A. Klimov Date: Wed, 20 Jun 2018 15:28:52 +0000 (+0200) Subject: Stream#ReadLine(): simplify algorithm X-Git-Tag: v2.9.0~22^2 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=1c213877a4554bbe3632eada2a6fd4a99f8b90de;p=icinga2 Stream#ReadLine(): simplify algorithm refs #6354 --- diff --git a/lib/base/stream.cpp b/lib/base/stream.cpp index a7ac2067c..0b847060f 100644 --- a/lib/base/stream.cpp +++ b/lib/base/stream.cpp @@ -129,40 +129,19 @@ StreamReadStatus Stream::ReadLine(String *line, StreamReadContext& context, bool } } - int count = 0; - size_t first_newline; - for (size_t i = 0; i < context.Size; i++) { if (context.Buffer[i] == '\n') { - count++; - - if (count == 1) - first_newline = i; - else if (count > 1) - break; - } - } - - switch (count) { - case 0: - context.MustRead = true; - break; - case 1: - context.MustRead = first_newline == (context.Size - 1u); - break; - default: - context.MustRead = false; - } - - if (count > 0) { - *line = String(context.Buffer, &(context.Buffer[first_newline])); - boost::algorithm::trim_right(*line); + *line = String(context.Buffer, context.Buffer + i); + boost::algorithm::trim_right(*line); - context.DropData(first_newline + 1); + context.DropData(i + 1u); - return StatusNewItem; + context.MustRead = !context.Size; + return StatusNewItem; + } } + context.MustRead = true; return StatusNeedData; }