From 85439be549b3a0e52ffd7f1bcb0c7f867a883101 Mon Sep 17 00:00:00 2001 From: Aaron Jacobs Date: Wed, 29 Jul 2015 14:51:33 +1000 Subject: [PATCH] InterruptFSTest.InterruptedDuringRead --- samples/interruptfs/interrupt_fs_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/samples/interruptfs/interrupt_fs_test.go b/samples/interruptfs/interrupt_fs_test.go index 5cf7f41..115b3a3 100644 --- a/samples/interruptfs/interrupt_fs_test.go +++ b/samples/interruptfs/interrupt_fs_test.go @@ -73,6 +73,7 @@ func (t *InterruptFSTest) StatFoo() { func (t *InterruptFSTest) InterruptedDuringRead() { var err error + t.fs.EnableReadBlocking() // Start a sub-process that attempts to read the file. cmd := exec.Command("cat", path.Join(t.Dir, "foo")) @@ -92,7 +93,7 @@ func (t *InterruptFSTest) InterruptedDuringRead() { }() // Wait for the read to make it to the file system. - t.fs.WaitForReadInFlight() + t.fs.WaitForFirstRead() // The command should be hanging on the read, and not yet have returned. select {