@@ -97,12 +97,12 @@ namespace {
9797 const ssize_t bytes_written = write (mWpipe , data, to_write);
9898 if (bytes_written <= 0 ) {
9999 const int err = errno;
100- std::cerr << " #### ThreadExecutor::writeToPipeInternal() error for type " << type << " : " << std::strerror (err) << std::endl ;
100+ std::cerr << " #### ThreadExecutor::writeToPipeInternal() error for type " << type << " : " << std::strerror (err) << ' \n ' ;
101101 std::exit (EXIT_FAILURE);
102102 }
103103 // TODO: write until everything is written
104104 if (bytes_written != to_write) {
105- std::cerr << " #### ThreadExecutor::writeToPipeInternal() error for type " << type << " : insufficient data written (expected: " << to_write << " / got: " << bytes_written << " )" << std::endl ;
105+ std::cerr << " #### ThreadExecutor::writeToPipeInternal() error for type " << type << " : insufficient data written (expected: " << to_write << " / got: " << bytes_written << " )" << ' \n ' ;
106106 std::exit (EXIT_FAILURE);
107107 }
108108 }
@@ -146,12 +146,12 @@ bool ProcessExecutor::handleRead(int rpipe, unsigned int &result, const std::str
146146 return false ;
147147 }
148148 if (bytes_read != bytes_to_read) {
149- std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (type): insufficient data read (expected: " << bytes_to_read << " / got: " << bytes_read << " )" << std::endl ;
149+ std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (type): insufficient data read (expected: " << bytes_to_read << " / got: " << bytes_read << " )" << ' \n ' ;
150150 std::exit (EXIT_FAILURE);
151151 }
152152
153153 if (type != PipeWriter::REPORT_OUT && type != PipeWriter::REPORT_ERROR && type != PipeWriter::CHILD_END) {
154- std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) invalid type " << int (type) << std::endl ;
154+ std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) invalid type " << int (type) << ' \n ' ;
155155 std::exit (EXIT_FAILURE);
156156 }
157157
@@ -160,11 +160,11 @@ bool ProcessExecutor::handleRead(int rpipe, unsigned int &result, const std::str
160160 bytes_read = read (rpipe, &len, bytes_to_read);
161161 if (bytes_read <= 0 ) {
162162 const int err = errno;
163- std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (len) for type " << int (type) << " : " << std::strerror (err) << std::endl ;
163+ std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (len) for type " << int (type) << " : " << std::strerror (err) << ' \n ' ;
164164 std::exit (EXIT_FAILURE);
165165 }
166166 if (bytes_read != bytes_to_read) {
167- std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (len) for type" << int (type) << " : insufficient data read (expected: " << bytes_to_read << " / got: " << bytes_read << " )" << std::endl ;
167+ std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (len) for type" << int (type) << " : insufficient data read (expected: " << bytes_to_read << " / got: " << bytes_read << " )" << ' \n ' ;
168168 std::exit (EXIT_FAILURE);
169169 }
170170
@@ -175,7 +175,7 @@ bool ProcessExecutor::handleRead(int rpipe, unsigned int &result, const std::str
175175 bytes_read = read (rpipe, data_start, bytes_to_read);
176176 if (bytes_read <= 0 ) {
177177 const int err = errno;
178- std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (buf) for type" << int (type) << " : " << std::strerror (err) << std::endl ;
178+ std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) error (buf) for type" << int (type) << " : " << std::strerror (err) << ' \n ' ;
179179 std::exit (EXIT_FAILURE);
180180 }
181181 bytes_to_read -= bytes_read;
@@ -193,7 +193,7 @@ bool ProcessExecutor::handleRead(int rpipe, unsigned int &result, const std::str
193193 try {
194194 msg.deserialize (buf);
195195 } catch (const InternalError& e) {
196- std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) internal error: " << e.errorMessage << std::endl ;
196+ std::cerr << " #### ThreadExecutor::handleRead(" << filename << " ) internal error: " << e.errorMessage << ' \n ' ;
197197 std::exit (EXIT_FAILURE);
198198 }
199199
@@ -250,25 +250,25 @@ unsigned int ProcessExecutor::check()
250250 if ((iFile != mFiles .cend () || iFileSettings != mFileSettings .cend ()) && nchildren < mSettings .jobs && checkLoadAverage (nchildren)) {
251251 int pipes[2 ];
252252 if (pipe (pipes) == -1 ) {
253- std::cerr << " #### ThreadExecutor::check, pipe() failed: " << std::strerror (errno) << std::endl ;
253+ std::cerr << " #### ThreadExecutor::check, pipe() failed: " << std::strerror (errno) << ' \n ' ;
254254 std::exit (EXIT_FAILURE);
255255 }
256256
257257 const int flags = fcntl (pipes[0 ], F_GETFL, 0 );
258258 if (flags < 0 ) {
259- std::cerr << " #### ThreadExecutor::check, fcntl(F_GETFL) failed: " << std::strerror (errno) << std::endl ;
259+ std::cerr << " #### ThreadExecutor::check, fcntl(F_GETFL) failed: " << std::strerror (errno) << ' \n ' ;
260260 std::exit (EXIT_FAILURE);
261261 }
262262
263263 if (fcntl (pipes[0 ], F_SETFL, flags) < 0 ) {
264- std::cerr << " #### ThreadExecutor::check, fcntl(F_SETFL) failed: " << std::strerror (errno) << std::endl ;
264+ std::cerr << " #### ThreadExecutor::check, fcntl(F_SETFL) failed: " << std::strerror (errno) << ' \n ' ;
265265 std::exit (EXIT_FAILURE);
266266 }
267267
268268 const pid_t pid = fork ();
269269 if (pid < 0 ) {
270270 // Error
271- std::cerr << " #### ThreadExecutor::check, Failed to create child process: " << std::strerror (errno) << std::endl ;
271+ std::cerr << " #### ThreadExecutor::check, Failed to create child process: " << std::strerror (errno) << ' \n ' ;
272272 std::exit (EXIT_FAILURE);
273273 } else if (pid == 0 ) {
274274#if defined(__linux__)
0 commit comments