diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2025-01-19 13:36:24 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2025-01-19 13:36:24 +0000 |
commit | 2994dbfbd3587c4990b97979a8dec2c08c80c90a (patch) | |
tree | 6b32aeebabf2cd51abbea7e2f930d2a9bf1c3ff0 /dec_stdout.cc | |
parent | Adding upstream version 1.12~rc1. (diff) | |
download | plzip-2994dbfbd3587c4990b97979a8dec2c08c80c90a.tar.xz plzip-2994dbfbd3587c4990b97979a8dec2c08c80c90a.zip |
Adding upstream version 1.12.upstream/1.12upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'dec_stdout.cc')
-rw-r--r-- | dec_stdout.cc | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/dec_stdout.cc b/dec_stdout.cc index d32f7a8..569e21f 100644 --- a/dec_stdout.cc +++ b/dec_stdout.cc @@ -1,6 +1,6 @@ /* Plzip - Massively parallel implementation of lzip Copyright (C) 2009 Laszlo Ersek. - Copyright (C) 2009-2024 Antonio Diaz Diaz. + Copyright (C) 2009-2025 Antonio Diaz Diaz. This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -129,9 +129,8 @@ out: xunlock( &omutex ); do { while( opacket_queues[deliver_id].empty() && num_working > 0 ) { ++owait_counter; xwait( &oav_or_exit, &omutex ); } - while( true ) + while( !opacket_queues[deliver_id].empty() ) { - if( opacket_queues[deliver_id].empty() ) break; Packet opacket = opacket_queues[deliver_id].front(); opacket_queues[deliver_id].pop(); if( opacket_queues[deliver_id].size() + 1 == out_slots ) @@ -275,7 +274,7 @@ void muxer( Packet_courier & courier, const Pretty_print & pp, if( shared_retval() == 0 && writeblock( outfd, opacket.data, opacket.size ) != opacket.size && shared_retval.set_value( 1 ) ) - { pp(); show_error( write_error_msg, errno ); } + { pp(); show_error( wr_err_msg, errno ); } opacket.delete_data(); } } |