12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781 |
- // 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.
- package memfs_test
- import (
- "bytes"
- "io"
- "io/ioutil"
- "os"
- "os/user"
- "path"
- "runtime"
- "strconv"
- "syscall"
- "testing"
- "time"
- "github.com/jacobsa/fuse"
- "github.com/jacobsa/fuse/fusetesting"
- "github.com/jacobsa/fuse/samples"
- "github.com/jacobsa/fuse/samples/memfs"
- . "github.com/jacobsa/oglematchers"
- . "github.com/jacobsa/ogletest"
- "github.com/kahing/go-xattr"
- )
- func TestMemFS(t *testing.T) { RunTests(t) }
- // The radius we use for "expect mtime is within"-style assertions. We can't
- // share a synchronized clock with the ultimate source of mtimes because with
- // writeback caching enabled the kernel manufactures them based on wall time.
- const timeSlop = 25 * time.Millisecond
- ////////////////////////////////////////////////////////////////////////
- // Helpers
- ////////////////////////////////////////////////////////////////////////
- func currentUid() uint32 {
- user, err := user.Current()
- if err != nil {
- panic(err)
- }
- uid, err := strconv.ParseUint(user.Uid, 10, 32)
- if err != nil {
- panic(err)
- }
- return uint32(uid)
- }
- func currentGid() uint32 {
- user, err := user.Current()
- if err != nil {
- panic(err)
- }
- gid, err := strconv.ParseUint(user.Gid, 10, 32)
- if err != nil {
- panic(err)
- }
- return uint32(gid)
- }
- // Transform the supplied mode by the current umask.
- func applyUmask(m os.FileMode) os.FileMode {
- // HACK(jacobsa): Use umask(2) to change and restore the umask in order to
- // figure out what the mask is. See the listing in `man getumask`.
- umask := syscall.Umask(0)
- syscall.Umask(umask)
- // Apply it.
- return m &^ os.FileMode(umask)
- }
- ////////////////////////////////////////////////////////////////////////
- // Boilerplate
- ////////////////////////////////////////////////////////////////////////
- type memFSTest struct {
- samples.SampleTest
- }
- func (t *memFSTest) SetUp(ti *TestInfo) {
- t.Server = memfs.NewMemFS(currentUid(), currentGid())
- t.SampleTest.SetUp(ti)
- }
- ////////////////////////////////////////////////////////////////////////
- // Basics
- ////////////////////////////////////////////////////////////////////////
- type MemFSTest struct {
- memFSTest
- }
- func init() { RegisterTestSuite(&MemFSTest{}) }
- func (t *MemFSTest) ContentsOfEmptyFileSystem() {
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- }
- func (t *MemFSTest) Mkdir_OneLevel() {
- var err error
- var fi os.FileInfo
- var stat *syscall.Stat_t
- var entries []os.FileInfo
- dirName := path.Join(t.Dir, "dir")
- // Create a directory within the root.
- createTime := time.Now()
- err = os.Mkdir(dirName, 0754)
- AssertEq(nil, err)
- // Stat the directory.
- fi, err = os.Stat(dirName)
- stat = fi.Sys().(*syscall.Stat_t)
- AssertEq(nil, err)
- ExpectEq("dir", fi.Name())
- ExpectEq(0, fi.Size())
- ExpectEq(os.ModeDir|applyUmask(0754), fi.Mode())
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- ExpectThat(fi, fusetesting.BirthtimeIsWithin(createTime, timeSlop))
- ExpectTrue(fi.IsDir())
- ExpectNe(0, stat.Ino)
- ExpectEq(1, stat.Nlink)
- ExpectEq(currentUid(), stat.Uid)
- ExpectEq(currentGid(), stat.Gid)
- ExpectEq(0, stat.Size)
- // Check the root's mtime.
- fi, err = os.Stat(t.Dir)
- AssertEq(nil, err)
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- // Read the directory.
- entries, err = fusetesting.ReadDirPicky(dirName)
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- // Read the root.
- entries, err = fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq("dir", fi.Name())
- ExpectEq(os.ModeDir|applyUmask(0754), fi.Mode())
- }
- func (t *MemFSTest) Mkdir_TwoLevels() {
- var err error
- var fi os.FileInfo
- var stat *syscall.Stat_t
- var entries []os.FileInfo
- // Create a directory within the root.
- err = os.Mkdir(path.Join(t.Dir, "parent"), 0700)
- AssertEq(nil, err)
- // Create a child of that directory.
- createTime := time.Now()
- err = os.Mkdir(path.Join(t.Dir, "parent/dir"), 0754)
- AssertEq(nil, err)
- // Stat the directory.
- fi, err = os.Stat(path.Join(t.Dir, "parent/dir"))
- stat = fi.Sys().(*syscall.Stat_t)
- AssertEq(nil, err)
- ExpectEq("dir", fi.Name())
- ExpectEq(0, fi.Size())
- ExpectEq(os.ModeDir|applyUmask(0754), fi.Mode())
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- ExpectThat(fi, fusetesting.BirthtimeIsWithin(createTime, timeSlop))
- ExpectTrue(fi.IsDir())
- ExpectNe(0, stat.Ino)
- ExpectEq(1, stat.Nlink)
- ExpectEq(currentUid(), stat.Uid)
- ExpectEq(currentGid(), stat.Gid)
- ExpectEq(0, stat.Size)
- // Check the parent's mtime.
- fi, err = os.Stat(path.Join(t.Dir, "parent"))
- AssertEq(nil, err)
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- // Read the directory.
- entries, err = fusetesting.ReadDirPicky(path.Join(t.Dir, "parent/dir"))
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- // Read the parent.
- entries, err = fusetesting.ReadDirPicky(path.Join(t.Dir, "parent"))
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq("dir", fi.Name())
- ExpectEq(os.ModeDir|applyUmask(0754), fi.Mode())
- }
- func (t *MemFSTest) Mkdir_AlreadyExists() {
- var err error
- dirName := path.Join(t.Dir, "dir")
- // Create the directory once.
- err = os.Mkdir(dirName, 0754)
- AssertEq(nil, err)
- // Attempt to create it again.
- err = os.Mkdir(dirName, 0754)
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("exists")))
- }
- func (t *MemFSTest) Mkdir_IntermediateIsFile() {
- var err error
- // Create a file.
- fileName := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(fileName, []byte{}, 0700)
- AssertEq(nil, err)
- // Attempt to create a directory within the file.
- dirName := path.Join(fileName, "dir")
- err = os.Mkdir(dirName, 0754)
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("not a directory")))
- }
- func (t *MemFSTest) Mkdir_IntermediateIsNonExistent() {
- var err error
- // Attempt to create a sub-directory of a non-existent sub-directory.
- dirName := path.Join(t.Dir, "foo/dir")
- err = os.Mkdir(dirName, 0754)
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("no such file or directory")))
- }
- func (t *MemFSTest) Mkdir_PermissionDenied() {
- var err error
- // Create a directory within the root without write permissions.
- err = os.Mkdir(path.Join(t.Dir, "parent"), 0500)
- AssertEq(nil, err)
- // Attempt to create a child of that directory.
- err = os.Mkdir(path.Join(t.Dir, "parent/dir"), 0754)
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("permission denied")))
- }
- func (t *MemFSTest) CreateNewFile_InRoot() {
- var err error
- var fi os.FileInfo
- var stat *syscall.Stat_t
- // Write a file.
- fileName := path.Join(t.Dir, "foo")
- const contents = "Hello\x00world"
- createTime := time.Now()
- err = ioutil.WriteFile(fileName, []byte(contents), 0400)
- AssertEq(nil, err)
- // Stat it.
- fi, err = os.Stat(fileName)
- stat = fi.Sys().(*syscall.Stat_t)
- AssertEq(nil, err)
- ExpectEq("foo", fi.Name())
- ExpectEq(len(contents), fi.Size())
- ExpectEq(applyUmask(0400), fi.Mode())
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- ExpectThat(fi, fusetesting.BirthtimeIsWithin(createTime, timeSlop))
- ExpectFalse(fi.IsDir())
- ExpectNe(0, stat.Ino)
- ExpectEq(1, stat.Nlink)
- ExpectEq(currentUid(), stat.Uid)
- ExpectEq(currentGid(), stat.Gid)
- ExpectEq(len(contents), stat.Size)
- // Read it back.
- slice, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq(contents, string(slice))
- }
- func (t *MemFSTest) CreateNewFile_InSubDir() {
- var err error
- var fi os.FileInfo
- var stat *syscall.Stat_t
- // Create a sub-dir.
- dirName := path.Join(t.Dir, "dir")
- err = os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Write a file.
- fileName := path.Join(dirName, "foo")
- const contents = "Hello\x00world"
- createTime := time.Now()
- err = ioutil.WriteFile(fileName, []byte(contents), 0400)
- AssertEq(nil, err)
- // Stat it.
- fi, err = os.Stat(fileName)
- stat = fi.Sys().(*syscall.Stat_t)
- AssertEq(nil, err)
- ExpectEq("foo", fi.Name())
- ExpectEq(len(contents), fi.Size())
- ExpectEq(applyUmask(0400), fi.Mode())
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- ExpectThat(fi, fusetesting.BirthtimeIsWithin(createTime, timeSlop))
- ExpectFalse(fi.IsDir())
- ExpectNe(0, stat.Ino)
- ExpectEq(1, stat.Nlink)
- ExpectEq(currentUid(), stat.Uid)
- ExpectEq(currentGid(), stat.Gid)
- ExpectEq(len(contents), stat.Size)
- // Read it back.
- slice, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq(contents, string(slice))
- }
- func (t *MemFSTest) ModifyExistingFile_InRoot() {
- var err error
- var n int
- var fi os.FileInfo
- var stat *syscall.Stat_t
- // Write a file.
- fileName := path.Join(t.Dir, "foo")
- createTime := time.Now()
- err = ioutil.WriteFile(fileName, []byte("Hello, world!"), 0600)
- AssertEq(nil, err)
- // Open the file and modify it.
- f, err := os.OpenFile(fileName, os.O_WRONLY, 0400)
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- modifyTime := time.Now()
- n, err = f.WriteAt([]byte("H"), 0)
- AssertEq(nil, err)
- AssertEq(1, n)
- // Stat the file.
- fi, err = os.Stat(fileName)
- stat = fi.Sys().(*syscall.Stat_t)
- AssertEq(nil, err)
- ExpectEq("foo", fi.Name())
- ExpectEq(len("Hello, world!"), fi.Size())
- ExpectEq(applyUmask(0600), fi.Mode())
- ExpectThat(fi, fusetesting.MtimeIsWithin(modifyTime, timeSlop))
- ExpectThat(fi, fusetesting.BirthtimeIsWithin(createTime, timeSlop))
- ExpectFalse(fi.IsDir())
- ExpectNe(0, stat.Ino)
- ExpectEq(1, stat.Nlink)
- ExpectEq(currentUid(), stat.Uid)
- ExpectEq(currentGid(), stat.Gid)
- ExpectEq(len("Hello, world!"), stat.Size)
- // Read the file back.
- slice, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq("Hello, world!", string(slice))
- }
- func (t *MemFSTest) ModifyExistingFile_InSubDir() {
- var err error
- var n int
- var fi os.FileInfo
- var stat *syscall.Stat_t
- // Create a sub-directory.
- dirName := path.Join(t.Dir, "dir")
- err = os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Write a file.
- fileName := path.Join(dirName, "foo")
- createTime := time.Now()
- err = ioutil.WriteFile(fileName, []byte("Hello, world!"), 0600)
- AssertEq(nil, err)
- // Open the file and modify it.
- f, err := os.OpenFile(fileName, os.O_WRONLY, 0400)
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- modifyTime := time.Now()
- n, err = f.WriteAt([]byte("H"), 0)
- AssertEq(nil, err)
- AssertEq(1, n)
- // Stat the file.
- fi, err = os.Stat(fileName)
- stat = fi.Sys().(*syscall.Stat_t)
- AssertEq(nil, err)
- ExpectEq("foo", fi.Name())
- ExpectEq(len("Hello, world!"), fi.Size())
- ExpectEq(applyUmask(0600), fi.Mode())
- ExpectThat(fi, fusetesting.MtimeIsWithin(modifyTime, timeSlop))
- ExpectThat(fi, fusetesting.BirthtimeIsWithin(createTime, timeSlop))
- ExpectFalse(fi.IsDir())
- ExpectNe(0, stat.Ino)
- ExpectEq(1, stat.Nlink)
- ExpectEq(currentUid(), stat.Uid)
- ExpectEq(currentGid(), stat.Gid)
- ExpectEq(len("Hello, world!"), stat.Size)
- // Read the file back.
- slice, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq("Hello, world!", string(slice))
- }
- func (t *MemFSTest) UnlinkFile_Exists() {
- var err error
- // Write a file.
- fileName := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(fileName, []byte("Hello, world!"), 0600)
- AssertEq(nil, err)
- // Unlink it.
- err = os.Remove(fileName)
- AssertEq(nil, err)
- // Statting it should fail.
- _, err = os.Stat(fileName)
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("no such file")))
- // Nothing should be in the directory.
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- }
- func (t *MemFSTest) UnlinkFile_NonExistent() {
- err := os.Remove(path.Join(t.Dir, "foo"))
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("no such file")))
- }
- func (t *MemFSTest) UnlinkFile_StillOpen() {
- fileName := path.Join(t.Dir, "foo")
- // Create and open a file.
- f, err := os.OpenFile(fileName, os.O_RDWR|os.O_CREATE, 0600)
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- // Write some data into it.
- n, err := f.Write([]byte("taco"))
- AssertEq(nil, err)
- AssertEq(4, n)
- // Unlink it.
- err = os.Remove(fileName)
- AssertEq(nil, err)
- // The directory should no longer contain it.
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- // We should be able to stat the file. It should still show as having
- // contents, but with no links.
- fi, err := f.Stat()
- AssertEq(nil, err)
- ExpectEq(4, fi.Size())
- ExpectEq(0, fi.Sys().(*syscall.Stat_t).Nlink)
- // The contents should still be available.
- buf := make([]byte, 1024)
- n, err = f.ReadAt(buf, 0)
- AssertEq(io.EOF, err)
- AssertEq(4, n)
- ExpectEq("taco", string(buf[:4]))
- // Writing should still work, too.
- n, err = f.Write([]byte("burrito"))
- AssertEq(nil, err)
- AssertEq(len("burrito"), n)
- }
- func (t *MemFSTest) Rmdir_NonEmpty() {
- var err error
- // Create two levels of directories.
- err = os.MkdirAll(path.Join(t.Dir, "foo/bar"), 0754)
- AssertEq(nil, err)
- // Attempt to remove the parent.
- err = os.Remove(path.Join(t.Dir, "foo"))
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("not empty")))
- }
- func (t *MemFSTest) Rmdir_Empty() {
- var err error
- var entries []os.FileInfo
- // Create two levels of directories.
- err = os.MkdirAll(path.Join(t.Dir, "foo/bar"), 0754)
- AssertEq(nil, err)
- // Remove the leaf.
- rmTime := time.Now()
- err = os.Remove(path.Join(t.Dir, "foo/bar"))
- AssertEq(nil, err)
- // There should be nothing left in the parent.
- entries, err = fusetesting.ReadDirPicky(path.Join(t.Dir, "foo"))
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- // Check the parent's mtime.
- fi, err := os.Stat(path.Join(t.Dir, "foo"))
- AssertEq(nil, err)
- ExpectThat(fi, fusetesting.MtimeIsWithin(rmTime, timeSlop))
- // Remove the parent.
- err = os.Remove(path.Join(t.Dir, "foo"))
- AssertEq(nil, err)
- // Now the root directory should be empty, too.
- entries, err = fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- }
- func (t *MemFSTest) Rmdir_NonExistent() {
- err := os.Remove(path.Join(t.Dir, "blah"))
- AssertNe(nil, err)
- ExpectThat(err, Error(HasSubstr("no such file or directory")))
- }
- func (t *MemFSTest) Rmdir_OpenedForReading() {
- var err error
- // Create a directory.
- createTime := time.Now()
- 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. It should show up as
- // unlinked.
- fi, err := f.Stat()
- ExpectEq("dir", fi.Name())
- ExpectThat(fi, fusetesting.MtimeIsWithin(createTime, timeSlop))
- ExpectEq(0, fi.Sys().(*syscall.Stat_t).Nlink)
- // 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 *MemFSTest) CaseSensitive() {
- var err error
- // Create a file.
- err = ioutil.WriteFile(path.Join(t.Dir, "file"), []byte{}, 0400)
- AssertEq(nil, err)
- // Create a directory.
- err = os.Mkdir(path.Join(t.Dir, "dir"), 0400)
- AssertEq(nil, err)
- // Attempt to stat with the wrong case.
- names := []string{
- "FILE",
- "File",
- "filE",
- "DIR",
- "Dir",
- "dIr",
- }
- for _, name := range names {
- _, err = os.Stat(path.Join(t.Dir, name))
- AssertNe(nil, err, "Name: %s", name)
- AssertThat(err, Error(HasSubstr("no such file or directory")))
- }
- }
- func (t *MemFSTest) 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 *MemFSTest) 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 *MemFSTest) 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 *MemFSTest) 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 *MemFSTest) 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 *MemFSTest) LargeFile() {
- var err error
- // Create a file.
- f, err := os.Create(path.Join(t.Dir, "foo"))
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- // Copy in large contents.
- const size = 1 << 24
- contents := bytes.Repeat([]byte{0x20}, size)
- _, err = io.Copy(f, bytes.NewReader(contents))
- AssertEq(nil, err)
- // Read the full contents of the file.
- contents, err = ioutil.ReadFile(f.Name())
- AssertEq(nil, err)
- ExpectEq(size, len(contents))
- }
- func (t *MemFSTest) 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)
- ExpectThat(string(buf[:n]), AnyOf("Hello, world!", "Jello, world!H"))
- }
- func (t *MemFSTest) 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 *MemFSTest) Truncate_Smaller() {
- var err error
- fileName := path.Join(t.Dir, "foo")
- // Create a file.
- err = ioutil.WriteFile(fileName, []byte("taco"), 0600)
- AssertEq(nil, err)
- // Open it for modification.
- f, err := os.OpenFile(fileName, os.O_RDWR, 0)
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- // Truncate it.
- err = f.Truncate(2)
- AssertEq(nil, err)
- // Stat it.
- fi, err := f.Stat()
- AssertEq(nil, err)
- ExpectEq(2, fi.Size())
- // Read the contents.
- contents, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq("ta", string(contents))
- }
- func (t *MemFSTest) Truncate_SameSize() {
- var err error
- fileName := path.Join(t.Dir, "foo")
- // Create a file.
- err = ioutil.WriteFile(fileName, []byte("taco"), 0600)
- AssertEq(nil, err)
- // Open it for modification.
- f, err := os.OpenFile(fileName, os.O_RDWR, 0)
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- // Truncate it.
- err = f.Truncate(4)
- AssertEq(nil, err)
- // Stat it.
- fi, err := f.Stat()
- AssertEq(nil, err)
- ExpectEq(4, fi.Size())
- // Read the contents.
- contents, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq("taco", string(contents))
- }
- func (t *MemFSTest) Truncate_Larger() {
- var err error
- fileName := path.Join(t.Dir, "foo")
- // Create a file.
- err = ioutil.WriteFile(fileName, []byte("taco"), 0600)
- AssertEq(nil, err)
- // Open it for modification.
- f, err := os.OpenFile(fileName, os.O_RDWR, 0)
- t.ToClose = append(t.ToClose, f)
- AssertEq(nil, err)
- // Truncate it.
- err = f.Truncate(6)
- AssertEq(nil, err)
- // Stat it.
- fi, err := f.Stat()
- AssertEq(nil, err)
- ExpectEq(6, fi.Size())
- // Read the contents.
- contents, err := ioutil.ReadFile(fileName)
- AssertEq(nil, err)
- ExpectEq("taco\x00\x00", string(contents))
- }
- func (t *MemFSTest) Chmod() {
- var err error
- fileName := path.Join(t.Dir, "foo")
- // Create a file.
- err = ioutil.WriteFile(fileName, []byte(""), 0600)
- AssertEq(nil, err)
- // Chmod it.
- err = os.Chmod(fileName, 0754)
- AssertEq(nil, err)
- // Stat it.
- fi, err := os.Stat(fileName)
- AssertEq(nil, err)
- ExpectEq(0754, fi.Mode())
- }
- func (t *MemFSTest) Chtimes() {
- var err error
- fileName := path.Join(t.Dir, "foo")
- // Create a file.
- err = ioutil.WriteFile(fileName, []byte(""), 0600)
- AssertEq(nil, err)
- // Chtimes it.
- expectedMtime := time.Now().Add(123 * time.Second).Round(time.Second)
- err = os.Chtimes(fileName, time.Now(), expectedMtime)
- AssertEq(nil, err)
- // Stat it.
- fi, err := os.Stat(fileName)
- AssertEq(nil, err)
- ExpectThat(fi, fusetesting.MtimeIsWithin(expectedMtime, timeSlop))
- }
- func (t *MemFSTest) ReadDirWhileModifying() {
- dirName := path.Join(t.Dir, "dir")
- createFile := func(name string) {
- AssertEq(nil, ioutil.WriteFile(path.Join(dirName, name), []byte{}, 0400))
- }
- // Create a directory.
- err := os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Open the directory.
- d, err := os.Open(dirName)
- t.ToClose = append(t.ToClose, d)
- AssertEq(nil, err)
- // Add four files.
- createFile("foo")
- createFile("bar")
- createFile("baz")
- createFile("qux")
- // Read one entry from the directory.
- names, err := d.Readdirnames(1)
- AssertEq(nil, err)
- AssertThat(names, ElementsAre("foo"))
- // Make two holes in the directory.
- AssertEq(nil, os.Remove(path.Join(dirName, "foo")))
- AssertEq(nil, os.Remove(path.Join(dirName, "baz")))
- // Add a bunch of files to the directory.
- createFile("blah_0")
- createFile("blah_1")
- createFile("blah_2")
- createFile("blah_3")
- createFile("blah_4")
- // Continue reading from the directory, noting the names we see.
- namesSeen := make(map[string]bool)
- for {
- names, err = d.Readdirnames(1)
- for _, n := range names {
- namesSeen[n] = true
- }
- if err == io.EOF {
- break
- }
- AssertEq(nil, err)
- }
- // Posix requires that we should have seen bar and qux, which we didn't
- // delete.
- ExpectTrue(namesSeen["bar"])
- ExpectTrue(namesSeen["qux"])
- }
- func (t *MemFSTest) HardLinks() {
- var err error
- // Create a file and a directory.
- fileName := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(fileName, []byte{}, 0400)
- AssertEq(nil, err)
- dirName := path.Join(t.Dir, "bar")
- err = os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Attempt to link each. Neither should work, but for different reasons.
- err = os.Link(fileName, path.Join(t.Dir, "baz"))
- ExpectThat(err, Error(HasSubstr("not implemented")))
- err = os.Link(dirName, path.Join(t.Dir, "baz"))
- ExpectThat(err, Error(HasSubstr("not permitted")))
- }
- func (t *MemFSTest) CreateSymlink() {
- var fi os.FileInfo
- var err error
- symlinkName := path.Join(t.Dir, "foo")
- target := "taco/burrito"
- // Create the link.
- err = os.Symlink(target, symlinkName)
- AssertEq(nil, err)
- // Stat the link.
- fi, err = os.Lstat(symlinkName)
- AssertEq(nil, err)
- ExpectEq("foo", fi.Name())
- ExpectEq(0444|os.ModeSymlink, fi.Mode())
- // Read the link.
- actual, err := os.Readlink(symlinkName)
- AssertEq(nil, err)
- ExpectEq(target, actual)
- // Read the parent directory.
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq("foo", fi.Name())
- ExpectEq(0444|os.ModeSymlink, fi.Mode())
- }
- func (t *MemFSTest) CreateSymlink_AlreadyExists() {
- var err error
- // Create a file and a directory.
- fileName := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(fileName, []byte{}, 0400)
- AssertEq(nil, err)
- dirName := path.Join(t.Dir, "bar")
- err = os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Create an existing symlink.
- symlinkName := path.Join(t.Dir, "baz")
- err = os.Symlink("blah", symlinkName)
- AssertEq(nil, err)
- // Symlinking on top of any of them should fail.
- names := []string{
- fileName,
- dirName,
- symlinkName,
- }
- for _, n := range names {
- err = os.Symlink("blah", n)
- ExpectThat(err, Error(HasSubstr("exists")))
- }
- }
- func (t *MemFSTest) ReadLink_NonExistent() {
- _, err := os.Readlink(path.Join(t.Dir, "foo"))
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- }
- func (t *MemFSTest) ReadLink_NotASymlink() {
- var err error
- // Create a file and a directory.
- fileName := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(fileName, []byte{}, 0400)
- AssertEq(nil, err)
- dirName := path.Join(t.Dir, "bar")
- err = os.Mkdir(dirName, 0700)
- AssertEq(nil, err)
- // Reading either of them as a symlink should fail.
- names := []string{
- fileName,
- dirName,
- }
- for _, n := range names {
- _, err = os.Readlink(n)
- ExpectThat(err, Error(HasSubstr("invalid argument")))
- }
- }
- func (t *MemFSTest) DeleteSymlink() {
- var err error
- symlinkName := path.Join(t.Dir, "foo")
- target := "taco/burrito"
- // Create the link.
- err = os.Symlink(target, symlinkName)
- AssertEq(nil, err)
- // Remove it.
- err = os.Remove(symlinkName)
- AssertEq(nil, err)
- // Statting should now fail.
- _, err = os.Lstat(symlinkName)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- // Read the parent directory.
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- ExpectThat(entries, ElementsAre())
- }
- func (t *MemFSTest) CreateInParallel_NoTruncate() {
- fusetesting.RunCreateInParallelTest_NoTruncate(t.Ctx, t.Dir)
- }
- func (t *MemFSTest) CreateInParallel_Truncate() {
- fusetesting.RunCreateInParallelTest_Truncate(t.Ctx, t.Dir)
- }
- func (t *MemFSTest) CreateInParallel_Exclusive() {
- fusetesting.RunCreateInParallelTest_Exclusive(t.Ctx, t.Dir)
- }
- func (t *MemFSTest) MkdirInParallel() {
- fusetesting.RunMkdirInParallelTest(t.Ctx, t.Dir)
- }
- func (t *MemFSTest) SymlinkInParallel() {
- fusetesting.RunSymlinkInParallelTest(t.Ctx, t.Dir)
- }
- func (t *MemFSTest) RenameWithinDir_File() {
- var err error
- // Create a parent directory.
- parentPath := path.Join(t.Dir, "parent")
- err = os.Mkdir(parentPath, 0700)
- AssertEq(nil, err)
- // And a file within it.
- oldPath := path.Join(parentPath, "foo")
- err = ioutil.WriteFile(oldPath, []byte("taco"), 0400)
- AssertEq(nil, err)
- // Rename it.
- newPath := path.Join(parentPath, "bar")
- err = os.Rename(oldPath, newPath)
- AssertEq(nil, err)
- // The old name shouldn't work.
- _, err = os.Stat(oldPath)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- _, err = ioutil.ReadFile(oldPath)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- // The new name should.
- fi, err := os.Stat(newPath)
- AssertEq(nil, err)
- ExpectEq(len("taco"), fi.Size())
- ExpectEq(os.FileMode(0400), fi.Mode())
- contents, err := ioutil.ReadFile(newPath)
- AssertEq(nil, err)
- ExpectEq("taco", string(contents))
- // There should only be the new entry in the directory.
- entries, err := fusetesting.ReadDirPicky(parentPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq(path.Base(newPath), fi.Name())
- ExpectEq(os.FileMode(0400), fi.Mode())
- }
- func (t *MemFSTest) RenameWithinDir_Directory() {
- var err error
- // Create a parent directory.
- parentPath := path.Join(t.Dir, "parent")
- err = os.Mkdir(parentPath, 0700)
- AssertEq(nil, err)
- // And a non-empty directory within it.
- oldPath := path.Join(parentPath, "foo")
- err = os.MkdirAll(path.Join(oldPath, "child"), 0700)
- AssertEq(nil, err)
- // Rename it.
- newPath := path.Join(parentPath, "bar")
- err = os.Rename(oldPath, newPath)
- AssertEq(nil, err)
- // The old name shouldn't work.
- _, err = os.Stat(oldPath)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- // The new name should.
- fi, err := os.Stat(newPath)
- AssertEq(nil, err)
- ExpectEq(os.FileMode(0700)|os.ModeDir, fi.Mode())
- // There should only be the new entry in the parent.
- entries, err := fusetesting.ReadDirPicky(parentPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq(path.Base(newPath), fi.Name())
- ExpectEq(os.FileMode(0700)|os.ModeDir, fi.Mode())
- // And the child should still be present.
- entries, err = fusetesting.ReadDirPicky(newPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq("child", fi.Name())
- ExpectEq(os.FileMode(0700)|os.ModeDir, fi.Mode())
- }
- func (t *MemFSTest) RenameWithinDir_SameName() {
- var err error
- // Create a parent directory.
- parentPath := path.Join(t.Dir, "parent")
- err = os.Mkdir(parentPath, 0700)
- AssertEq(nil, err)
- // And a file within it.
- filePath := path.Join(parentPath, "foo")
- err = ioutil.WriteFile(filePath, []byte("taco"), 0400)
- AssertEq(nil, err)
- // Attempt to rename it.
- err = os.Rename(filePath, filePath)
- AssertEq(nil, err)
- // The file should still exist.
- contents, err := ioutil.ReadFile(filePath)
- AssertEq(nil, err)
- ExpectEq("taco", string(contents))
- // There should only be the one entry in the directory.
- entries, err := fusetesting.ReadDirPicky(parentPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi := entries[0]
- ExpectEq(path.Base(filePath), fi.Name())
- ExpectEq(os.FileMode(0400), fi.Mode())
- }
- func (t *MemFSTest) RenameAcrossDirs_File() {
- var err error
- // Create two parent directories.
- oldParentPath := path.Join(t.Dir, "old")
- newParentPath := path.Join(t.Dir, "new")
- err = os.Mkdir(oldParentPath, 0700)
- AssertEq(nil, err)
- err = os.Mkdir(newParentPath, 0700)
- AssertEq(nil, err)
- // And a file within the first.
- oldPath := path.Join(oldParentPath, "foo")
- err = ioutil.WriteFile(oldPath, []byte("taco"), 0400)
- AssertEq(nil, err)
- // Rename it.
- newPath := path.Join(newParentPath, "bar")
- err = os.Rename(oldPath, newPath)
- AssertEq(nil, err)
- // The old name shouldn't work.
- _, err = os.Stat(oldPath)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- _, err = ioutil.ReadFile(oldPath)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- // The new name should.
- fi, err := os.Stat(newPath)
- AssertEq(nil, err)
- ExpectEq(len("taco"), fi.Size())
- ExpectEq(os.FileMode(0400), fi.Mode())
- contents, err := ioutil.ReadFile(newPath)
- AssertEq(nil, err)
- ExpectEq("taco", string(contents))
- // Check the old parent.
- entries, err := fusetesting.ReadDirPicky(oldParentPath)
- AssertEq(nil, err)
- AssertEq(0, len(entries))
- // And the new one.
- entries, err = fusetesting.ReadDirPicky(newParentPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq(path.Base(newPath), fi.Name())
- ExpectEq(os.FileMode(0400), fi.Mode())
- }
- func (t *MemFSTest) RenameAcrossDirs_Directory() {
- var err error
- // Create two parent directories.
- oldParentPath := path.Join(t.Dir, "old")
- newParentPath := path.Join(t.Dir, "new")
- err = os.Mkdir(oldParentPath, 0700)
- AssertEq(nil, err)
- err = os.Mkdir(newParentPath, 0700)
- AssertEq(nil, err)
- // And a non-empty directory within the first.
- oldPath := path.Join(oldParentPath, "foo")
- err = os.MkdirAll(path.Join(oldPath, "child"), 0700)
- AssertEq(nil, err)
- // Rename it.
- newPath := path.Join(newParentPath, "bar")
- err = os.Rename(oldPath, newPath)
- AssertEq(nil, err)
- // The old name shouldn't work.
- _, err = os.Stat(oldPath)
- ExpectTrue(os.IsNotExist(err), "err: %v", err)
- // The new name should.
- fi, err := os.Stat(newPath)
- AssertEq(nil, err)
- ExpectEq(os.FileMode(0700)|os.ModeDir, fi.Mode())
- // And the child should still be present.
- entries, err := fusetesting.ReadDirPicky(newPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq("child", fi.Name())
- ExpectEq(os.FileMode(0700)|os.ModeDir, fi.Mode())
- // Check the old parent.
- entries, err = fusetesting.ReadDirPicky(oldParentPath)
- AssertEq(nil, err)
- AssertEq(0, len(entries))
- // And the new one.
- entries, err = fusetesting.ReadDirPicky(newParentPath)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi = entries[0]
- ExpectEq(path.Base(newPath), fi.Name())
- ExpectEq(os.FileMode(0700)|os.ModeDir, fi.Mode())
- }
- func (t *MemFSTest) RenameOutOfFileSystem() {
- var err error
- // Create a file.
- oldPath := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(oldPath, []byte("taco"), 0400)
- AssertEq(nil, err)
- // Attempt to move it out of the file system.
- tempDir, err := ioutil.TempDir("", "memfs_test")
- AssertEq(nil, err)
- defer os.RemoveAll(tempDir)
- err = os.Rename(oldPath, path.Join(tempDir, "bar"))
- ExpectThat(err, Error(HasSubstr("cross-device")))
- }
- func (t *MemFSTest) RenameIntoFileSystem() {
- var err error
- // Create a file outside of our file system.
- f, err := ioutil.TempFile("", "memfs_test")
- AssertEq(nil, err)
- defer f.Close()
- oldPath := f.Name()
- defer os.Remove(oldPath)
- // Attempt to move it into the file system.
- err = os.Rename(oldPath, path.Join(t.Dir, "bar"))
- ExpectThat(err, Error(HasSubstr("cross-device")))
- }
- func (t *MemFSTest) RenameOverExistingFile() {
- var err error
- // Create two files.
- oldPath := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(oldPath, []byte("taco"), 0400)
- AssertEq(nil, err)
- newPath := path.Join(t.Dir, "bar")
- err = ioutil.WriteFile(newPath, []byte("burrito"), 0600)
- AssertEq(nil, err)
- // Rename one over the other.
- err = os.Rename(oldPath, newPath)
- AssertEq(nil, err)
- // Check the file contents.
- contents, err := ioutil.ReadFile(newPath)
- AssertEq(nil, err)
- ExpectEq("taco", string(contents))
- // And the parent listing.
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- AssertEq(1, len(entries))
- fi := entries[0]
- ExpectEq(path.Base(newPath), fi.Name())
- ExpectEq(os.FileMode(0400), fi.Mode())
- ExpectEq(len("taco"), fi.Size())
- }
- func (t *MemFSTest) RenameOverExistingDirectory() {
- var err error
- // Create two directories, the first non-empty.
- oldPath := path.Join(t.Dir, "foo")
- err = os.MkdirAll(path.Join(oldPath, "child"), 0700)
- AssertEq(nil, err)
- newPath := path.Join(t.Dir, "bar")
- err = os.Mkdir(newPath, 0600)
- AssertEq(nil, err)
- // Renaming over the non-empty directory shouldn't work.
- err = os.Rename(newPath, oldPath)
- ExpectThat(err, Error(MatchesRegexp("not empty|file exists")))
- // As of Go 1.8 this shouldn't work the other way around either (see
- // https://github.com/golang/go/commit/321c312).
- if atLeastGo18 {
- err = os.Rename(oldPath, newPath)
- ExpectThat(err, Error(HasSubstr("file exists")))
- // Both should still be present in the parent listing.
- entries, err := fusetesting.ReadDirPicky(t.Dir)
- AssertEq(nil, err)
- ExpectEq(2, len(entries))
- }
- }
- func (t *MemFSTest) RenameOverExisting_WrongType() {
- var err error
- // Create a file and a directory.
- filePath := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(filePath, []byte("taco"), 0400)
- AssertEq(nil, err)
- dirPath := path.Join(t.Dir, "bar")
- err = os.Mkdir(dirPath, 0700)
- AssertEq(nil, err)
- // Renaming either over the other shouldn't work.
- err = os.Rename(filePath, dirPath)
- ExpectThat(err, Error(MatchesRegexp("is a directory|file exists")))
- err = os.Rename(dirPath, filePath)
- ExpectThat(err, Error(HasSubstr("not a directory")))
- }
- func (t *MemFSTest) RenameNonExistentFile() {
- var err error
- err = os.Rename(path.Join(t.Dir, "foo"), path.Join(t.Dir, "bar"))
- ExpectThat(err, Error(HasSubstr("no such file")))
- }
- func (t *MemFSTest) NoXattrs() {
- var err error
- // Create a file.
- filePath := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(filePath, []byte("taco"), 0400)
- AssertEq(nil, err)
- // List xattr names.
- names, err := xattr.List(filePath)
- AssertEq(nil, err)
- ExpectThat(names, ElementsAre())
- // Attempt to read a non-existent xattr.
- _, err = xattr.Getxattr(filePath, "foo", nil)
- ExpectEq(fuse.ENOATTR, err)
- }
- func (t *MemFSTest) SetXAttr() {
- var err error
- // Create a file.
- filePath := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(filePath, []byte("taco"), 0600)
- AssertEq(nil, err)
- err = xattr.Setxattr(filePath, "foo", []byte("bar"), xattr.REPLACE)
- AssertEq(fuse.ENOATTR, err)
- err = xattr.Setxattr(filePath, "foo", []byte("bar"), xattr.CREATE)
- AssertEq(nil, err)
- value, err := xattr.Get(filePath, "foo")
- AssertEq(nil, err)
- AssertEq("bar", string(value))
- err = xattr.Setxattr(filePath, "foo", []byte("hello world"), xattr.REPLACE)
- AssertEq(nil, err)
- value, err = xattr.Get(filePath, "foo")
- AssertEq(nil, err)
- AssertEq("hello world", string(value))
- names, err := xattr.List(filePath)
- AssertEq(nil, err)
- AssertEq(1, len(names))
- AssertEq("foo", names[0])
- err = xattr.Setxattr(filePath, "bar", []byte("hello world"), 0x0)
- AssertEq(nil, err)
- names, err = xattr.List(filePath)
- AssertEq(nil, err)
- AssertEq(2, len(names))
- ExpectThat(names, Contains("foo"))
- ExpectThat(names, Contains("bar"))
- }
- func (t *MemFSTest) RemoveXAttr() {
- var err error
- // Create a file
- filePath := path.Join(t.Dir, "foo")
- err = ioutil.WriteFile(filePath, []byte("taco"), 0600)
- AssertEq(nil, err)
- err = xattr.Removexattr(filePath, "foo")
- AssertEq(fuse.ENOATTR, err)
- err = xattr.Setxattr(filePath, "foo", []byte("bar"), xattr.CREATE)
- AssertEq(nil, err)
- err = xattr.Removexattr(filePath, "foo")
- AssertEq(nil, err)
- _, err = xattr.Getxattr(filePath, "foo", nil)
- AssertEq(fuse.ENOATTR, err)
- }
- ////////////////////////////////////////////////////////////////////////
- // Mknod
- ////////////////////////////////////////////////////////////////////////
- type MknodTest struct {
- memFSTest
- }
- func init() { RegisterTestSuite(&MknodTest{}) }
- func (t *MknodTest) File() {
- // mknod(2) only works for root on OS X.
- if runtime.GOOS == "darwin" {
- return
- }
- var err error
- p := path.Join(t.Dir, "foo")
- // Create
- err = syscall.Mknod(p, syscall.S_IFREG|0641, 0)
- AssertEq(nil, err)
- // Stat
- fi, err := os.Stat(p)
- AssertEq(nil, err)
- ExpectEq(path.Base(p), fi.Name())
- ExpectEq(0, fi.Size())
- ExpectEq(os.FileMode(0641), fi.Mode())
- // Read
- contents, err := ioutil.ReadFile(p)
- AssertEq(nil, err)
- ExpectEq("", string(contents))
- }
- func (t *MknodTest) Directory() {
- // mknod(2) only works for root on OS X.
- if runtime.GOOS == "darwin" {
- return
- }
- var err error
- p := path.Join(t.Dir, "foo")
- // Quoth `man 2 mknod`: "Under Linux, this call cannot be used to create
- // directories."
- err = syscall.Mknod(p, syscall.S_IFDIR|0700, 0)
- ExpectEq(syscall.EPERM, err)
- }
- func (t *MknodTest) AlreadyExists() {
- // mknod(2) only works for root on OS X.
- if runtime.GOOS == "darwin" {
- return
- }
- var err error
- p := path.Join(t.Dir, "foo")
- // Create (first)
- err = ioutil.WriteFile(p, []byte("taco"), 0600)
- AssertEq(nil, err)
- // Create (second)
- err = syscall.Mknod(p, syscall.S_IFREG|0600, 0)
- ExpectEq(syscall.EEXIST, err)
- // Read
- contents, err := ioutil.ReadFile(p)
- AssertEq(nil, err)
- ExpectEq("taco", string(contents))
- }
- func (t *MknodTest) NonExistentParent() {
- // mknod(2) only works for root on OS X.
- if runtime.GOOS == "darwin" {
- return
- }
- var err error
- p := path.Join(t.Dir, "foo/bar")
- err = syscall.Mknod(p, syscall.S_IFREG|0600, 0)
- ExpectEq(syscall.ENOENT, err)
- }
|