Method pullAnyCacheData

engine/src/cache_machine/CacheMachine.cpp:691–724

}

std::unique_ptr<ral::cache::CacheData> CacheMachine::pullAnyCacheData(const std::vector<std::string> & messages) {

	if (messages.size() == 0){
		return nullptr;
	}

	CodeTimer cacheEventTimer;
    cacheEventTimer.start();

    std::unique_ptr<message> message_data = waitingCache->get_or_wait_any(messages);
	std::string message_id = message_data->get_message_id();
    
    size_t num_rows = message_data->get_data().num_rows();
    size_t num_bytes = message_data->get_data().sizeInBytes();
    int dataType = static_cast<int>(message_data->get_data().get_type());
    std::unique_ptr<ral::cache::CacheData> output = message_data->release_data();

    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=message_id,
                                  "cache_id"_a=cache_id,
                                  "num_rows"_a=num_rows,
                                  "num_bytes"_a=num_bytes,
                                  "event_type"_a="pullAnyCacheData",
                                  "timestamp_begin"_a=cacheEventTimer.start_time(),
                                  "timestamp_end"_a=cacheEventTimer.end_time(),
                                  "description"_a="Pull from CacheMachine CacheData object type {}"_format(dataType));
    }

	return output;
}

bool CacheMachine::has_data_in_index_now(size_t index){
    std::string message = this->cache_machine_name + "_" + std::to_string(index);