mirror of
https://gitlab.com/veilid/veilidchat.git
synced 2025-06-24 22:30:32 -04:00
watch anomaly
This commit is contained in:
parent
adaa2951c2
commit
7b400ed08b
1 changed files with 2 additions and 2 deletions
|
@ -673,7 +673,7 @@ class DHTRecordPool with TableDBBackedJson<DHTRecordPoolAllocations> {
|
||||||
|
|
||||||
/// Handle the DHT record updates coming from Veilid
|
/// Handle the DHT record updates coming from Veilid
|
||||||
void processRemoteValueChange(VeilidUpdateValueChange updateValueChange) {
|
void processRemoteValueChange(VeilidUpdateValueChange updateValueChange) {
|
||||||
if (updateValueChange.subkeys.isNotEmpty) {
|
if (updateValueChange.subkeys.isNotEmpty && updateValueChange.count != 0) {
|
||||||
// Change
|
// Change
|
||||||
for (final kv in _opened.entries) {
|
for (final kv in _opened.entries) {
|
||||||
if (kv.key == updateValueChange.key) {
|
if (kv.key == updateValueChange.key) {
|
||||||
|
@ -691,7 +691,7 @@ class DHTRecordPool with TableDBBackedJson<DHTRecordPoolAllocations> {
|
||||||
final openedRecordInfo = entry.value;
|
final openedRecordInfo = entry.value;
|
||||||
|
|
||||||
if (openedKey == updateValueChange.key) {
|
if (openedKey == updateValueChange.key) {
|
||||||
// Renew watch state for each opened recrod
|
// Renew watch state for each opened record
|
||||||
for (final rec in openedRecordInfo.records) {
|
for (final rec in openedRecordInfo.records) {
|
||||||
// See if the watch had an expiration and if it has expired
|
// See if the watch had an expiration and if it has expired
|
||||||
// otherwise the renewal will keep the same parameters
|
// otherwise the renewal will keep the same parameters
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue