From be24b2b3e3fdec1540885e69157fdfc2a6711ede Mon Sep 17 00:00:00 2001 From: Aaron Jacobs Date: Mon, 4 May 2015 22:00:24 +1000 Subject: [PATCH] Signal in flight. --- samples/interruptfs/interrupt_fs.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/samples/interruptfs/interrupt_fs.go b/samples/interruptfs/interrupt_fs.go index 2229bf3..62554d1 100644 --- a/samples/interruptfs/interrupt_fs.go +++ b/samples/interruptfs/interrupt_fs.go @@ -142,6 +142,12 @@ func (fs *InterruptFS) ReadFile( var err error defer fuseutil.RespondToOp(op, &err) + // Signal that a read has been received. + fs.mu.Lock() + fs.readInFlight = true + fs.readInFlightChanged.Broadcast() + fs.mu.Unlock() + // Wait for cancellation. done := op.Context().Done() if done == nil {