Check fo rinterrupts in raftable

Author: knizhnik

contrib/mmts/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 && \

contrib/mmts/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);
 }
 
 

contrib/raftable/worker.c

@@ -445,7 +445,7 @@ static void worker_main(Datum arg)
 
 	elog(LOG, "Start raftable worker");
 
-	state = (StateP)get_shared_state();
+	state = get_shared_state();
 
 	cfg->raft_config.userdata = state;
 	cfg->raft_config.applier = applier;
@@ -487,6 +487,7 @@ static void worker_main(Datum arg)
 			raft_handle_message(raft, m);
 			notify();
 		}
+		CHECK_FOR_INTERRUPTS();
 	}
 	elog(LOG, "Raftable worker stopped");
 }