| 68 | } |
| 69 | |
| 70 | void InitialReservations::Claim(BufferPool::ClientHandle* dst, int64_t bytes) { |
| 71 | DCHECK_GE(bytes, 0); |
| 72 | lock_guard<SpinLock> l(lock_); |
| 73 | DCHECK_LE(bytes, remaining_initial_reservation_claims_); |
| 74 | bool success = dst->TransferReservationFrom(&initial_reservations_, bytes); |
| 75 | DCHECK(success) << "Planner computation should ensure enough initial reservations"; |
| 76 | remaining_initial_reservation_claims_ -= bytes; |
| 77 | } |
| 78 | |
| 79 | void InitialReservations::Return(BufferPool::ClientHandle* src, int64_t bytes) { |
| 80 | lock_guard<SpinLock> l(lock_); |
no test coverage detected