Skip to content

Commit fe0f6d3

Browse files
committed
pass actual shm names to c++
1 parent e720fb1 commit fe0f6d3

File tree

1 file changed

+10
-6
lines changed

1 file changed

+10
-6
lines changed

tests/test_atomic_cursor.py

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -469,15 +469,18 @@ def test_atomic_cursor_python_cpp_work_stealing_cursor_created_by_py():
469469
cursor = AtomicCursor(cursor_shm.buf, 0)
470470
cursor.store(0)
471471

472+
actual_name = q.get_shm_name()
473+
actual_cursor_name = cursor_shm.name
474+
472475
# Start C++ consumer process
473476
cpp_consumer = find_cpp_executable("cpp_work_stealing_consumer")
474477
output_file = Path(__file__).parent / "cpp_work_stealing_consumer_output.txt"
475478
cpp_consumer_proc = subprocess.Popen([
476479
cpp_consumer,
477-
queue_name,
480+
actual_name,
478481
str(num_items),
479482
str(32), # element size
480-
cursor_name,
483+
actual_cursor_name,
481484
str(output_file)
482485
], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
483486

@@ -554,20 +557,21 @@ def test_atomic_cursor_python_cpp_work_stealing_cursor_created_by_py():
554557
cursor = AtomicCursor(cursor_shm.buf, 0)
555558
cursor.store(0)
556559

560+
actual_name = q.get_shm_name()
561+
actual_cursor_name = cursor_shm.name
562+
557563
# Start C++ consumer process
558564
cpp_consumer = find_cpp_executable("cpp_work_stealing_consumer")
559565
output_file = Path(__file__).parent / "cpp_work_stealing_consumer_output.txt"
560566
cpp_consumer_proc = subprocess.Popen([
561567
cpp_consumer,
562-
queue_name,
568+
actual_name,
563569
str(num_items),
564570
str(32), # element size
565-
cursor_name,
571+
actual_cursor_name,
566572
str(output_file)
567573
], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
568574

569-
#time.sleep(1) # Give C++ consumer time to start
570-
571575
# Start consumer processes
572576
results = MPQueue()
573577
py_consumer_proc = Process(

0 commit comments

Comments
 (0)