diff options
Diffstat (limited to 'src/test/modules/test_shm_mq/worker.c')
| -rw-r--r-- | src/test/modules/test_shm_mq/worker.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/test/modules/test_shm_mq/worker.c b/src/test/modules/test_shm_mq/worker.c index 3e45c75dc05..f8aef263f72 100644 --- a/src/test/modules/test_shm_mq/worker.c +++ b/src/test/modules/test_shm_mq/worker.c @@ -95,7 +95,7 @@ test_shm_mq_main(Datum main_arg) * find it. Our worker number gives our identity: there may be just one * worker involved in this parallel operation, or there may be many. */ - hdr = shm_toc_lookup(toc, 0); + hdr = shm_toc_lookup(toc, 0, false); SpinLockAcquire(&hdr->mutex); myworkernumber = ++hdr->workers_attached; SpinLockRelease(&hdr->mutex); @@ -158,10 +158,10 @@ attach_to_queues(dsm_segment *seg, shm_toc *toc, int myworkernumber, shm_mq *inq; shm_mq *outq; - inq = shm_toc_lookup(toc, myworkernumber); + inq = shm_toc_lookup(toc, myworkernumber, false); shm_mq_set_receiver(inq, MyProc); *inqhp = shm_mq_attach(inq, seg, NULL); - outq = shm_toc_lookup(toc, myworkernumber + 1); + outq = shm_toc_lookup(toc, myworkernumber + 1, false); shm_mq_set_sender(outq, MyProc); *outqhp = shm_mq_attach(outq, seg, NULL); } |