tools: handle short header read in offline_log_viewer

mmaslankaprv · Dec 15, 2022 · b492385 · b492385
1 parent 7f666f7
commit b492385
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/tools/offline_log_viewer/storage.py b/tools/offline_log_viewer/storage.py
@@ -218,7 +218,10 @@ def from_stream(f, index):
                 return None
             assert len(data) == records_size
             return Batch(index, header, data)
-        assert len(data) == 0
+
+        if len(data) < HEADER_SIZE:
+            # Short read, probably log being actively written or unclean shutdown
+            return None
 
     def __len__(self):
         return self.header.record_count