pglogical_apply.c :: CHECK_FOR_INTERRUPTS

2ndQuadrant · Mar 7, 2024 · 537c1a7 · 537c1a7
1 parent bff71f2
commit 537c1a7
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pglogical_apply.c b/pglogical_apply.c
@@ -1360,6 +1360,8 @@ apply_work(PGconn *streamConn)
 	{
 		int			rc;
 		int			r;
+
+		CHECK_FOR_INTERRUPTS();
 
 		/*
 		 * Background workers mustn't call usleep() or any direct equivalent: