RRD footers: everything framing

Author: teh-cmc

Cargo.lock

@@ -9070,10 +9070,13 @@ dependencies = [
  "bytes",
  "criterion",
  "ehttp",
+ "insta",
+ "itertools 0.14.0",
  "js-sys",
  "lz4_flex 0.12.0",
  "mimalloc",
  "parking_lot",
+ "re_arrow_util",
  "re_build_info",
  "re_chunk",
  "re_log",
@@ -9083,6 +9086,8 @@ dependencies = [
  "re_sorbet",
  "re_tracing",
  "re_types",
+ "re_types_core",
+ "sha2",
  "similar-asserts",
  "thiserror 2.0.17",
  "tokio",
@@ -9092,6 +9097,7 @@ dependencies = [
  "wasm-bindgen-futures",
  "web-sys",
  "web-time",
+ "xxhash-rust",
 ]
 
 [[package]]

Cargo.toml

@@ -427,6 +427,7 @@ wgpu = { version = "27.0.1", default-features = false, features = [
   "fragile-send-sync-non-atomic-wasm",
 ] }
 xshell = "0.2.7"
+xxhash-rust = { version = "0.8", features = ["xxh32"] }
 
 # ---------------------------------------------------------------------------------
 [profile]

crates/store/re_log_encoding/Cargo.toml

@@ -42,6 +42,7 @@ stream_from_http = [
 [dependencies]
 
 # Rerun:
+re_arrow_util.workspace = true
 re_build_info.workspace = true
 re_chunk.workspace = true
 re_log_types.workspace = true
@@ -50,13 +51,17 @@ re_protos.workspace = true
 re_smart_channel.workspace = true
 re_sorbet.workspace = true
 re_tracing.workspace = true
+re_types_core.workspace = true
 
 # External:
 arrow = { workspace = true, features = ["ipc"] }
+itertools.workspace = true
 lz4_flex = { workspace = true }
 parking_lot.workspace = true
+sha2.workspace = true
 thiserror.workspace = true
 tracing.workspace = true
+xxhash-rust.workspace = true
 
 # Optional external dependencies:
 bytes = { workspace = true, optional = true }
@@ -76,6 +81,7 @@ web-sys = { workspace = true, optional = true, features = ["Window", "MessageEve
 re_types.workspace = true
 
 criterion.workspace = true
+insta.workspace = true
 mimalloc.workspace = true
 similar-asserts.workspace = true
 

crates/store/re_log_encoding/src/rrd/decoder/iterator.rs

@@ -139,7 +139,7 @@ impl<T: DecoderEntrypoint, R: std::io::BufRead> std::iter::Iterator for DecoderI
 
                         // …and the underlying decoder already considers that it's done (i.e. it's
                         // waiting for a whole new stream to begin): time to stop.
-                        Ok(None) if self.decoder.state == DecoderState::StreamHeader => {
+                        Ok(None) if self.decoder.state == DecoderState::WaitingForStreamHeader => {
                             return None;
                         }
 
@@ -570,3 +570,4 @@ mod tests {
         }
     }
 }
+