123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447 |
- // Copyright 2015 Google Inc. All Rights Reserved.
- //
- // Licensed under the Apache License, Version 2.0 (the "License");
- // you may not use this file except in compliance with the License.
- // You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing, software
- // distributed under the License is distributed on an "AS IS" BASIS,
- // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- // See the License for the specific language governing permissions and
- // limitations under the License.
- // Tests for the behavior of os.File objects on plain old posix file systems,
- // for use in verifying the intended behavior of memfs.
- package memfs_test
- import (
- "io"
- "io/ioutil"
- "os"
- "path"
- "runtime"
- "testing"
- "golang.org/x/net/context"
- "github.com/jacobsa/fuse/fusetesting"
- . "github.com/jacobsa/oglematchers"
- . "github.com/jacobsa/ogletest"
- )
- func TestPosix(t *testing.T) { RunTests(t) }
- ////////////////////////////////////////////////////////////////////////
- // Helpers
- ////////////////////////////////////////////////////////////////////////
- func getFileOffset(f *os.File) (offset int64, err error) {
- const relativeToCurrent = 1
- offset, err = f.Seek(0, relativeToCurrent)
- return
- }
- ////////////////////////////////////////////////////////////////////////
- // Boilerplate
- ////////////////////////////////////////////////////////////////////////
- type PosixTest struct {
- ctx context.Context
- // A temporary directory.
- dir string
- // Files to close when tearing down. Nil entries are skipped.
- toClose []io.Closer
- }
- var _ SetUpInterface = &PosixTest{}
- var _ TearDownInterface = &PosixTest{}
- func init() { RegisterTestSuite(&PosixTest{}) }
- func (t *PosixTest) SetUp(ti *TestInfo) {
- var err error
- t.ctx = ti.Ctx
- // Create a temporary directory.
- t.dir, err = ioutil.TempDir("", "posix_test")
- if err != nil {
- panic(err)
- }
- }
- func (t *PosixTest) TearDown() {
- // Close any files we opened.
- for _, c := range t.toClose {
- if c == nil {
- continue
- }
- err := c.Close()
- if err != nil {
- panic(err)
- }
- }
- // Remove the temporary directory.
- err := os.RemoveAll(t.dir)
- if err != nil {
- panic(err)
- }
- }
- ////////////////////////////////////////////////////////////////////////
- // Test functions
- ////////////////////////////////////////////////////////////////////////
- func (t *PosixTest) WriteOverlapsEndOfFile() {
- var err error
- var n int
- // Create a file.
- f, err := os.Create(path.Join(t.dir, "foo"))
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Make it 4 bytes long.
- err = f.Truncate(4)
- AssertEq(nil, err)
- // Write the range [2, 6).
- n, err = f.WriteAt([]byte("taco"), 2)
- AssertEq(nil, err)
- AssertEq(4, n)
- // Read the full contents of the file.
- contents, err := ioutil.ReadAll(f)
- AssertEq(nil, err)
- ExpectEq("\x00\x00taco", string(contents))
- }
- func (t *PosixTest) WriteStartsAtEndOfFile() {
- var err error
- var n int
- // Create a file.
- f, err := os.Create(path.Join(t.dir, "foo"))
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Make it 2 bytes long.
- err = f.Truncate(2)
- AssertEq(nil, err)
- // Write the range [2, 6).
- n, err = f.WriteAt([]byte("taco"), 2)
- AssertEq(nil, err)
- AssertEq(4, n)
- // Read the full contents of the file.
- contents, err := ioutil.ReadAll(f)
- AssertEq(nil, err)
- ExpectEq("\x00\x00taco", string(contents))
- }
- func (t *PosixTest) WriteStartsPastEndOfFile() {
- var err error
- var n int
- // Create a file.
- f, err := os.Create(path.Join(t.dir, "foo"))
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Write the range [2, 6).
- n, err = f.WriteAt([]byte("taco"), 2)
- AssertEq(nil, err)
- AssertEq(4, n)
- // Read the full contents of the file.
- contents, err := ioutil.ReadAll(f)
- AssertEq(nil, err)
- ExpectEq("\x00\x00taco", string(contents))
- }
- func (t *PosixTest) WriteStartsPastEndOfFile_AppendMode() {
- var err error
- var n int
- // Create a file.
- f, err := os.OpenFile(
- path.Join(t.dir, "foo"),
- os.O_RDWR|os.O_APPEND|os.O_CREATE,
- 0600)
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Write three bytes.
- n, err = f.Write([]byte("111"))
- AssertEq(nil, err)
- AssertEq(3, n)
- // Write at offset six.
- n, err = f.WriteAt([]byte("222"), 6)
- AssertEq(nil, err)
- AssertEq(3, n)
- // Read the full contents of the file.
- //
- // Linux's support for pwrite is buggy; the pwrite(2) man page says this:
- //
- // POSIX requires that opening a file with the O_APPEND flag should have
- // no affect on the location at which pwrite() writes data. However, on
- // Linux, if a file is opened with O_APPEND, pwrite() appends data to
- // the end of the file, regardless of the value of offset.
- //
- contents, err := ioutil.ReadFile(f.Name())
- AssertEq(nil, err)
- if runtime.GOOS == "linux" {
- ExpectEq("111222", string(contents))
- } else {
- ExpectEq("111\x00\x00\x00222", string(contents))
- }
- }
- func (t *PosixTest) WriteAtDoesntChangeOffset_NotAppendMode() {
- var err error
- var n int
- // Create a file.
- f, err := os.Create(path.Join(t.dir, "foo"))
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Make it 16 bytes long.
- err = f.Truncate(16)
- AssertEq(nil, err)
- // Seek to offset 4.
- _, err = f.Seek(4, 0)
- AssertEq(nil, err)
- // Write the range [10, 14).
- n, err = f.WriteAt([]byte("taco"), 2)
- AssertEq(nil, err)
- AssertEq(4, n)
- // We should still be at offset 4.
- offset, err := getFileOffset(f)
- AssertEq(nil, err)
- ExpectEq(4, offset)
- }
- func (t *PosixTest) WriteAtDoesntChangeOffset_AppendMode() {
- var err error
- var n int
- // Create a file in append mode.
- f, err := os.OpenFile(
- path.Join(t.dir, "foo"),
- os.O_RDWR|os.O_APPEND|os.O_CREATE,
- 0600)
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Make it 16 bytes long.
- err = f.Truncate(16)
- AssertEq(nil, err)
- // Seek to offset 4.
- _, err = f.Seek(4, 0)
- AssertEq(nil, err)
- // Write the range [10, 14).
- n, err = f.WriteAt([]byte("taco"), 2)
- AssertEq(nil, err)
- AssertEq(4, n)
- // We should still be at offset 4.
- offset, err := getFileOffset(f)
- AssertEq(nil, err)
- ExpectEq(4, offset)
- }
- func (t *PosixTest) AppendMode() {
- var err error
- var n int
- var off int64
- buf := make([]byte, 1024)
- // Create a file with some contents.
- fileName := path.Join(t.dir, "foo")
- err = ioutil.WriteFile(fileName, []byte("Jello, "), 0600)
- AssertEq(nil, err)
- // Open the file in append mode.
- f, err := os.OpenFile(fileName, os.O_RDWR|os.O_APPEND, 0600)
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Seek to somewhere silly and then write.
- off, err = f.Seek(2, 0)
- AssertEq(nil, err)
- AssertEq(2, off)
- n, err = f.Write([]byte("world!"))
- AssertEq(nil, err)
- AssertEq(6, n)
- // The offset should have been updated to point at the end of the file.
- off, err = getFileOffset(f)
- AssertEq(nil, err)
- ExpectEq(13, off)
- // A random write should still work, without updating the offset.
- n, err = f.WriteAt([]byte("H"), 0)
- AssertEq(nil, err)
- AssertEq(1, n)
- off, err = getFileOffset(f)
- AssertEq(nil, err)
- ExpectEq(13, off)
- // Read back the contents of the file, which should be correct even though we
- // seeked to a silly place before writing the world part.
- //
- // Linux's support for pwrite is buggy; the pwrite(2) man page says this:
- //
- // POSIX requires that opening a file with the O_APPEND flag should have
- // no affect on the location at which pwrite() writes data. However, on
- // Linux, if a file is opened with O_APPEND, pwrite() appends data to
- // the end of the file, regardless of the value of offset.
- //
- // So we allow either the POSIX result or the Linux result.
- n, err = f.ReadAt(buf, 0)
- AssertEq(io.EOF, err)
- if runtime.GOOS == "linux" {
- ExpectEq("Jello, world!H", string(buf[:n]))
- } else {
- ExpectEq("Hello, world!", string(buf[:n]))
- }
- }
- func (t *PosixTest) ReadsPastEndOfFile() {
- var err error
- var n int
- buf := make([]byte, 1024)
- // Create a file.
- f, err := os.Create(path.Join(t.dir, "foo"))
- t.toClose = append(t.toClose, f)
- AssertEq(nil, err)
- // Give it some contents.
- n, err = f.Write([]byte("taco"))
- AssertEq(nil, err)
- AssertEq(4, n)
- // Read a range overlapping EOF.
- n, err = f.ReadAt(buf[:4], 2)
- AssertEq(io.EOF, err)
- ExpectEq(2, n)
- ExpectEq("co", string(buf[:n]))
- // Read a range starting at EOF.
- n, err = f.ReadAt(buf[:4], 4)
- AssertEq(io.EOF, err)
- ExpectEq(0, n)
- ExpectEq("", string(buf[:n]))
- // Read a range starting past EOF.
- n, err = f.ReadAt(buf[:4], 100)
- AssertEq(io.EOF, err)
- ExpectEq(0, n)
- ExpectEq("", string(buf[:n]))
- }
- func (t *PosixTest) HardLinkDirectory() {
- dirName := path.Join(t.dir, "dir")
- // Create a directory.
- err := os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Attempt to hard-link it to a new name.
- err = os.Link(dirName, path.Join(t.dir, "other"))
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("link")))
- ExpectThat(err, Error(HasSubstr("not permitted")))
- }
- func (t *PosixTest) RmdirWhileOpenedForReading() {
- var err error
- // Create a directory.
- err = os.Mkdir(path.Join(t.dir, "dir"), 0700)
- AssertEq(nil, err)
- // Open the directory for reading.
- f, err := os.Open(path.Join(t.dir, "dir"))
- defer func() {
- if f != nil {
- ExpectEq(nil, f.Close())
- }
- }()
- AssertEq(nil, err)
- // Remove the directory.
- err = os.Remove(path.Join(t.dir, "dir"))
- AssertEq(nil, err)
- // Create a new directory, with the same name even, and add some contents
- // within it.
- err = os.MkdirAll(path.Join(t.dir, "dir/foo"), 0700)
- AssertEq(nil, err)
- err = os.MkdirAll(path.Join(t.dir, "dir/bar"), 0700)
- AssertEq(nil, err)
- err = os.MkdirAll(path.Join(t.dir, "dir/baz"), 0700)
- AssertEq(nil, err)
- // We should still be able to stat the open file handle.
- fi, err := f.Stat()
- ExpectEq("dir", fi.Name())
- // Attempt to read from the directory. This shouldn't see any junk from the
- // new directory. It should either succeed with an empty result or should
- // return ENOENT.
- names, err := f.Readdirnames(0)
- if err != nil {
- ExpectThat(err, Error(HasSubstr("no such file")))
- } else {
- ExpectThat(names, ElementsAre())
- }
- }
- func (t *PosixTest) CreateInParallel_NoTruncate() {
- fusetesting.RunCreateInParallelTest_NoTruncate(t.ctx, t.dir)
- }
- func (t *PosixTest) CreateInParallel_Truncate() {
- fusetesting.RunCreateInParallelTest_Truncate(t.ctx, t.dir)
- }
- func (t *PosixTest) CreateInParallel_Exclusive() {
- fusetesting.RunCreateInParallelTest_Exclusive(t.ctx, t.dir)
- }
- func (t *PosixTest) MkdirInParallel() {
- fusetesting.RunMkdirInParallelTest(t.ctx, t.dir)
- }
- func (t *PosixTest) SymlinkInParallel() {
- fusetesting.RunSymlinkInParallelTest(t.ctx, t.dir)
- }
|