aboutsummaryrefslogtreecommitdiff
path: root/src/k2v-client/lib.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-07-04 14:00:02 +0200
committerAlex Auvolat <alex@adnab.me>2022-07-04 14:00:02 +0200
commitb6d59ec19a3d41ce581716cf0dda5d47c2785843 (patch)
tree9f5147aeb868c62eb4d628258e4c2790a9cf4a6e /src/k2v-client/lib.rs
parent0850bac874029f0b8b278d75537dd037e5db57da (diff)
downloadgarage-b6d59ec19a3d41ce581716cf0dda5d47c2785843.tar.gz
garage-b6d59ec19a3d41ce581716cf0dda5d47c2785843.zip
Fix poll item when item didn't changek2v-poll-fix
Diffstat (limited to 'src/k2v-client/lib.rs')
-rw-r--r--src/k2v-client/lib.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/k2v-client/lib.rs b/src/k2v-client/lib.rs
index 95974d7a..c2606af4 100644
--- a/src/k2v-client/lib.rs
+++ b/src/k2v-client/lib.rs
@@ -122,14 +122,14 @@ impl K2vClient {
let res = self.dispatch(req, Some(timeout + DEFAULT_TIMEOUT)).await?;
- let causality = res
- .causality_token
- .ok_or_else(|| Error::InvalidResponse("missing causality token".into()))?;
-
if res.status == StatusCode::NOT_MODIFIED {
return Ok(None);
}
+ let causality = res
+ .causality_token
+ .ok_or_else(|| Error::InvalidResponse("missing causality token".into()))?;
+
if res.status == StatusCode::NO_CONTENT {
return Ok(Some(CausalValue {
causality,