From: Moises Silva <moy@sangoma.com>
Date: Thu, 2 Sep 2010 16:38:43 +0000 (-0400)
Subject: freetdm: only notify interrupt waiters if there is not a notification already pending
X-Git-Tag: v1.2-rc1~382^2~4^2
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=cd0cc2e4a30398b3a2e1eb8f5e10c2df3e041fa0;p=thirdparty%2Ffreeswitch.git

freetdm: only notify interrupt waiters if there is not a notification already pending
---

diff --git a/libs/freetdm/src/ftdm_threadmutex.c b/libs/freetdm/src/ftdm_threadmutex.c
index 79bd28f7d9..56bd49ca18 100644
--- a/libs/freetdm/src/ftdm_threadmutex.c
+++ b/libs/freetdm/src/ftdm_threadmutex.c
@@ -376,9 +376,19 @@ FT_DECLARE(ftdm_status_t) ftdm_interrupt_signal(ftdm_interrupt_t *interrupt)
 	}
 #else
 	int err;
-	if ((err = write(interrupt->writefd, "w", 1)) != 1) {
-		ftdm_log(FTDM_LOG_ERROR, "Failed to signal interrupt: %s\n", errno, strerror(errno));
-		return FTDM_FAIL;
+	struct pollfd testpoll;
+	testpoll.revents = 0;
+	testpoll.events = POLLIN;
+	testpoll.fd = interrupt->readfd;
+	err = poll(&testpoll, 1, 0);
+	if (err == 0 && !(testpoll.revents & POLLIN)) {
+		/* we just try to notify if there is nothing on the read fd already, 
+		 * otherwise users that never call interrupt wait eventually will 
+		 * eventually have the pipe buffer filled */
+		if ((err = write(interrupt->writefd, "w", 1)) != 1) {
+			ftdm_log(FTDM_LOG_ERROR, "Failed to signal interrupt: %s\n", errno, strerror(errno));
+			return FTDM_FAIL;
+		}
 	}
 #endif
 	return FTDM_SUCCESS;