Further tweaks

apache · Sep 14, 2023 · fe93e7a · fe93e7a
1 parent 8e3b884
commit fe93e7a
Showing 1 changed file with 10 additions and 12 deletions.
diff --git a/arrow-row/src/variable.rs b/arrow-row/src/variable.rs
@@ -165,24 +165,22 @@ fn decode_blocks(row: &[u8], options: SortOptions, mut f: impl FnMut(&[u8])) ->
     let mut idx = 1;
     for _ in 0..MINI_BLOCK_COUNT {
         let sentinel = row[idx + MINI_BLOCK_SIZE];
-        if sentinel == continuation {
-            f(&row[idx..idx + MINI_BLOCK_SIZE]);
-            idx += MINI_BLOCK_SIZE + 1;
-            continue;
+        if sentinel != continuation {
+            f(&row[idx..idx + block_len(sentinel)]);
+            return idx + MINI_BLOCK_SIZE + 1;
         }
-        f(&row[idx..idx + block_len(sentinel)]);
-        return idx + MINI_BLOCK_SIZE + 1;
+        f(&row[idx..idx + MINI_BLOCK_SIZE]);
+        idx += MINI_BLOCK_SIZE + 1;
     }
 
     loop {
         let sentinel = row[idx + BLOCK_SIZE];
-        if sentinel == continuation {
-            f(&row[idx..idx + BLOCK_SIZE]);
-            idx += BLOCK_SIZE + 1;
-            continue;
+        if sentinel != continuation {
+            f(&row[idx..idx + block_len(sentinel)]);
+            return idx + BLOCK_SIZE + 1;
         }
-        f(&row[idx..idx + block_len(sentinel)]);
-        return idx + BLOCK_SIZE + 1;
+        f(&row[idx..idx + BLOCK_SIZE]);
+        idx += BLOCK_SIZE + 1;
     }
 }