pub fn replay(&mut self) -> Result<(), Error> {
        let partition_path = Path::new(&self.cfg.dir).join("partition");
        create_dir_all(&partition_path)?;

        // iterate over every partition and find the crashed segment
        // files.
        for partition in read_dir(&partition_path)? {
            let partition = partition?;
            if partition.path().is_dir() {
                self.replay_segments(partition.path())?;
            }
        }
        Ok(())
    }
/// replay function replay the crashed segment files.
replay function replay the crashed segment files.
replay function replay the crashed segment files .
pub fn replay(&mut self) -> Result<(), Error> {
        let partition_path = Path::new(&self.cfg.dir).join("partition");
        create_dir_all(&partition_path)?;
        // iterate over every partition and find the crashed segment
        // files.
        for partition in read_dir(&partition_path)? {
            let partition = partition?;
            if partition.path().is_dir() {
                self.replay_segments(partition.path())?;
            }
        }
        Ok(())
    }
pub fn replay ( & mut self ) -> Result < ( ) , Error > { let partition_path = Path :: new ( & self . cfg . dir ) . join ( " " ) ; create_dir_all ( & partition_path ) ? ; // iterate over every partition and find the crashed segment // files. for partition in read_dir ( & partition_path ) ? { let partition = partition ? ; if partition . path ( ) . is_dir ( ) { self . replay_segments ( partition . path ( ) ) ? ; } } Ok ( ( ) ) }
replay function replay the crashed segment files.
replay function replay the crashed segment files .
&mut self