summaryrefslogtreecommitdiff
path: root/cli/worker.rs
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2020-02-11 17:23:40 +0100
committerGitHub <noreply@github.com>2020-02-11 17:23:40 +0100
commite0bcecee6042b219c6626172851af5a25362b948 (patch)
tree6d56a581d715738c9e38fc4e4077c96c083f67ba /cli/worker.rs
parent5a143cdbd34df590a24ec756a6319a89d7656e5c (diff)
refactor: Remove atomics from metrics (#3968)
* replace "AtomicUsize" with "u64" for field type on "Metrics" * move "compiler_starts" field from "Metrics" to "GlobalState"
Diffstat (limited to 'cli/worker.rs')
-rw-r--r--cli/worker.rs23
1 files changed, 9 insertions, 14 deletions
diff --git a/cli/worker.rs b/cli/worker.rs
index b804ff449..c975a588a 100644
--- a/cli/worker.rs
+++ b/cli/worker.rs
@@ -265,11 +265,10 @@ mod tests {
panic!("Future got unexpected error: {:?}", e);
}
});
- let mut state = state_.borrow_mut();
- let metrics = &mut state.metrics;
- assert_eq!(metrics.resolve_count.load(Ordering::SeqCst), 2);
+ let state = state_.borrow();
+ assert_eq!(state.metrics.resolve_count, 2);
// Check that we didn't start the compiler.
- assert_eq!(metrics.compiler_starts.load(Ordering::SeqCst), 0);
+ assert_eq!(state.global_state.compiler_starts.load(Ordering::SeqCst), 0);
}
#[test]
@@ -298,11 +297,10 @@ mod tests {
}
});
- let mut state = state_.borrow_mut();
- let metrics = &mut state.metrics;
- // TODO assert_eq!(metrics.resolve_count.load(Ordering::SeqCst), 2);
+ let state = state_.borrow();
+ assert_eq!(state.metrics.resolve_count, 1);
// Check that we didn't start the compiler.
- assert_eq!(metrics.compiler_starts.load(Ordering::SeqCst), 0);
+ assert_eq!(state.global_state.compiler_starts.load(Ordering::SeqCst), 0);
}
#[tokio::test]
@@ -339,13 +337,10 @@ mod tests {
if let Err(e) = (&mut *worker).await {
panic!("Future got unexpected error: {:?}", e);
}
- let state = state.borrow_mut();
- assert_eq!(state.metrics.resolve_count.load(Ordering::SeqCst), 3);
+ let state = state.borrow();
+ assert_eq!(state.metrics.resolve_count, 3);
// Check that we've only invoked the compiler once.
- assert_eq!(
- global_state.metrics.compiler_starts.load(Ordering::SeqCst),
- 1
- );
+ assert_eq!(state.global_state.compiler_starts.load(Ordering::SeqCst), 1);
drop(http_server_guard);
}