wip

varfish-org · Oct 23, 2023 · 38a1886 · 38a1886
1 parent d9da776
commit 38a1886
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 3 deletions.
diff --git a/build.rs b/build.rs
@@ -1,5 +1,6 @@
 // The custom build script, needed as we use prost.
 
 fn main() {
+    println!("cargo:rerun-if-changed=src/db/create/txs/data.proto3");
     prost_build::compile_protos(&["src/db/create/txs/data.proto3"], &["src/"]).unwrap();
 }
diff --git a/...mon/io/snapshots/mehari__common__io__tokio__test__open_write_maybe_bgzf@14kb.txt.bgz.snap b/...mon/io/snapshots/mehari__common__io__tokio__test__open_write_maybe_bgzf@14kb.txt.bgz.snap
@@ -407,4 +407,6 @@ expression: "String::from_utf8_lossy(&buffer)"
 6432: 0E 1D 0E 1D 0E 1D 0E 1D 0E 1D 0E 1D 8E 3D 7F F5  .............=..
 6448: 31 7F F6 31 7F F7 31 7F F8 31 7F F9 31 7F FA 31  1..1..1..1..1..1
 6464: 7F FB 31 7F FC 31 7F FD F1 FF F3 8F 7D FC 00 80  ..1..1......}...
-6480: 99 73 8A 40 36 00 00                             .s.@6..
+6480: 99 73 8A 40 36 00 00 1F 8B 08 04 00 00 00 00 00  .s.@6...........
+6496: FF 06 00 42 43 02 00 1B 00 03 00 00 00 00 00 00  ...BC...........
+6512: 00 00 00                                         ...
diff --git a/...mmon/io/snapshots/mehari__common__io__tokio__test__open_write_maybe_bgzf@14kb.txt.gz.snap b/...mmon/io/snapshots/mehari__common__io__tokio__test__open_write_maybe_bgzf@14kb.txt.gz.snap
@@ -407,4 +407,6 @@ expression: "String::from_utf8_lossy(&buffer)"
 6432: 0E 1D 0E 1D 0E 1D 0E 1D 0E 1D 0E 1D 8E 3D 7F F5  .............=..
 6448: 31 7F F6 31 7F F7 31 7F F8 31 7F F9 31 7F FA 31  1..1..1..1..1..1
 6464: 7F FB 31 7F FC 31 7F FD F1 FF F3 8F 7D FC 00 80  ..1..1......}...
-6480: 99 73 8A 40 36 00 00                             .s.@6..
+6480: 99 73 8A 40 36 00 00 1F 8B 08 04 00 00 00 00 00  .s.@6...........
+6496: FF 06 00 42 43 02 00 1B 00 03 00 00 00 00 00 00  ...BC...........
+6512: 00 00 00                                         ...
diff --git a/src/common/io/tokio.rs b/src/common/io/tokio.rs
@@ -125,10 +125,12 @@ mod test {
                 writer.write_all(format!("{}\n", i).as_bytes()).await?;
             }
 
-            writer.flush().await?;
+            // writer.flush().await?;
             writer.shutdown().await?;
         }
 
+        std::thread::sleep(std::time::Duration::from_millis(100));
+
         let mut buffer: Vec<u8> = Vec::new();
         hxdmp::hexdump(
             &crate::common::io::std::read_to_bytes(&tmp_file_path)?,