Signal in flight.
parent
0b00132020
commit
be24b2b3e3
|
@ -142,6 +142,12 @@ func (fs *InterruptFS) ReadFile(
|
||||||
var err error
|
var err error
|
||||||
defer fuseutil.RespondToOp(op, &err)
|
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.
|
// Wait for cancellation.
|
||||||
done := op.Context().Done()
|
done := op.Context().Done()
|
||||||
if done == nil {
|
if done == nil {
|
||||||
|
|
Loading…
Reference in New Issue