1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
package fileIO;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.zip.ZipOutputStream;
import shared.Parse;
import shared.Parser;
import shared.PreParser;
import shared.Timer;
import shared.Tools;
import tracker.ReadStats;
/**
* Unlike ReadWrite's version, this one forces compression and decompression even with same extensions.
* Mainly for benchmarking.
* @author Brian Bushnell
* @date Jan 23, 2013
*
*/
public class CopyFile {
public static void main(String[] args){
{//Preparse block for help, config files, and outstream
PreParser pp=new PreParser(args, new Object() { }.getClass().getEnclosingClass(), false);
args=pp.args;
//outstream=pp.outstream;
}
String in=null, out=null;
boolean overwrite=true;
boolean append=false;
for(int i=0; i<args.length; i++){
final String arg=args[i];
final String[] split=arg.split("=");
String a=split[0].toLowerCase();
String b=split.length>1 ? split[1] : null;
if(Parser.parseCommonStatic(arg, a, b)){
//do nothing
}else if(Parser.parseZip(arg, a, b)){
//do nothing
}else if(a.equals("in")){
in=b;
}else if(a.equals("out")){
out=b;
}else if(a.equals("append") || a.equals("app")){
append=ReadStats.append=Parse.parseBoolean(b);
}else if(a.equals("overwrite") || a.equals("ow")){
overwrite=Parse.parseBoolean(b);
}else if(in==null && i==0 && !args[i].contains("=")){
in=args[i];
}else if(out==null && i==1 && !args[i].contains("=")){
out=args[i];
}
}
assert(in!=null && out!=null);
long bytes=new File(in).length();
Timer t=new Timer();
copyFile(in, out, false, overwrite);
t.stop();
double mbps1=bytes*1000d/t.elapsed;
System.err.println("Time: \t"+t);
System.err.println(Tools.format("Speed: \t%.2f MB/s", mbps1));
}
public static synchronized void copyFile(String source, String dest, boolean createPathIfNeeded, boolean overwrite){
assert(overwrite || !new File(dest).exists()) : "Destination file already exists: "+dest;
if(createPathIfNeeded){
File parent=new File(dest).getParentFile();
if(parent!=null && !parent.exists()){
parent.mkdirs();
}
}
try{
InputStream in=ReadWrite.getInputStream(source, false, true);
OutputStream out=ReadWrite.getOutputStream(dest, false, false, true);
final byte[] buffer=new byte[16384];
int len;
while((len = in.read(buffer)) > 0){
out.write(buffer, 0, len);
}
in.close();
out.flush();
if(out.getClass()==ZipOutputStream.class){
ZipOutputStream zos=(ZipOutputStream)out;
zos.closeEntry();
zos.finish();
}
// else if(PROCESS_XZ && out.getClass()==org.tukaani.xz.XZOutputStream.class){
// org.tukaani.xz.XZOutputStream zos=(org.tukaani.xz.XZOutputStream)out;
// zos.finish();
// }
out.close();
}catch(FileNotFoundException e){
throw new RuntimeException(e);
}catch(IOException e){
throw new RuntimeException(e);
}
}
}
|
