1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.gwe.drivers.fileSystems;
18
19 import org.apache.commons.logging.Log;
20 import org.apache.commons.logging.LogFactory;
21 import org.gwe.utils.security.KeyStore;
22
23
24
25
26
27 public class GridFileSystem {
28
29 private static Log log = LogFactory.getLog(GridFileSystem.class);
30
31 private FileTransferer downloadfileTransferer;
32 private FileTransferer uploadFileTransferer;
33
34 public GridFileSystem(int maxParallelFileTransfers) {
35 this.downloadfileTransferer = new FileTransferer(maxParallelFileTransfers, "Download");
36 this.uploadFileTransferer = new FileTransferer(5, "Upload");
37 }
38
39 public Long stageFile(String srcFile, String destFile, KeyStore keys) throws Exception {
40 return downloadfileTransferer.transferFile(srcFile, destFile, keys);
41 }
42
43 public Long transferFile(String srcFile, String destFile, KeyStore keys) throws Exception {
44 return downloadfileTransferer.transferFile(srcFile, destFile, keys);
45 }
46
47 public Long uploadFile(String srcFile, String destFile, KeyStore keys) throws Exception {
48 return uploadFileTransferer.transferFile(srcFile, destFile, keys);
49 }
50 }
51