IntenseWebs/veilid
3
0
Fork 0
mirror of https://gitlab.com/veilid/veilid.git synced 2025-02-25 18:55:38 -06:00
Code Issues Packages Projects Releases Wiki Activity

keep 'last ditch watch cancel' from failing the whole operation

Browse Source
This commit is contained in:
Christien Rioux
2024-06-02 12:54:06 -04:00
parent 76eedb01b0
commit faf8347aa8
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
veilid-core/src/storage_manager/mod.rs
View File

@@ -332,7 +332,7 @@ impl StorageManager {
if let Some(rpc_processor) = opt_rpc_processor { if let Some(rpc_processor) = opt_rpc_processor {
// Use the safety selection we opened the record with // Use the safety selection we opened the record with
// Use the writer we opened with as the 'watcher' as well // Use the writer we opened with as the 'watcher' as well
let opt_owvresult = self let opt_owvresult = match self
.outbound_watch_value_cancel( .outbound_watch_value_cancel(
rpc_processor, rpc_processor,
key, key,
@@ -342,7 +342,16 @@ impl StorageManager {
active_watch.id, active_watch.id,
active_watch.watch_node, active_watch.watch_node,
) )
.await?; .await
{
Ok(v) => v,
Err(e) => {
log_stor!(debug
"close record watch cancel failed: {}", e
);
None
}
};
if let Some(owvresult) = opt_owvresult { if let Some(owvresult) = opt_owvresult {
if owvresult.expiration_ts.as_u64() != 0 { if owvresult.expiration_ts.as_u64() != 0 {
log_stor!(debug log_stor!(debug