Check fo rinterrupts in raftable

knizhnik · kelvich · commit 60fa4a084fa6 · 2017-11-13T00:17:14.000+03:00
diff --git a/Dockerfile b/Dockerfile
@@ -31,7 +31,7 @@ USER postgres
 ENV CFLAGS -O0
 WORKDIR /pg
 
-ENV REBUILD 9
+ENV REBUILD 10
 
 RUN cd /pg && \
 	git clone https://github.com/postgrespro/postgres_cluster.git --depth 1 && \
diff --git a/arbiter.c b/arbiter.c
@@ -710,7 +710,9 @@ static void MtmTransSender(Datum arg)
 				txBuffer[i].used = 0;
 			}
 		}		
+		CHECK_FOR_INTERRUPTS();
 	}
+	elog(LOG, "Stop arbiter sender %d", MyProcPid);
 }
 
 

Original file line number	Diff line number	Diff line change
`@@ -710,7 +710,9 @@ static void MtmTransSender(Datum arg)`
`710`	`710`	`txBuffer[i].used = 0;`
`711`	`711`	`}`
`712`	`712`	`}`
	`713`	`+ CHECK_FOR_INTERRUPTS();`
`713`	`714`	`}`
	`715`	`+ elog(LOG, "Stop arbiter sender %d", MyProcPid);`
`714`	`716`	`}`
`715`	`717`
`716`	`718`