snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-22 19:46:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Introduce the new IndexMapper index path method

Browse Source
This commit is contained in:
Kerollmops
2025-10-15 16:44:01 +02:00
parent 5a49b93b77
commit ffacf1c002
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
crates/index-scheduler/src/index_mapper/mod.rs
View File

@@ -199,7 +199,7 @@ impl IndexMapper {
let uuid = Uuid::new_v4(); let uuid = Uuid::new_v4();
self.index_mapping.put(&mut wtxn, name, &uuid)?; self.index_mapping.put(&mut wtxn, name, &uuid)?;
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.index_path(uuid);
fs::create_dir_all(&index_path)?; fs::create_dir_all(&index_path)?;
// Error if the UUIDv4 somehow already exists in the map, since it should be fresh. // Error if the UUIDv4 somehow already exists in the map, since it should be fresh.
@@ -286,7 +286,7 @@ impl IndexMapper {
}; };
let index_map = self.index_map.clone(); let index_map = self.index_map.clone();
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.index_path(uuid);
let index_name = name.to_string(); let index_name = name.to_string();
thread::Builder::new() thread::Builder::new()
.name(String::from("index_deleter")) .name(String::from("index_deleter"))
@@ -408,7 +408,7 @@ impl IndexMapper {
} else { } else {
continue; continue;
}; };
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.index_path(uuid);
// take the lock to reopen the environment. // take the lock to reopen the environment.
reopen reopen
.reopen(&mut self.index_map.write().unwrap(), &index_path) .reopen(&mut self.index_map.write().unwrap(), &index_path)
@@ -425,7 +425,7 @@ impl IndexMapper {
// if it's not already there. // if it's not already there.
match index_map.get(&uuid) { match index_map.get(&uuid) {
Missing => { Missing => {
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.index_path(uuid);
break index_map break index_map
.create( .create(
@@ -452,6 +452,14 @@ impl IndexMapper {
Ok(index) Ok(index)
} }
/// Returns the path of the index.
///
/// The folder located at this path is containing the data.mdb,
/// the lock.mdb and an optional data.mdb.cpy file.
pub fn index_path(&self, uuid: Uuid) -> PathBuf {
self.base_path.join(uuid.to_string())
}
pub fn rollback_index( pub fn rollback_index(
&self, &self,
rtxn: &RoTxn, rtxn: &RoTxn,
@@ -492,7 +500,7 @@ impl IndexMapper {
}; };
} }
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.index_path(uuid);
Index::rollback(milli::heed::EnvOpenOptions::new().read_txn_without_tls(), index_path, to) Index::rollback(milli::heed::EnvOpenOptions::new().read_txn_without_tls(), index_path, to)
.map_err(|err| crate::Error::from_milli(err, Some(name.to_string()))) .map_err(|err| crate::Error::from_milli(err, Some(name.to_string())))
} }