| 55 | } |
| 56 | |
| 57 | std::vector<ContinuePromise> LocalExchangeMemoryManager::decreaseMemoryUsage( |
| 58 | int64_t removed) { |
| 59 | std::vector<ContinuePromise> promises; |
| 60 | { |
| 61 | std::lock_guard<std::mutex> l(mutex_); |
| 62 | bufferedBytes_ -= removed; |
| 63 | |
| 64 | if (bufferedBytes_ < maxBufferSize_) { |
| 65 | promises = std::move(promises_); |
| 66 | } |
| 67 | } |
| 68 | return promises; |
| 69 | } |
| 70 | |
| 71 | void LocalExchangeQueue::addProducer() { |
| 72 | queue_.withWLock([&](auto& /*queue*/) { |
no outgoing calls
no test coverage detected