move old funcs to repo_test and add roundtrip test

1 files changed, 0 insertions, 41 deletions

diff --git a/repo.go b/repo.go
index b9407fc..e633241 100644
--- a/repo.go
+++ b/repo.go
@@ -38,7 +38,6 @@ import (
 	"os"
 	"path/filepath"
 	"reflect"
-	"sync"
 
 	"github.com/chmduquesne/rollinghash/rabinkarp64"
 	"github.com/n-peugnet/dna-backup/cache"
@@ -493,46 +492,6 @@ func (r *Repo) chunkMinLen() int {
 	return sketch.SuperFeatureSize(r.chunkSize, r.sketchSfCount, r.sketchFCount)
 }
 
-// hashChunks calculates the hashes for a channel of chunks.
-// For each chunk, both a fingerprint (hash over the full content) and a sketch
-// (resemblance hash based on maximal values of regions) are calculated and
-// stored in an hashmap.
-func (r *Repo) hashChunks(chunks <-chan IdentifiedChunk) {
-	for c := range chunks {
-		r.hashChunk(c.GetId(), c.Reader())
-	}
-}
-
-// hashChunk calculates the hashes for a chunk and store them in th repo hashmaps.
-func (r *Repo) hashChunk(id *ChunkId, reader io.Reader) (fp uint64, sk []uint64) {
-	var buffSk bytes.Buffer
-	var buffFp bytes.Buffer
-	var wg sync.WaitGroup
-	reader = io.TeeReader(reader, &buffSk)
-	io.Copy(&buffFp, reader)
-	wg.Add(2)
-	go r.makeFingerprint(id, &buffFp, &wg, &fp)
-	go r.makeSketch(id, &buffSk, &wg, &sk)
-	wg.Wait()
-	if _, e := r.fingerprints[fp]; e {
-		logger.Error(fp, " already exists in fingerprints map")
-	}
-	r.fingerprints[fp] = id
-	r.sketches.Set(sk, id)
-	return
-}
-
-func (r *Repo) makeFingerprint(id *ChunkId, reader io.Reader, wg *sync.WaitGroup, ret *uint64) {
-	defer wg.Done()
-	hasher := rabinkarp64.NewFromPol(r.pol)
-	io.Copy(hasher, reader)
-	*ret = hasher.Sum64()
-}
-
-func (r *Repo) makeSketch(id *ChunkId, reader io.Reader, wg *sync.WaitGroup, ret *[]uint64) {
-	defer wg.Done()
-	*ret, _ = sketch.SketchChunk(reader, r.pol, r.chunkSize, r.sketchWSize, r.sketchSfCount, r.sketchFCount)
-}
 func contains(s []*ChunkId, id *ChunkId) bool {
 	for _, v := range s {
 		if v == id {