tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reuse pipe inode if it already exists. 

Fixes #3552
This commit is contained in:
Gunnar Beutner 2013-01-23 10:18:23 +01:00
parent 153ab33074
commit 65c0334b28
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
components/compat/compatcomponent.cpp
View File

@ -100,11 +100,20 @@ void CompatComponent::Stop(void)
#ifndef _WIN32 #ifndef _WIN32
void CompatComponent::CommandPipeThread(const String& commandPath) void CompatComponent::CommandPipeThread(const String& commandPath)
{ {
(void) unlink(commandPath.CStr()); struct stat statbuf;
bool fifo_ok = false;
int rc = mkfifo(commandPath.CStr(), S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP); if (lstat(commandPath.CStr(), &statbuf) >= 0) {
if (S_ISFIFO(statbuf.st_mode) && access(commandPath.CStr(), R_OK) >= 0) {
fifo_ok = true;
} else {
if (unlink(commandPath.CStr()) < 0)
throw_exception(PosixException("unlink() failed", errno));
}
}
if (rc < 0)
if (!fifo_ok && mkfifo(commandPath.CStr(), S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP) < 0)
throw_exception(PosixException("mkfifo() failed", errno)); throw_exception(PosixException("mkfifo() failed", errno));
for (;;) { for (;;) {