start at min size in gear function

chunker_test.go

@@ -24,13 +24,17 @@ func TestChunkerNext(t *testing.T) {
 	require.NoError(t, err)
 
 	var output []byte
-	for chunker.HasNext() {
+	for {
 		chunk, err := chunker.Next()
 		require.NoError(t, err)
 		output = append(output, chunk...)
 
-		assert.True(t, len(chunk) <= options.maxSize)
-		assert.True(t, len(chunk) >= options.minSize || !chunker.HasNext())
+		if !chunker.HasNext() {
+			break
+		}
+
+		assert.True(t, len(chunk) <= options.maxSize, "maxSize=%d len=%d", options.maxSize, len(chunk))
+		assert.True(t, len(chunk) >= options.minSize, "minSize=%d len=%d", options.minSize, len(chunk))
 	}
 
 	expect, err := io.ReadAll(&input)

fastcdc.go

@@ -27,19 +27,19 @@ func init() {
 // Boundary returns the next chunk boundary for the given bytes.
 func Boundary(src []byte, options *Options) int {
 	size := min(len(src), options.maxSize)
-	if size < options.minSize {
+	if size <= options.minSize {
 		return size
 	}
 
 	hash := uint64(0)
 	norm := min(options.avgSize, size)
 
-	for i := 0; i < (norm / 2); i++ {
+	for i := options.minSize; i < (norm / 2); i++ {
 		hash = (hash << 2) + gearL[src[i*2]]
 		if (hash & (options.maskS << 1)) == 0 {
 			return i * 2
 		}
-		hash += gearN[src[i*2+1]]
+		hash = hash + gearN[src[i*2+1]]
 		if (hash & options.maskS) == 0 {
 			return (i * 2) + 1
 		}
@@ -50,7 +50,7 @@ func Boundary(src []byte, options *Options) int {
 		if (hash & (options.maskL << 1)) == 0 {
 			return i * 2
 		}
-		hash += gearN[src[i*2+1]]
+		hash = hash + gearN[src[i*2+1]]
 		if (hash & options.maskL) == 0 {
 			return (i * 2) + 1
 		}