X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=libringbuffer%2Ffrontend_internal.h;h=c60affe07d94dd4e549af3c4abc1dbcfc6eb6c3e;hb=260cdac788ddd0ab0ff6f413bf9166a50df203b6;hp=73b44726df2fe9f1c4baaee731418e8fcead28f0;hpb=1d4981969313da002983ca979bd85c95493f7316;p=lttng-ust.git

diff --git a/libringbuffer/frontend_internal.h b/libringbuffer/frontend_internal.h
index 73b44726..c60affe0 100644
--- a/libringbuffer/frontend_internal.h
+++ b/libringbuffer/frontend_internal.h
@@ -378,8 +378,19 @@ void lib_ring_buffer_check_deliver(const struct lib_ring_buffer_config *config,
 			if (config->wakeup == RING_BUFFER_WAKEUP_BY_WRITER
 			    && uatomic_read(&buf->active_readers)
 			    && lib_ring_buffer_poll_deliver(config, buf, chan, handle)) {
-				//wake_up_interruptible(&buf->read_wait);
-				//wake_up_interruptible(&chan->read_wait);
+				int wakeup_fd = shm_get_wakeup_fd(handle, &buf->self._ref);
+
+				if (wakeup_fd >= 0) {
+					int ret;
+					/*
+					 * Wake-up the other end by
+					 * writing a null byte in the
+					 * pipe (non-blocking).
+					 */
+					do {
+						ret = write(wakeup_fd, "", 1);
+					} while (ret == -1L && errno == EINTR);
+				}
 			}
 
 		}