From f59479736bed49411bda3368f419d6605f1faa78 Mon Sep 17 00:00:00 2001
From: Jakob Unterwurzacher
Date: Thu, 10 Aug 2017 20:55:45 +0200
Subject: tests: add diriv cache race test

Passes.
---
 tests/defaults/diriv_test.go | 73 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 73 insertions(+)
 create mode 100644 tests/defaults/diriv_test.go

(limited to 'tests/defaults')

diff --git a/tests/defaults/diriv_test.go b/tests/defaults/diriv_test.go
new file mode 100644
index 0000000..75f1511
--- /dev/null
+++ b/tests/defaults/diriv_test.go
@@ -0,0 +1,73 @@
+package defaults
+
+import (
+	"io/ioutil"
+	"os"
+	"sync"
+	"syscall"
+	"testing"
+	"time"
+
+	"github.com/rfjakob/gocryptfs/tests/test_helpers"
+)
+
+func TestDirIVRace(t *testing.T) {
+	// Create "dir1" with one file in it
+	dir1 := test_helpers.DefaultPlainDir + "/TestDirIVRace_Dir1"
+	err := os.Mkdir(dir1, 0700)
+	if err != nil {
+		t.Fatal(err)
+	}
+	err = ioutil.WriteFile(dir1+"/file", nil, 0600)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	// Create directory "dir2"
+	dir2 := test_helpers.DefaultPlainDir + "/TestDirIVRace_Dir2"
+	err = os.Mkdir(dir2, 0700)
+	if err != nil {
+		t.Fatal(err)
+	}
+	file2 := dir2 + "/file"
+	err = ioutil.WriteFile(file2, nil, 0600)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	stop := false
+	defer func() { stop = true }()
+
+	var wg sync.WaitGroup
+	wg.Add(1)
+	go func() {
+		wg.Done()
+		for {
+			// Keep dir2 in the diriv cache
+			fd, err2 := os.Open(file2)
+			if err2 != nil {
+				fd.Close()
+			}
+			if stop {
+				return
+			}
+		}
+	}()
+	wg.Wait()
+	time.Sleep(time.Millisecond)
+
+	// Overwrite dir2 with dir1
+	err = syscall.Unlink(file2)
+	if err != nil {
+		t.Fatal(err)
+	}
+	err = syscall.Rename(dir1, dir2)
+	if err != nil {
+		t.Fatal(err)
+	}
+	// We should be able to stat file2
+	_, err = os.Stat(file2)
+	if err != nil {
+		t.Error(err)
+	}
+}
-- 
cgit v1.2.3