fix successor

Author: rklaehn

src/store/fs.rs

@@ -86,7 +86,6 @@ use serde::{Deserialize, Serialize};
 use smallvec::SmallVec;
 use tokio::io::AsyncWriteExt;
 use tracing::trace_span;
-
 mod tables;
 #[doc(hidden)]
 pub mod test_support;

src/store/mem.rs

@@ -17,6 +17,7 @@ use bao_tree::{
 use bytes::{Bytes, BytesMut};
 use futures_lite::{Stream, StreamExt};
 use iroh_io::AsyncSliceReader;
+use tracing::info;
 
 use super::{
     temp_name, BaoBatchWriter, ConsistencyCheckProgress, ExportMode, ExportProgressCb, ImportMode,
@@ -215,6 +216,8 @@ impl super::Store for Store {
 
     async fn delete_tags(&self, from: Option<Tag>, to: Option<Tag>) -> io::Result<()> {
         let mut state = self.write_lock();
+        info!("deleting tags from {:?} to {:?}", from, to);
+        // state.tags.remove(&from.unwrap());
         // todo: more efficient impl
         state.tags.retain(|tag, _| {
             if let Some(from) = &from {
@@ -227,6 +230,7 @@ impl super::Store for Store {
                     return true;
                 }
             }
+            info!("    removing {:?}", tag);
             false
         });
         Ok(())

src/util.rs

@@ -148,7 +148,8 @@ impl Tag {
     /// The successor of this tag in lexicographic order.
     pub fn successor(&self) -> Self {
         let mut bytes = self.0.to_vec();
-        increment_vec(&mut bytes);
+        // increment_vec(&mut bytes);
+        bytes.push(0);
         Self(bytes.into())
     }
 
@@ -349,20 +350,6 @@ pub(crate) fn next_prefix(bytes: &mut [u8]) -> bool {
     false
 }
 
-/// Increment a byte vector, lexographically.
-#[allow(dead_code)]
-pub(crate) fn increment_vec(bytes: &mut Vec<u8>) {
-    for byte in bytes.iter_mut().rev() {
-        if *byte < 255 {
-            *byte += 1;
-            return;
-        }
-        *byte = 0;
-    }
-
-    bytes.push(0);
-}
-
 /// Synchronously compute the outboard of a file, and return hash and outboard.
 ///
 /// It is assumed that the file is not modified while this is running.