summaryrefslogtreecommitdiff
path: root/src/step.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/step.rs')
-rw-r--r--src/step.rs68
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(())
}