Method pull_all_cache_data

engine/src/cache_machine/CacheMachine.cpp:172–200

std::vector<std::unique_ptr<ral::cache::CacheData> > CacheMachine::pull_all_cache_data(){
    CodeTimer cacheEventTimer;
    cacheEventTimer.start();

	auto messages = this->waitingCache->get_all();
	std::vector<std::unique_ptr<ral::cache::CacheData> > new_messages(messages.size());
	int i = 0;
	for (auto & message_data : messages){
		new_messages[i] = message_data->release_data();
		i++;
	}

    cacheEventTimer.stop();
    if(cache_events_logger) {
        cache_events_logger->info("{ral_id}|{query_id}|{message_id}|{cache_id}|{num_rows}|{num_bytes}|{event_type}|{timestamp_begin}|{timestamp_end}|{description}",
                                  "ral_id"_a=(ctx ? ctx->getNodeIndex(ral::communication::CommunicationData::getInstance().getSelfNode()) : -1),
                                  "query_id"_a=(ctx ? ctx->getContextToken() : -1),
                                  "message_id"_a=cache_machine_name,
                                  "cache_id"_a=cache_id,
                                  "num_rows"_a=num_rows_added,
                                  "num_bytes"_a=num_bytes_added,
                                  "event_type"_a="PullAllCacheData",
                                  "timestamp_begin"_a=cacheEventTimer.start_time(),
                                  "timestamp_end"_a=cacheEventTimer.end_time(),
                                  "description"_a="Pull all cache data");
    }

	return new_messages;
}

std::vector<size_t> CacheMachine::get_all_indexes() {
	std::vector<std::string> message_ids = this->waitingCache->get_all_message_ids();