We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 540324c commit 3b685eaCopy full SHA for 3b685ea
zstor/src/actors/repairer.rs
@@ -67,15 +67,15 @@ struct SweepGuard {
67
68
impl Drop for SweepGuard {
69
fn drop(&mut self) {
70
- self.flag.store(false, Ordering::Release);
+ self.flag.store(false, Ordering::Relaxed);
71
}
72
73
74
impl Handler<SweepObjects> for RepairActor {
75
type Result = ResponseFuture<()>;
76
77
fn handle(&mut self, _: SweepObjects, _: &mut Self::Context) -> Self::Result {
78
- if self.handling_sweep_objects.swap(true, Ordering::Acquire) {
+ if self.handling_sweep_objects.swap(true, Ordering::Relaxed) {
79
log::info!("Dropping SweepObjects message - still processing");
80
return Box::pin(async {});
81
0 commit comments