diff options
Diffstat (limited to 'src/step.rs')
-rw-r--r-- | src/step.rs | 68 |
1 files changed, 0 insertions, 68 deletions
diff --git a/src/step.rs b/src/step.rs index 9755f70..dee07d3 100644 --- a/src/step.rs +++ b/src/step.rs @@ -1,6 +1,4 @@ -use crate::result::{Measurement, OpMeasurements, Operation}; use crate::specification::{Change, Create, FileCount}; -use std::time::Instant; /// A step in the execution of a benchmark. #[derive(Debug)] @@ -49,70 +47,4 @@ impl Step { Change::Delete(x) => Self::Delete(x.clone()), } } - - pub fn execute( - &self, - current: &mut Option<String>, - ) -> Result<Option<OpMeasurements>, StepError> { - let now = Instant::now(); - let om = match self { - Self::Start(name) => { - *current = Some(name.to_string()); - None - } - Self::Stop(_) => { - *current = None; - None - } - Self::Create(x) => { - create_files(x)?; - None - } - Self::Rename(x) => { - rename_files(x)?; - None - } - Self::Delete(x) => { - delete_files(x)?; - None - } - Self::Backup(x) => Some(backup(*x, current.as_ref().unwrap())?), - Self::Restore(x) => Some(restore(*x, current.as_ref().unwrap())?), - }; - - println!("{:?}", self); - let t = std::time::Duration::from_millis(10); - std::thread::sleep(t); - - if let Some(mut om) = om { - let ms = now.elapsed().as_millis(); - om.push(Measurement::DurationMs(ms)); - Ok(Some(om)) - } else { - Ok(None) - } - } -} - -fn backup(i: usize, current: &str) -> Result<OpMeasurements, StepError> { - let mut om = OpMeasurements::new(current, Operation::Backup(i)); - om.push(Measurement::TotalFiles(0)); - om.push(Measurement::TotalData(0)); - Ok(om) -} - -fn restore(i: usize, current: &str) -> Result<OpMeasurements, StepError> { - Ok(OpMeasurements::new(current, Operation::Restore(i))) -} - -fn create_files(_: &Create) -> Result<(), StepError> { - Ok(()) -} - -fn rename_files(_: &FileCount) -> Result<(), StepError> { - Ok(()) -} - -fn delete_files(_: &FileCount) -> Result<(), StepError> { - Ok(()) } |