diff options
Diffstat (limited to 'src/test')
| -rw-r--r-- | src/test/modules/test_shm_mq/setup.c | 6 | ||||
| -rw-r--r-- | src/test/modules/test_shm_mq/test.c | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/test/modules/test_shm_mq/setup.c b/src/test/modules/test_shm_mq/setup.c index 7f2f5fd3ff7..061af8b4676 100644 --- a/src/test/modules/test_shm_mq/setup.c +++ b/src/test/modules/test_shm_mq/setup.c @@ -287,11 +287,11 @@ wait_for_workers_to_become_ready(worker_state *wstate, /* Wait to be signalled. */ WaitLatch(MyLatch, WL_LATCH_SET, 0); - /* An interrupt may have occurred while we were waiting. */ - CHECK_FOR_INTERRUPTS(); - /* Reset the latch so we don't spin. */ ResetLatch(MyLatch); + + /* An interrupt may have occurred while we were waiting. */ + CHECK_FOR_INTERRUPTS(); } } PG_CATCH(); diff --git a/src/test/modules/test_shm_mq/test.c b/src/test/modules/test_shm_mq/test.c index 732376daff2..b36b4bf1293 100644 --- a/src/test/modules/test_shm_mq/test.c +++ b/src/test/modules/test_shm_mq/test.c @@ -231,8 +231,8 @@ test_shm_mq_pipelined(PG_FUNCTION_ARGS) * for us to do. */ WaitLatch(MyLatch, WL_LATCH_SET, 0); - CHECK_FOR_INTERRUPTS(); ResetLatch(MyLatch); + CHECK_FOR_INTERRUPTS(); } } |