202 my_oracle(std::move(oracle)),
203 my_total(my_oracle->total()),
204 my_max_slabs(sanisizer::cast<decltype(my_max_slabs)>(max_slabs))
206 my_all_slabs.reserve(max_slabs);
207 my_current_cache.reserve(max_slabs);
208 my_future_cache.reserve(max_slabs);
209 my_close_future_subset_cache.reserve(max_slabs);
210 my_far_future_subset_cache.reserve(max_slabs);
212 my_all_subset_details.resize(sanisizer::product<
decltype(my_all_subset_details.size())>(2, max_slabs));
213 for (
auto& as : my_all_subset_details) {
214 my_free_subset_details.push_back(&as);
281 std::pair<const Slab_*, Index_>
next(Ifunction_ identify, Cfunction_ create, Pfunction_ populate) {
282 Index_ index = this->
next();
283 auto slab_info = identify(index);
284 if (slab_info.first == my_last_slab_id && my_last_slab) {
285 return std::make_pair(my_last_slab, slab_info.second);
287 my_last_slab_id = slab_info.first;
290 if (my_counter - 1 == my_close_refresh_point) {
291 if (my_all_slabs.empty()) {
293 requisition_subset_close(slab_info.first, slab_info.second);
294 decltype(my_max_slabs) used_slabs = 1;
296 while (++my_close_refresh_point < my_total) {
297 auto future_index = my_oracle->get(my_close_refresh_point);
298 auto future_slab_info = identify(future_index);
299 auto cfcIt = my_close_future_subset_cache.find(future_slab_info.first);
300 if (cfcIt != my_close_future_subset_cache.end()) {
301 OracularSubsettedSlabCache_internals::add_to_details(*(cfcIt->second), future_slab_info.second);
302 }
else if (used_slabs < my_max_slabs) {
303 requisition_subset_close(future_slab_info.first, future_slab_info.second);
306 my_far_slab_id = future_slab_info.first;
307 my_far_slab_offset = future_slab_info.second;
312 my_far_refresh_point = my_close_refresh_point;
314 my_close_refresh_point = my_far_refresh_point;
318 if (my_far_refresh_point < my_total) {
319 requisition_subset_far(my_far_slab_id, my_far_slab_offset);
320 decltype(my_max_slabs) used_slabs = 1;
322 while (++my_far_refresh_point < my_total) {
323 auto future_index = my_oracle->get(my_far_refresh_point);
324 auto future_slab_info = identify(future_index);
325 auto ffcIt = my_far_future_subset_cache.find(future_slab_info.first);
326 if (ffcIt != my_far_future_subset_cache.end()) {
327 OracularSubsettedSlabCache_internals::add_to_details(*(ffcIt->second), future_slab_info.second);
328 }
else if (used_slabs < my_max_slabs) {
329 requisition_subset_far(future_slab_info.first, future_slab_info.second);
332 my_far_slab_id = future_slab_info.first;
333 my_far_slab_offset = future_slab_info.second;
340 for (
auto& cf : my_close_future_subset_cache) {
341 auto cIt = my_current_cache.find(cf.first);
342 if (cIt == my_current_cache.end()) {
343 my_to_reassign.emplace_back(cf.first, cf.second);
345 my_future_cache[cf.first] = cIt->second;
346 my_current_cache.erase(cIt);
351 auto cIt = my_current_cache.begin();
352 for (
auto a : my_to_reassign) {
354 if (cIt == my_current_cache.end()) {
355 my_all_slabs.emplace_back(create());
356 slab_ptr = &(my_all_slabs.back());
358 slab_ptr = cIt->second;
361 my_future_cache[a.first] = slab_ptr;
362 OracularSubsettedSlabCache_internals::finalize_details(*(a.second));
363 my_to_populate.emplace_back(a.first, slab_ptr, a.second);
365 my_to_reassign.clear();
367 populate(my_to_populate);
368 my_to_populate.clear();
378 my_current_cache.clear();
379 my_current_cache.swap(my_future_cache);
383 for (
auto& cfc : my_close_future_subset_cache) {
384 my_free_subset_details.push_back(cfc.second);
386 my_close_future_subset_cache.clear();
387 my_close_future_subset_cache.swap(my_far_future_subset_cache);
391 auto ccIt = my_current_cache.find(slab_info.first);
392 my_last_slab = ccIt->second;
393 return std::make_pair(my_last_slab, slab_info.second);