X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/f6b78bb3d0769199c811da40367afd4d9bded914..312bc8bb5bb01f8dc3fbf98a98a5de402172ba88:/sdk/go/arvados/fs_deferred.go diff --git a/sdk/go/arvados/fs_deferred.go b/sdk/go/arvados/fs_deferred.go index bb6c7a2626..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, @@ -113,3 +79,5 @@ func (dn *deferrednode) RUnlock() { dn.realinode().RUnloc 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) }