X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.sync%2Fsrc%2Forg%2Fargeo%2Fsync%2Ffs%2FPathSync.java;fp=org.argeo.sync%2Fsrc%2Forg%2Fargeo%2Fsync%2Ffs%2FPathSync.java;h=0000000000000000000000000000000000000000;hb=d6bb3d3e0643c410ecd3ca1d4d88ae412697f258;hp=1dc30db6567ea9ffec7a08c1355d72ef88e4f3b7;hpb=98cb11c643f2f4de160061e64cc93df120130f8d;p=lgpl%2Fargeo-commons.git diff --git a/org.argeo.sync/src/org/argeo/sync/fs/PathSync.java b/org.argeo.sync/src/org/argeo/sync/fs/PathSync.java deleted file mode 100644 index 1dc30db65..000000000 --- a/org.argeo.sync/src/org/argeo/sync/fs/PathSync.java +++ /dev/null @@ -1,60 +0,0 @@ -package org.argeo.sync.fs; - -import java.net.URI; -import java.nio.file.FileSystems; -import java.nio.file.Files; -import java.nio.file.Path; -import java.nio.file.Paths; -import java.nio.file.spi.FileSystemProvider; -import java.time.ZonedDateTime; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.argeo.jackrabbit.fs.DavexFsProvider; -import org.argeo.sync.SyncException; -import org.argeo.util.LangUtils; - -public class PathSync implements Runnable { - private final static Log log = LogFactory.getLog(PathSync.class); - - private final URI sourceUri, targetUri; - - public PathSync(URI sourceUri, URI targetUri) { - this.sourceUri = sourceUri; - this.targetUri = targetUri; - } - - @Override - public void run() { - try { - FileSystemProvider sourceFsProvider = createFsProvider(sourceUri); - FileSystemProvider targetFsProvider = createFsProvider(targetUri); - Path sourceBasePath = sourceUri.getScheme() != null ? sourceFsProvider.getPath(sourceUri) - : Paths.get(sourceUri.getPath()); - Path targetBasePath = targetUri.getScheme() != null ? targetFsProvider.getPath(targetUri) - : Paths.get(targetUri.getPath()); - SyncFileVisitor syncFileVisitor = new SyncFileVisitor(sourceBasePath, targetBasePath); - ZonedDateTime begin = ZonedDateTime.now(); - Files.walkFileTree(sourceBasePath, syncFileVisitor); - if (log.isDebugEnabled()) - log.debug("Sync from " + sourceBasePath + " to " + targetBasePath + " took " + LangUtils.since(begin)); - } catch (Exception e) { - e.printStackTrace(); - } - } - - private static FileSystemProvider createFsProvider(URI uri) { - FileSystemProvider fsProvider; - if (uri.getScheme() == null || uri.getScheme().equals("file")) - fsProvider = FileSystems.getDefault().provider(); - else if (uri.getScheme().equals("davex")) - fsProvider = new DavexFsProvider(); - else - throw new SyncException("URI scheme not supported for " + uri); - return fsProvider; - } - - static enum Arg { - to, from; - } -}