MyFSIO v0.4.0 Release #33

Merged
kqjy merged 19 commits from next into main 2026-03-22 05:06:47 +00:00
Showing only changes of commit a496862902 - Show all commits

View File

@@ -406,6 +406,10 @@ class ObjectStorage:
self._stats_serial[bucket_id] = self._stats_serial.get(bucket_id, 0) + 1 self._stats_serial[bucket_id] = self._stats_serial.get(bucket_id, 0) + 1
self._stats_mem_time[bucket_id] = time.monotonic() self._stats_mem_time[bucket_id] = time.monotonic()
self._stats_dirty.add(bucket_id) self._stats_dirty.add(bucket_id)
needs_immediate = data["objects"] == 0 and objects_delta < 0
if needs_immediate:
self._flush_stats()
else:
self._schedule_stats_flush() self._schedule_stats_flush()
def _schedule_stats_flush(self) -> None: def _schedule_stats_flush(self) -> None: