summaryrefslogtreecommitdiffhomepage
path: root/pkg/sentry/fs/file.go
diff options
context:
space:
mode:
authorIan Gudger <igudger@google.com>2018-10-03 17:02:05 -0700
committerShentubot <shentubot@google.com>2018-10-03 17:03:09 -0700
commit4fef31f96c289d5e58c3c2997ee38fcb22c0378f (patch)
treecc05ab5e2841ff987e126095657db94a1492d12b /pkg/sentry/fs/file.go
parent9f2ba6ac3e7b56d428ef4369a7326dd85f30642d (diff)
Add S/R support for FIOASYNC
PiperOrigin-RevId: 215655197 Change-Id: I668b1bc7c29daaf2999f8f759138bcbb09c4de6f
Diffstat (limited to 'pkg/sentry/fs/file.go')
-rw-r--r--pkg/sentry/fs/file.go10
1 files changed, 9 insertions, 1 deletions
diff --git a/pkg/sentry/fs/file.go b/pkg/sentry/fs/file.go
index 904827a3e..36794d378 100644
--- a/pkg/sentry/fs/file.go
+++ b/pkg/sentry/fs/file.go
@@ -85,6 +85,9 @@ type File struct {
// async handles O_ASYNC notifications.
async FileAsync
+ // saving indicates that this file is in the process of being saved.
+ saving bool `state:"nosave"`
+
// mu is dual-purpose: first, to make read(2) and write(2) thread-safe
// in conformity with POSIX, and second, to cancel operations before they
// begin in response to interruptions (i.e. signals).
@@ -127,10 +130,15 @@ func (f *File) DecRef() {
// Release a reference on the Dirent.
f.Dirent.DecRef()
+ // Only unregister if we are currently registered. There is nothing
+ // to register if f.async is nil (this happens when async mode is
+ // enabled without setting an owner). Also, we unregister during
+ // save.
f.flagsMu.Lock()
- if f.flags.Async && f.async != nil {
+ if !f.saving && f.flags.Async && f.async != nil {
f.async.Unregister(f)
}
+ f.async = nil
f.flagsMu.Unlock()
})
}