Lines Matching refs:heap
47 import multiprocessing.heap
1723 wrapper = multiprocessing.heap.BufferWrapper(struct.calcsize('i'))
3673 # Make pristine heap for these tests
3674 self.old_heap = multiprocessing.heap.BufferWrapper._heap
3675 multiprocessing.heap.BufferWrapper._heap = multiprocessing.heap.Heap()
3678 multiprocessing.heap.BufferWrapper._heap = self.old_heap
3686 # get the heap object
3687 heap = multiprocessing.heap.BufferWrapper._heap
3688 heap._DISCARD_FREE_SPACE_LARGER_THAN = 0
3693 b = multiprocessing.heap.BufferWrapper(size)
3700 # verify the state of the heap
3701 with heap._lock:
3705 for L in list(heap._len_to_seq.values()):
3708 all.append((heap._arenas.index(arena), start, stop,
3711 for arena, arena_blocks in heap._allocated_blocks.items():
3714 all.append((heap._arenas.index(arena), start, stop,
3719 sum(arena.size for arena in heap._arenas))
3728 self.assertEqual(stop, heap._arenas[arena].size) # last block
3739 self.assertEqual(heap._n_frees, heap._n_mallocs)
3740 self.assertEqual(len(heap._pending_free_blocks), 0)
3741 self.assertEqual(len(heap._arenas), 0)
3742 self.assertEqual(len(heap._allocated_blocks), 0, heap._allocated_blocks)
3743 self.assertEqual(len(heap._len_to_seq), 0)
3761 a = multiprocessing.heap.BufferWrapper(1)
3762 b = multiprocessing.heap.BufferWrapper(1)