X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1e4630ddb8015d72978aae1be334cce2f8ca20d4..8fbe20476e2d10b1fc8dac848b2a0ffdf488a082:/sdk/go/arvados/fs_deferred.go?ds=sidebyside diff --git a/sdk/go/arvados/fs_deferred.go b/sdk/go/arvados/fs_deferred.go index 254b90c812..e85446098f 100644 --- a/sdk/go/arvados/fs_deferred.go +++ b/sdk/go/arvados/fs_deferred.go @@ -5,44 +5,10 @@ package arvados import ( - "log" "os" "sync" - "time" ) -func deferredCollectionFS(fs FileSystem, parent inode, coll Collection) inode { - modTime := coll.ModifiedAt - if modTime.IsZero() { - modTime = time.Now() - } - placeholder := &treenode{ - fs: fs, - parent: parent, - inodes: nil, - fileinfo: fileinfo{ - name: coll.Name, - modTime: modTime, - mode: 0755 | os.ModeDir, - }, - } - return &deferrednode{wrapped: placeholder, create: func() inode { - err := fs.RequestAndDecode(&coll, "GET", "arvados/v1/collections/"+coll.UUID, nil, nil) - if err != nil { - log.Printf("BUG: unhandled error: %s", err) - return placeholder - } - newfs, err := coll.FileSystem(fs, fs) - if err != nil { - log.Printf("BUG: unhandled error: %s", err) - return placeholder - } - cfs := newfs.(*collectionFileSystem) - cfs.SetParent(parent, coll.Name) - return cfs - }} -} - // A deferrednode wraps an inode that's expensive to build. Initially, // it responds to basic directory functions by proxying to the given // placeholder. If a caller uses a read/write/lock operation, @@ -112,3 +78,6 @@ func (dn *deferrednode) RLock() { dn.realinode().RLock( func (dn *deferrednode) RUnlock() { dn.realinode().RUnlock() } func (dn *deferrednode) FS() FileSystem { return dn.currentinode().FS() } func (dn *deferrednode) Parent() inode { return dn.currentinode().Parent() } +func (dn *deferrednode) MemorySize() int64 { return dn.currentinode().MemorySize() } +func (dn *deferrednode) Snapshot() (inode, error) { return dn.realinode().Snapshot() } +func (dn *deferrednode) Splice(repl inode) error { return dn.realinode().Splice(repl) }