173 if ( !
canRead() || maxSize < 0 )
176 if ( channel >= d->_readChannels.size() ) {
183 const auto maxBArrSize = int64_t( std::min(
ByteArray::maxSize(), std::size_t(std::numeric_limits<int64_t>::max()) ) );
184 if ( maxSize > maxBArrSize ) {
185 ERR <<
"Calling channelReadLine with maxSize > int64_t(ByteArray::maxSize) " << std::endl;
186 maxSize = maxBArrSize - 1;
190 int64_t readSoFar = 0;
194 if ( maxSize == 0 || maxSize >= (maxBArrSize - 1) ) {
197 maxSize = maxBArrSize;
200 int64_t lastReadSize = 0;
203 result.resize( std::min( std::size_t(maxSize), std::size_t(result.size() + d->_readBufChunkSize )) );
204 lastReadSize =
channelReadLine( channel, result.data() + readSoFar, result.size() - readSoFar );
205 if ( lastReadSize > 0)
206 readSoFar += lastReadSize;
211 }
while( lastReadSize == d->_readBufChunkSize
212 && result[readSoFar-1] !=
'\n' );
215 result.resize( maxSize );
219 if ( readSoFar > 0 ) {
221 result.resize( readSoFar );
227 result.shrink_to_fit();
236 if ( !
canRead() || maxSize < 0 )
239 if ( channel >= d->_readChannels.size() ) {
245 ERR <<
"channelReadLine needs at least a buffsize of 2" << std::endl;
249 int64_t toRead = maxSize - 1;
250 int64_t readSoFar = 0;
251 if ( d->_readChannels[channel].size () > 0 )
252 readSoFar = d->_readChannels[channel].readLine( buf, toRead + 1 );
254 if ( readSoFar == toRead || ( readSoFar > 0 && buf[readSoFar-1] ==
'\n' ) ) {
255 buf[readSoFar] =
'\0';
259 bool hasError =
false;
262 while ( readSoFar < toRead ) {
263 const auto r =
readData( channel, buf+readSoFar, 1 );
274 if ( buf[readSoFar-1] ==
'\n' )
278 if ( readSoFar == 0 )
279 return hasError ? -1 : 0;
281 buf[readSoFar] =
'\0';