diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2010-01-15 17:03:51 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2010-01-15 17:03:51 +0100 |
| commit | 9901996b5ba444e58e168397f126c81e6a8ea673 (patch) | |
| tree | 3bba2b56577a9a9f149d797bf176d599fff12adb /runtime/stream.c | |
| parent | b7ea09361c7618b1a1c8a7f0b9d0b7f2b1414884 (diff) | |
| parent | 5b4e06fc28ef217e9ca26611e11afd974bdd1a4a (diff) | |
| download | rsyslog-9901996b5ba444e58e168397f126c81e6a8ea673.tar.gz rsyslog-9901996b5ba444e58e168397f126c81e6a8ea673.tar.xz rsyslog-9901996b5ba444e58e168397f126c81e6a8ea673.zip | |
Merge branch 'v4-beta' into beta
Conflicts:
ChangeLog
Diffstat (limited to 'runtime/stream.c')
| -rw-r--r-- | runtime/stream.c | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/runtime/stream.c b/runtime/stream.c index 3673db91..81f8e89b 100644 --- a/runtime/stream.c +++ b/runtime/stream.c @@ -209,13 +209,19 @@ doPhysOpen(strm_t *pThis) default:assert(0); break; } + if(pThis->sType == STREAMTYPE_NAMED_PIPE) { + DBGPRINTF("Note: stream '%s' is a named pipe, open with O_NONBLOCK\n", pThis->pszCurrFName); + iFlags |= O_NONBLOCK; + } pThis->fd = open((char*)pThis->pszCurrFName, iFlags, pThis->tOpenMode); DBGPRINTF("file '%s' opened as #%d with mode %d\n", pThis->pszCurrFName, pThis->fd, pThis->tOpenMode); if(pThis->fd == -1) { - int ierrnoSave = errno; - dbgoprint((obj_t*) pThis, "open error %d, file '%s'\n", errno, pThis->pszCurrFName); - if(ierrnoSave == ENOENT) + char errStr[1024]; + int err = errno; + rs_strerror_r(err, errStr, sizeof(errStr)); + dbgoprint((obj_t*) pThis, "open error %d, file '%s': %s\n", errno, pThis->pszCurrFName, errStr); + if(err == ENOENT) ABORT_FINALIZE(RS_RET_FILE_NOT_FOUND); else ABORT_FINALIZE(RS_RET_IO_ERROR); @@ -429,6 +435,7 @@ strmHandleEOF(strm_t *pThis) ISOBJ_TYPE_assert(pThis, strm); switch(pThis->sType) { case STREAMTYPE_FILE_SINGLE: + case STREAMTYPE_NAMED_PIPE: ABORT_FINALIZE(RS_RET_EOF); break; case STREAMTYPE_FILE_CIRCULAR: |