Home
last modified time | relevance | path

Searched refs:srcFs (Results 1 – 25 of 72) sorted by relevance

123

/dports/x11-fm/wcmcommander/WCMCommander-release-0.20.0/src/
H A Dfileopers.cpp331 clPtr<FS> srcFs; //??volatile member in OperCFData
477 clPtr<FS> fs = data->srcFs; in MkDirThreadFunc()
513 dlg.threadData.srcFs = f; in MkDir()
681 clPtr<FS> fs = data->srcFs; in DeleteThreadFunc()
721 dlg.threadData.srcFs = f; in DeleteList()
1435 srcFs->Close( in, 0, Info() ); in CopyFile()
1651 clPtr<FS> srcFs = data->srcFs; in CopyThreadFunc() local
1698 dlg.threadData.srcFs = srcFs; in CopyFiles()
1727 if ( srcFs != destFs && !srcFs->Equal( destFs ) ) { return 1; } in MoveFile()
1986 clPtr<FS> srcFs = data->srcFs; in MoveThreadFunc() local
[all …]
H A Dfile-util.cpp255 …LoadFileDataThreadData( NCDialogParent* p, clPtr<FS>& srcFs, FSPath& srcPath, clPtr<FS>& dstFs, FS… in LoadFileDataThreadData() argument
257 , m_SrcFs( srcFs ) in LoadFileDataThreadData()
287 clPtr<FS>& srcFs = Data->m_SrcFs; in Run() local
299 in = srcFs->OpenRead( srcPath, FS::SHARE_READ, &ret_error, Info() ); in Run()
302 throw_msg( "%s", srcFs->StrError( ret_error ).GetUtf8() ); in Run()
325 const int n = srcFs->Read( in, buf, sizeof( buf ), &ret_error, Info() ); in Run()
328 throw_msg( "Can't load file:\n%s", srcFs->StrError( ret_error ).GetUtf8() ); in Run()
352 srcFs->Close( in, 0, Info() ); in Run()
362 srcFs->Close( in, 0, Info() ); in Run()
422 …LoadFileDataThreadDlg( NCDialogParent* parent, clPtr<FS>& srcFs, FSPath& srcPath, clPtr<FS>& dstFs… in LoadFileDataThreadDlg() argument
[all …]
H A Dfileopers.h84 clPtr<cstrhash<bool, unicode_t> > CopyFiles( clPtr<FS> srcFs, FSPath& srcPath, clPtr<FSList> list, …
85 bool MoveFiles( clPtr<FS> srcFs, FSPath& srcPath, clPtr<FSList> list, clPtr<FS> destFs, FSPath& des…
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/fs/
H A DFsShell.java220 return srcFs; in getSrcFileSystem()
357 printToStdout(srcFs.open(p)); in cat()
424 if (srcFs.isDirectory(p)) { in text()
667 (!srcFs.exists(srcPath)))){ in du()
729 if (!srcFs.mkdirs(f)) { in mkdir()
744 if (srcFs.exists(f)) { in touchz()
745 st = srcFs.getFileStatus(f); in touchz()
847 URI srcURI = srcFs.getUri(); in rename()
1089 if (srcFs.delete(src, true)) { in delete()
1128 if (srcFs.isDirectory(path)) { in tail()
[all …]
H A DFsShellPermissions.java64 public void run(FileStatus file, FileSystem srcFs) throws IOException { in run() argument
68 srcFs.setPermission(file.getPath(), new FsPermission((short)newperms)); in run()
113 public void run(FileStatus file, FileSystem srcFs) throws IOException { in run() argument
121 srcFs.setOwner(file.getPath(), newOwner, newGroup); in run()
/dports/net/rclone/rclone-1.57.0/fs/sync/
H A Drc.go25 - srcFs - a remote name string e.g. "drive:src" for the source
37 srcFs, err := rc.GetFsNamed(ctx, in, "srcFs")
51 return nil, Sync(ctx, dstFs, srcFs, createEmptySrcDirs)
53 return nil, CopyDir(ctx, dstFs, srcFs, createEmptySrcDirs)
59 return nil, MoveDir(ctx, dstFs, srcFs, deleteEmptySrcDirs, createEmptySrcDirs)
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/util/
H A DTestFSHDFSUtils.java115 FileSystem srcFs = srcPath.getFileSystem(conf); in testIsSameHdfs() local
118 assertTrue(FSHDFSUtils.isSameHdfs(conf, srcFs, desFs)); in testIsSameHdfs()
122 assertTrue(!FSHDFSUtils.isSameHdfs(conf, srcFs, desFs)); in testIsSameHdfs()
126 assertTrue(!FSHDFSUtils.isSameHdfs(conf, srcFs, desFs)); in testIsSameHdfs()
138 assertTrue(FSHDFSUtils.isSameHdfs(conf, srcFs, desFs)); in testIsSameHdfs()
144 assertTrue(!FSHDFSUtils.isSameHdfs(conf, srcFs, desFs)); in testIsSameHdfs()
/dports/cad/librepcb/librepcb-0.1.6/libs/librepcb/common/fileio/
H A Dtransactionaldirectory.cpp152 void TransactionalDirectory::copyDirRecursively(TransactionalFileSystem& srcFs, in copyDirRecursively() argument
160 foreach (const QString& file, srcFs.getFiles(srcDir)) { in copyDirRecursively()
161 dstFs.write(dstDir % file, srcFs.read(srcDir % file)); in copyDirRecursively()
165 foreach (const QString& dir, srcFs.getDirs(srcDir)) { in copyDirRecursively()
166 copyDirRecursively(srcFs, srcDir % dir % "/", dstFs, dstDir % dir % "/"); in copyDirRecursively()
/dports/net/rclone/rclone-1.57.0/fs/operations/
H A Dmultithread_test.go24 srcFs := mockfs.NewFs(ctx, "sausage", "")
25 src.SetFs(srcFs)
66 srcFs.Features().IsLocal = true
72 srcFs.Features().IsLocal = false
74 srcFs.Features().IsLocal = true
78 srcFs.Features().IsLocal = false
/dports/net/rclone/rclone-1.57.0/vendor/github.com/hanwen/go-fuse/v2/fuse/pathfs/
H A Dcopy.go13 func CopyFile(srcFs, destFs FileSystem, srcFile, destFile string, context *fuse.Context) fuse.Statu… argument
14 src, code := srcFs.Open(srcFile, uint32(os.O_RDONLY), context)
21 attr, code := srcFs.GetAttr(srcFile, context)
/dports/sysutils/chezmoi/chezmoi-2.9.3/vendor/github.com/go-git/go-git/v5/
H A Dprune_test.go23 srcFs := fixtures.ByTag("unpacked").One().DotGit()
26 sto = filesystem.NewStorage(srcFs, cache.NewObjectLRUDefault())
38 r, err := Open(sto, srcFs)
/dports/net/cloudquery/cloudquery-0.16.0/vendor/github.com/go-git/go-git/v5/
H A Dprune_test.go23 srcFs := fixtures.ByTag("unpacked").One().DotGit()
26 sto = filesystem.NewStorage(srcFs, cache.NewObjectLRUDefault())
38 r, err := Open(sto, srcFs)
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/go-git/go-git/v5/
H A Dprune_test.go23 srcFs := fixtures.ByTag("unpacked").One().DotGit()
26 sto = filesystem.NewStorage(srcFs, cache.NewObjectLRUDefault())
38 r, err := Open(sto, srcFs)
/dports/devel/lazygit/lazygit-0.31.4/vendor/github.com/jesseduffield/go-git/v5/go-git-341962be15a4/
H A Dprune_test.go23 srcFs := fixtures.ByTag("unpacked").One().DotGit()
26 sto = filesystem.NewStorage(srcFs, cache.NewObjectLRUDefault())
38 r, err := Open(sto, srcFs)
/dports/devel/gitty/gitty-0.3.0/vendor/github.com/go-git/go-git/v5/
H A Dprune_test.go23 srcFs := fixtures.ByTag("unpacked").One().DotGit()
26 sto = filesystem.NewStorage(srcFs, cache.NewObjectLRUDefault())
38 r, err := Open(sto, srcFs)
/dports/net/syncthing/syncthing-1.18.1/syncthing/cmd/syncthing/decrypt/
H A Ddecrypt.go77 srcFs := fs.NewFilesystem(fs.FilesystemTypeBasic, c.Path)
83 return srcFs.Walk(".", func(path string, info fs.FileInfo, err error) error {
94 return c.withContinue(c.process(srcFs, dstFs, path))
130 func (c *CLI) process(srcFs fs.Filesystem, dstFs fs.Filesystem, path string) error {
135 encFd, err := srcFs.Open(path)
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/
H A DSecureBulkLoadEndpoint.java372 private FileSystem srcFs = null; field in SecureBulkLoadEndpoint.SecureBulkLoadListener
386 if (srcFs == null) { in prepareBulkLoad()
387 srcFs = FileSystem.get(p.toUri(), conf); in prepareBulkLoad()
395 if (!FSHDFSUtils.isSameHdfs(conf, srcFs, fs)) { in prepareBulkLoad()
398 FileUtil.copy(srcFs, p, fs, stageP, false, conf); in prepareBulkLoad()
418 if (!FSHDFSUtils.isSameHdfs(conf, srcFs, fs)) { in failedBulkLoad()
445 FileStatus status = srcFs.getFileStatus(p); in isFile()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/util/
H A DFSHDFSUtils.java116 public static boolean isSameHdfs(Configuration conf, FileSystem srcFs, FileSystem desFs) { in isSameHdfs() argument
119 String srcServiceName = srcFs.getCanonicalServiceName(); in isSameHdfs()
139 if (srcFs instanceof DistributedFileSystem && desFs instanceof DistributedFileSystem) { in isSameHdfs()
143 Set<InetSocketAddress> srcAddrs = getNNAddresses((DistributedFileSystem) srcFs, conf); in isSameHdfs()
/dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/hdfs/
H A DTestBalancer.java309 FileSystem srcFs = temp.getFileSystem(hadoopConf); in makeTempDir() local
312 fstatus = srcFs.getFileStatus(temp); in makeTempDir()
321 if (!srcFs.mkdirs(temp)) { in makeTempDir()
335 FileSystem srcFs = temp.getFileSystem(hadoopConf); in deleteTempDir() local
336 … LOG.info("attempting to delete path " + temp + "; this path exists? -> " + srcFs.exists(temp)); in deleteTempDir()
337 srcFs.delete(temp, true); in deleteTempDir()
/dports/net/syncthing/syncthing-1.18.1/syncthing/lib/osutil/
H A Dosutil.go109 func copyFileContents(method fs.CopyRangeMethod, srcFs, dstFs fs.Filesystem, src, dst string) (err … argument
110 in, err := srcFs.Open(src)
/dports/cad/librepcb/librepcb-0.1.6/apps/librepcb/projectlibraryupdater/
H A Dprojectlibraryupdater.cpp170 std::shared_ptr<TransactionalFileSystem> srcFs = in updateElements() local
172 TransactionalDirectory srcDir(srcFs); in updateElements()
/dports/net/rclone/rclone-1.57.0/backend/mega/
H A Dmega.go689 func (f *Fs) move(ctx context.Context, dstRemote string, srcFs *Fs, srcRemote string, info *mega.No…
712 srcDirNode, srcLeaf, err = srcFs.lookupParentDir(ctx, srcRemote)
715 absRoot := srcFs.srv.FS.GetRoot()
716 srcParent, srcLeaf = path.Split(srcFs.root)
798 srcFs, ok := src.(*Fs)
800 fs.Debugf(srcFs, "Can't move directory - not same remote type")
805 info, err := srcFs.lookupDir(ctx, srcRemote)
819 err = f.move(ctx, dstRemote, srcFs, srcRemote, info)
826 srcFs.clearRoot()
/dports/net/syncthing/syncthing-1.18.1/syncthing/lib/versioner/
H A Dutil.go135 func archiveFile(method fs.CopyRangeMethod, srcFs, dstFs fs.Filesystem, filePath string, tagger fil… argument
137 info, err := srcFs.Lstat(filePath)
176 err = osutil.RenameOrCopy(method, srcFs, dstFs, filePath, dst)
/dports/net/rclone/rclone-1.57.0/backend/koofr/
H A Dkoofr.go519 srcFs := src.(*Fs)
520 srcFullPath := srcFs.fullPath(srcRemote)
522 if srcFs.mountID == f.mountID && srcFullPath == dstFullPath {
530 err = f.client.FilesMove(srcFs.mountID, srcFullPath, f.mountID, dstFullPath)
/dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/distcp2/util/
H A DDistCpUtils.java312 public static boolean compareFs(FileSystem srcFs, FileSystem destFs) {
313 URI srcUri = srcFs.getUri();

123