aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJakob Unterwurzacher2015-10-20 20:12:31 +0200
committerJakob Unterwurzacher2015-11-01 01:36:19 +0100
commita5b907b42fa0960582b5fa2eae6a3a939a577c3d (patch)
tree9d8eeef02ebc78aa1f5c62584d2b6e4f96cbf45c
parentf87ea8672a3f9a18d74355e7944657c093800b4c (diff)
Add rmw race test
-rw-r--r--main_test.go87
1 files changed, 86 insertions, 1 deletions
diff --git a/main_test.go b/main_test.go
index b4dff95..8ae7b12 100644
--- a/main_test.go
+++ b/main_test.go
@@ -1,6 +1,8 @@
package main
import (
+ "runtime"
+ "sync"
"bytes"
"crypto/md5"
"encoding/hex"
@@ -12,13 +14,14 @@ import (
"testing"
)
-const tmpDir = "tmp/"
+const tmpDir = "/tmp/"
const plainDir = tmpDir + "plain/"
const cipherDir = tmpDir + "cipher/"
func mount(extraArgs ...string) {
var args []string
args = append(args, extraArgs...)
+ //args = append(args, "--fusedebug")
args = append(args, cipherDir)
args = append(args, plainDir)
c := exec.Command("./gocryptfs", args...)
@@ -44,6 +47,10 @@ func md5fn(filename string) string {
fmt.Printf("ReadFile: %v\n", err)
return ""
}
+ return md5hex(buf)
+}
+
+func md5hex(buf []byte) string {
rawHash := md5.Sum(buf)
hash := hex.EncodeToString(rawHash[:])
return hash
@@ -209,6 +216,84 @@ func TestFileHoles(t *testing.T) {
}
}
+func sContains(haystack []string, needle string) bool {
+ for _, element := range haystack {
+ if element == needle {
+ return true
+ }
+ }
+ return false
+}
+
+func TestRmwRace(t *testing.T) {
+
+ runtime.GOMAXPROCS(10)
+
+ fn := plainDir + "rmwrace"
+ f1, err := os.Create(fn)
+ if err != nil {
+ t.Errorf("file create failed")
+ }
+ f2, err := os.Create(fn)
+ if err != nil {
+ t.Errorf("file create failed")
+ }
+
+ oldBlock := bytes.Repeat([]byte("o"), 4096)
+
+ newBlock := bytes.Repeat([]byte("n"), 4096)
+
+ shortBlock := bytes.Repeat([]byte("s"), 16)
+
+ mergedBlock := make([]byte, 4096)
+ copy(mergedBlock, newBlock)
+ copy(mergedBlock[4080:], shortBlock)
+
+ goodMd5 := make(map[string]int)
+
+ for i := 0; i < 1000; i++ {
+ // Reset to [ooooooooo]
+ _, err = f1.WriteAt(oldBlock, 0)
+ if err != nil {
+ t.Errorf("Write failed")
+ }
+
+ var wg sync.WaitGroup
+ wg.Add(2)
+
+ // Write to the end of the file, [....ssss]
+ go func() {
+ f1.WriteAt(shortBlock, 4080)
+ wg.Done()
+ }()
+
+ // Overwrite to [nnnnnnn]
+ go func() {
+ f2.WriteAt(newBlock, 0)
+ wg.Done()
+ }()
+
+ wg.Wait()
+
+ // The file should be either:
+ // [nnnnnnnnnn] (md5: 6c1660fdabccd448d1359f27b3db3c99) or
+ // [nnnnnnssss] (md5: da885006a6a284530a427c73ce1e5c32)
+ // but it must not be
+ // [oooooossss]
+
+ buf, _ := ioutil.ReadFile(fn)
+ m := md5hex(buf)
+ goodMd5[m] = goodMd5[m] + 1
+
+ /*
+ if m == "6c1660fdabccd448d1359f27b3db3c99" {
+ fmt.Println(hex.Dump(buf))
+ t.FailNow()
+ }
+ */
+ }
+ fmt.Println(goodMd5)
+}
func BenchmarkStreamWrite(t *testing.B) {
buf := make([]byte, 1024*1024)
t.SetBytes(int64(len(buf)))