1 files changed, 9 insertions, 15 deletions

diff --git a/src/charon/plugins/stroke/stroke_socket.c b/src/charon/plugins/stroke/stroke_socket.c
index abc14794a..f889f9a8c 100644
--- a/src/charon/plugins/stroke/stroke_socket.c
+++ b/src/charon/plugins/stroke/stroke_socket.c
@@ -370,7 +370,10 @@ static void stroke_config(private_stroke_socket_t *this, stroke_msg_t *msg, FILE
  */
 static void stroke_job_context_destroy(stroke_job_context_t *this)
 {
-	close(this->fd);
+	if (this->fd)
+	{
+		close(this->fd);
+	}
 	free(this);
 }
 
@@ -392,17 +395,15 @@ static job_requeue_t process(stroke_job_context_t *ctx)
 	{
 		DBG1(DBG_CFG, "reading length of stroke message failed: %s",
 			 strerror(errno));
-		close(strokefd);
 		return JOB_REQUEUE_NONE;
 	}
 	
 	/* read message */
-	msg = malloc(msg_length);
+	msg = alloca(msg_length);
 	bytes_read = recv(strokefd, msg, msg_length, 0);
 	if (bytes_read != msg_length)
 	{
 		DBG1(DBG_CFG, "reading stroke message failed: %s", strerror(errno));
-		close(strokefd);
 		return JOB_REQUEUE_NONE;
 	}
 	
@@ -410,18 +411,11 @@ static job_requeue_t process(stroke_job_context_t *ctx)
 	if (out == NULL)
 	{
 		DBG1(DBG_CFG, "opening stroke output channel failed: %s", strerror(errno));
-		close(strokefd);
-		free(msg);
 		return JOB_REQUEUE_NONE;
 	}
 	
 	DBG3(DBG_CFG, "stroke message %b", (void*)msg, msg_length);
 	
-	/* the stroke_* functions are blocking, as they listen on the bus. Add
-	 * cancellation handlers. */
-	pthread_cleanup_push((void*)fclose, out);
-	pthread_cleanup_push(free, msg);
-	
 	switch (msg->type)
 	{
 		case STR_INITIATE:
@@ -471,11 +465,11 @@ static job_requeue_t process(stroke_job_context_t *ctx)
 			break;
 		default:
 			DBG1(DBG_CFG, "received unknown stroke");
+			break;
 	}
-	/* remove and execute cancellation handlers */
-	pthread_cleanup_pop(1);
-	pthread_cleanup_pop(1);
-	
+	fclose(out);
+	/* fclose() closes underlying FD */
+	ctx->fd = 0;
 	return JOB_REQUEUE_NONE;
 }