From 5320830b137d580aa47d55a85f1da38c23e0ac34 Mon Sep 17 00:00:00 2001
From: Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
Date: Mon, 11 Jul 2016 16:02:32 +0200
Subject: [PATCH] added pthread cancelation points to pipe

---
 src/pipe.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/pipe.c b/src/pipe.c
index aa6eabdd0..61a902b09 100644
--- a/src/pipe.c
+++ b/src/pipe.c
@@ -119,6 +119,7 @@ retry:			reason = sample_fscan(stdin, s, NULL);
 		}
 
 		node_write(node, smps, node->vectorize);
+		pthread_testcancel();
 	}
 
 killme: pthread_kill(ptid, SIGINT);
@@ -157,6 +158,7 @@ static void * recv_loop(void *ctx)
 			sample_fprint(stdout, s, SAMPLE_ALL);
 			fflush(stdout);
 		}
+		pthread_testcancel();
 	}
 	
 	return NULL;