Skip to content

Commit d74a7c1

Browse files
committed
reserve_or_wait_or_overbook: use mem_type_
1 parent f980092 commit d74a7c1

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

cpp/src/streaming/core/memory_reserve_or_wait.cpp

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -126,9 +126,7 @@ MemoryReserveOrWait::reserve_or_wait_or_overbook(
126126
) {
127127
auto ret = co_await reserve_or_wait(size, future_release_potential);
128128
if (ret.size() < size) {
129-
co_return ctx_->br()->reserve(
130-
MemoryType::DEVICE, size, /* allow_overbooking = */ true
131-
);
129+
co_return ctx_->br()->reserve(mem_type_, size, /* allow_overbooking = */ true);
132130
}
133131
co_return {std::move(ret), size};
134132
}

0 commit comments

Comments
 (0)