mirror of
https://gitlab.com/veilid/veilid.git
synced 2025-07-31 10:48:49 -04:00
process watch changes only when online
This commit is contained in:
parent
93a8969938
commit
808cbda229
1 changed files with 3 additions and 3 deletions
|
@ -75,14 +75,14 @@ impl StorageManager {
|
||||||
// Run the flush stores task
|
// Run the flush stores task
|
||||||
self.save_metadata_task.tick().await?;
|
self.save_metadata_task.tick().await?;
|
||||||
|
|
||||||
// Check active watches
|
|
||||||
self.check_outbound_watches_task.tick().await?;
|
|
||||||
|
|
||||||
// Check watched records
|
// Check watched records
|
||||||
self.check_inbound_watches_task.tick().await?;
|
self.check_inbound_watches_task.tick().await?;
|
||||||
|
|
||||||
// Run online-only tasks
|
// Run online-only tasks
|
||||||
if self.dht_is_online() {
|
if self.dht_is_online() {
|
||||||
|
// Check active watches
|
||||||
|
self.check_outbound_watches_task.tick().await?;
|
||||||
|
|
||||||
// Run offline subkey writes task if there's work to be done
|
// Run offline subkey writes task if there's work to be done
|
||||||
if self.has_offline_subkey_writes().await {
|
if self.has_offline_subkey_writes().await {
|
||||||
self.offline_subkey_writes_task.tick().await?;
|
self.offline_subkey_writes_task.tick().await?;
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue