Method get_data

src/models/cache_loader.rs:307–357

(
        &self,
        file_offset: FileOffset,
    )

    }

    pub fn get_data(
        &self,
        file_offset: FileOffset,
    ) -> Result<*mut LazyItem<InvertedIndexNodeData, ()>, BufIoError> {
        let combined_index = Self::combine_index(file_offset, 0);

        if let Some(item) = self.registry.get(&combined_index) {
            return Ok(item);
        }

        let mut mutex = self
            .loading_data
            .get_or_create(combined_index, || Arc::new(Mutex::new(false)));
        let mut load_complete = mutex.lock().unwrap();

        loop {
            // check again
            if let Some(item) = self.registry.get(&combined_index) {
                return Ok(item);
            }

            // another thread loaded the data but its not in the registry (got evicted), retry
            if *load_complete {
                drop(load_complete);
                mutex = self
                    .loading_data
                    .get_or_create(combined_index, || Arc::new(Mutex::new(false)));
                load_complete = mutex.lock().unwrap();
                continue;
            }

            break;
        }

        let data = InvertedIndexNodeData::deserialize(
            &self.dim_bufman,
            &self.data_bufmans,
            file_offset,
            VersionNumber::from(u32::MAX), // not used
            self,
        )?;

        let item = LazyItem::new(data, (), file_offset);

        self.registry.insert(combined_index, item);

        *load_complete = true;
        self.loading_data.delete(&combined_index);

        Ok(item)
    }

    pub fn combine_index(file_offset: FileOffset, data_file_idx: u8) -> u64 {
        ((data_file_idx as u64) << 32) | file_offset.0 as u64