diff options
author | Dan Gohman <gohman@apple.com> | 2010-05-06 01:27:36 +0000 |
---|---|---|
committer | Dan Gohman <gohman@apple.com> | 2010-05-06 01:27:36 +0000 |
commit | 5fe89d0126ec215ac2a09884bfbd4dd7bf8e7d2f (patch) | |
tree | 8e5340dc0231a4202ac1f5dafa7ee76130436e22 /lib/Support | |
parent | 5758d4ce4603bd2c0b97c87e6e516bf2afd78a85 (diff) |
Handle EWOULDBLOCK as EAGAIN. And add a comment explaining why
EAGAIN and EWOULDBLOCK are used here.
Also, handle the case where a write call is interrupted after
some data has already been written.
git-svn-id: https://llvm.org/svn/llvm-project/llvm/trunk@103153 91177308-0d34-0410-b5e6-96231b3b80d8
Diffstat (limited to 'lib/Support')
-rw-r--r-- | lib/Support/raw_ostream.cpp | 25 |
1 files changed, 22 insertions, 3 deletions
diff --git a/lib/Support/raw_ostream.cpp b/lib/Support/raw_ostream.cpp index f8ac65d7e1..ad47cb6cf5 100644 --- a/lib/Support/raw_ostream.cpp +++ b/lib/Support/raw_ostream.cpp @@ -422,11 +422,30 @@ void raw_fd_ostream::write_impl(const char *Ptr, size_t Size) { assert(FD >= 0 && "File already closed."); pos += Size; ssize_t ret; + do { ret = ::write(FD, Ptr, Size); - } while (ret < 0 && (errno == EAGAIN || errno == EINTR)); - if (ret != (ssize_t) Size) - error_detected(); + + if (ret < 0) { + // If it's a recoverable error, swallow it and retry the write. + // EAGAIN and EWOULDBLOCK are not unambiguously recoverable, but + // some programs, such as bjam, assume that their child processes + // will treat them as if they are. If you don't want this code to + // spin, don't use O_NONBLOCK file descriptors with raw_ostream. + if (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK) + continue; + + // Otherwise it's a non-recoverable error. Note it and quit. + error_detected(); + break; + } + + // The write may have written some or all of the data. Update the + // size and buffer pointer to reflect the remainder that needs + // to be written. If there are no bytes left, we're done. + Ptr += ret; + Size -= ret; + } while (Size > 0); } void raw_fd_ostream::close() { |