| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/ |
| H A D | TestLocalFileSystem.java | 171 assertTrue(FileUtil.copy(fileSys, src, fileSys, dst, true, false, conf)); in testCopy()
172 assertTrue(!fileSys.exists(src) && fileSys.exists(dst)); in testCopy()
173 assertTrue(FileUtil.copy(fileSys, dst, fileSys, src, false, false, conf)); in testCopy()
174 assertTrue(fileSys.exists(src) && fileSys.exists(dst)); in testCopy()
175 assertTrue(FileUtil.copy(fileSys, src, fileSys, dst, true, true, conf)); in testCopy()
176 assertTrue(!fileSys.exists(src) && fileSys.exists(dst)); in testCopy()
177 fileSys.mkdirs(src); in testCopy()
178 assertTrue(FileUtil.copy(fileSys, dst, fileSys, src, false, false, conf)); in testCopy()
180 assertTrue(fileSys.exists(tmp) && fileSys.exists(dst)); in testCopy()
181 assertTrue(FileUtil.copy(fileSys, dst, fileSys, src, false, true, conf)); in testCopy()
[all …]
|
| H A D | TestFsShellReturnCode.java | 143 writeFile(fileSys, p1); in testChmod()
159 writeFile(fileSys, p4); in testChmod()
161 writeFile(fileSys, p5); in testChmod()
163 writeFile(fileSys, p6); in testChmod()
200 writeFile(fileSys, p1); in testChown()
213 writeFile(fileSys, p4); in testChown()
215 writeFile(fileSys, p5); in testChown()
217 writeFile(fileSys, p6); in testChown()
255 writeFile(fileSys, p1); in testChgrp()
270 writeFile(fileSys, p4); in testChgrp()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
| H A D | TestLocalDFS.java | 53 assertTrue(fileSys.exists(name)); in cleanupFile()
54 fileSys.delete(name, true); in cleanupFile()
77 writeFile(fileSys, file1); in testWorkingDirectory()
79 fileSys.delete(file1, true); in testWorkingDirectory()
82 writeFile(fileSys, file1); in testWorkingDirectory()
86 writeFile(fileSys, file1); in testWorkingDirectory()
87 readFile(fileSys, file1); in testWorkingDirectory()
93 fileSys.makeQualified( in testWorkingDirectory()
100 fileSys.close(); in testWorkingDirectory()
119 fileSys.makeQualified( in testHomeDirectory()
[all …]
|
| H A D | TestFSInputChecker.java | 228 fileSys.delete(name, true); in cleanupFile()
238 writeFile(fileSys, file); in testChecker()
245 stm = fileSys.open(file); in testChecker()
268 writeFile(fileSys, file); in testFileCorruption()
280 fileSys.delete(file, true); in testFileCorruption()
282 writeFile(fileSys, file); in testFileCorruption()
287 fileSys.delete(file, true); in testFileCorruption()
333 fileSys.close(); in testFSInputChecker()
346 fileSys.close(); in testFSInputChecker()
353 writeFile(fileSys, file); in testSeekAndRead()
[all …]
|
| H A D | TestModTime.java | 57 FSDataOutputStream stm = fileSys.create(name, true, fileSys.getConf() in writeFile()
68 assertTrue(fileSys.exists(name)); in cleanupFile()
69 fileSys.delete(name, true); in cleanupFile()
70 assertTrue(!fileSys.exists(name)); in cleanupFile()
115 stat = fileSys.getFileStatus(dir1); in testModTime()
138 assertTrue(fileSys.mkdirs(dir2)); in testModTime()
146 fileSys.rename(file1, newfile); in testModTime()
180 cleanupFile(fileSys, file2); in testModTime()
181 cleanupFile(fileSys, dir1); in testModTime()
182 cleanupFile(fileSys, dir2); in testModTime()
[all …]
|
| H A D | TestSeekBug.java | 89 fileSys = ((ChecksumFileSystem)fileSys).getRawFileSystem(); in smallReadSeek()
121 fileSys.delete(name, true); in cleanupFile()
135 writeFile(fileSys, file1); in testSeekBugDFS()
136 seekReadFile(fileSys, file1); in testSeekBugDFS()
137 smallReadSeek(fileSys, file1); in testSeekBugDFS()
138 cleanupFile(fileSys, file1); in testSeekBugDFS()
140 fileSys.close(); in testSeekBugDFS()
212 writeFile(fileSys, file1); in testSeekBugLocalFS()
213 seekReadFile(fileSys, file1); in testSeekBugLocalFS()
214 cleanupFile(fileSys, file1); in testSeekBugLocalFS()
[all …]
|
| H A D | TestSetTimes.java | 64 FSDataOutputStream stm = fileSys.create(name, true, fileSys.getConf() in writeFile()
75 assertTrue(fileSys.exists(name)); in cleanupFile()
76 fileSys.delete(name, true); in cleanupFile()
77 assertTrue(!fileSys.exists(name)); in cleanupFile()
144 stat = fileSys.getFileStatus(dir1); in testTimes()
199 fileSys = cluster.getFileSystem(); in testTimes()
208 cleanupFile(fileSys, file1); in testTimes()
209 cleanupFile(fileSys, dir1); in testTimes()
215 fileSys.close(); in testTimes()
270 cleanupFile(fileSys, file1); in testTimesAtClose()
[all …]
|
| H A D | TestPread.java | 176 stm = fileSys.open(name); in pReadFile()
241 pReadFile(fileSys, file); in getPReadFileCallable()
349 fileSys.close();
392 writeFile(fileSys, file1);
395 pReadFile(fileSys, file1);
405 pReadFile(fileSys, file1);
430 fileSys.close();
453 writeFile(fileSys, file1);
454 pReadFile(fileSys, file1);
458 fileSys.close();
[all …]
|
| H A D | TestSmallBlock.java | 48 FSDataOutputStream stm = fileSys.create(name, true, fileSys.getConf() in writeFile()
69 fileSys.getFileStatus(name), 0, fileSize); in checkFile()
71 FSDataInputStream stm = fileSys.open(name); in checkFile()
89 assertTrue(fileSys.exists(name)); in cleanupFile()
90 fileSys.delete(name, true); in cleanupFile()
91 assertTrue(!fileSys.exists(name)); in cleanupFile()
105 FileSystem fileSys = cluster.getFileSystem(); in testSmallBlock() local
108 writeFile(fileSys, file1); in testSmallBlock()
109 checkFile(fileSys, file1); in testSmallBlock()
110 cleanupFile(fileSys, file1); in testSmallBlock()
[all …]
|
| H A D | TestFSOutputSummer.java | 46 private FileSystem fileSys; field in TestFSOutputSummer
50 FSDataOutputStream stm = fileSys.create(name, true, in writeFile1()
101 FSDataInputStream stm = fileSys.open(name); in checkFile()
107 fileSys.getFileChecksum(name); in checkFile()
111 assertTrue(fileSys.exists(name)); in cleanupFile()
112 fileSys.delete(name, true); in cleanupFile()
113 assertTrue(!fileSys.exists(name)); in cleanupFile()
134 fileSys = cluster.getFileSystem(); in doTestFSOutputSummer()
143 fileSys.close(); in doTestFSOutputSummer()
157 fileSys = cluster.getFileSystem(); in TestDFSCheckSumType()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestNameEditsConfigs.java | 87 fileSys.delete(name, true); in cleanupFile()
116 FileSystem fileSys = null; in testNameEditsConfigs() local
144 fileSys.close(); in testNameEditsConfigs()
173 cleanupFile(fileSys, file1); in testNameEditsConfigs()
178 fileSys.close(); in testNameEditsConfigs()
221 fileSys.close(); in testNameEditsConfigs()
258 fileSys.close(); in testNameEditsConfigs()
283 FileSystem fileSys = null; in testNameEditsConfigsFailure() local
304 fileSys.close(); in testNameEditsConfigsFailure()
331 fileSys.close(); in testNameEditsConfigsFailure()
[all …]
|
| H A D | TestCheckpoint.java | 81 fileSys.delete(name, true); in cleanupFile()
171 fileSys.close(); in testSecondaryNamenodeError1()
209 fileSys.close(); in testSecondaryNamenodeError1()
247 fileSys.close(); in testSecondaryNamenodeError2()
267 fileSys.close(); in testSecondaryNamenodeError2()
313 fileSys.close(); in testSecondaryNamenodeError3()
333 fileSys.close(); in testSecondaryNamenodeError3()
384 fileSys.close(); in testSecondaryFailsToReturnImage()
608 fileSys.close(); in testCheckpoint()
634 fileSys.close(); in testCheckpoint()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/ |
| H A D | TestLocalDFS.java | 47 assertTrue(fileSys.exists(name)); in cleanupFile()
48 fileSys.delete(name, true); in cleanupFile()
49 assertTrue(!fileSys.exists(name)); in cleanupFile()
70 writeFile(fileSys, file1); in testWorkingDirectory()
72 fileSys.delete(file1, true); in testWorkingDirectory()
74 fileSys.setWorkingDirectory(subdir1); in testWorkingDirectory()
75 writeFile(fileSys, file1); in testWorkingDirectory()
79 writeFile(fileSys, file1); in testWorkingDirectory()
80 readFile(fileSys, file1); in testWorkingDirectory()
86 .makeQualified(fileSys); in testWorkingDirectory()
[all …]
|
| H A D | TestModTime.java | 61 assertTrue(fileSys.exists(name)); in cleanupFile()
62 fileSys.delete(name, true); in cleanupFile()
63 assertTrue(!fileSys.exists(name)); in cleanupFile()
106 stat = fileSys.getFileStatus(dir1); in testModTime()
121 stat = fileSys.getFileStatus(dir1); in testModTime()
129 assertTrue(fileSys.mkdirs(dir2)); in testModTime()
137 fileSys.rename(file1, newfile); in testModTime()
171 cleanupFile(fileSys, file2); in testModTime()
172 cleanupFile(fileSys, dir1); in testModTime()
173 cleanupFile(fileSys, dir2); in testModTime()
[all …]
|
| H A D | TestSeekBug.java | 84 fileSys = ((ChecksumFileSystem)fileSys).getRawFileSystem(); in smallReadSeek()
116 fileSys.delete(name, true); in cleanupFile()
129 writeFile(fileSys, file1); in testSeekBugDFS()
130 seekReadFile(fileSys, file1); in testSeekBugDFS()
131 smallReadSeek(fileSys, file1); in testSeekBugDFS()
132 cleanupFile(fileSys, file1); in testSeekBugDFS()
134 fileSys.close(); in testSeekBugDFS()
147 writeFile(fileSys, file1); in testSeekBugLocalFS()
148 seekReadFile(fileSys, file1); in testSeekBugLocalFS()
149 cleanupFile(fileSys, file1); in testSeekBugLocalFS()
[all …]
|
| H A D | TestFSInputChecker.java | 199 fileSys.delete(name, true); in cleanupFile()
210 writeFile(fileSys, file); in testChecker()
214 stm = fileSys.open(file); in testChecker()
221 cleanupFile(fileSys, file); in testChecker()
232 writeFile(fileSys, file); in testFileCorruption()
244 fileSys.delete(file, true); in testFileCorruption()
246 writeFile(fileSys, file); in testFileCorruption()
298 fileSys.close(); in testFSInputChecker()
311 fileSys.close(); in testFSInputChecker()
318 writeFile(fileSys, file); in testSeekAndRead()
[all …]
|
| H A D | TestPread.java | 56 if (!fileSys.delete(name, true)) in writeFile()
131 stm = fileSys.open(name); in pReadFile()
187 assertTrue(fileSys.exists(name)); in cleanupFile()
214 writeFile(fileSys, file1); in dfsPreadTest()
215 pReadFile(fileSys, file1); in dfsPreadTest()
217 cleanupFile(fileSys, file1); in dfsPreadTest()
219 fileSys.close(); in dfsPreadTest()
238 writeFile(fileSys, file1); in testPreadLocalFS()
239 pReadFile(fileSys, file1); in testPreadLocalFS()
240 cleanupFile(fileSys, file1); in testPreadLocalFS()
[all …]
|
| H A D | TestSetTimes.java | 63 assertTrue(fileSys.exists(name)); in cleanupFile()
64 fileSys.delete(name, true); in cleanupFile()
65 assertTrue(!fileSys.exists(name)); in cleanupFile()
115 stat = fileSys.getFileStatus(file1); in testTimes()
129 stat = fileSys.getFileStatus(dir1); in testTimes()
135 fileSys.setTimes(file1, -1, atime2); in testTimes()
138 stat = fileSys.getFileStatus(file1); in testTimes()
165 fileSys = cluster.getFileSystem(); in testTimes()
174 cleanupFile(fileSys, file1); in testTimes()
175 cleanupFile(fileSys, dir1); in testTimes()
[all …]
|
| H A D | TestSmallBlock.java | 43 FSDataOutputStream stm = fileSys.create(name, true, in writeFile()
64 fileSys.getFileStatus(name), 0, fileSize); in checkFile()
66 FSDataInputStream stm = fileSys.open(name); in checkFile()
84 assertTrue(fileSys.exists(name)); in cleanupFile()
85 fileSys.delete(name, true); in cleanupFile()
86 assertTrue(!fileSys.exists(name)); in cleanupFile()
99 FileSystem fileSys = cluster.getFileSystem(); in testSmallBlock() local
102 writeFile(fileSys, file1); in testSmallBlock()
103 checkFile(fileSys, file1); in testSmallBlock()
104 cleanupFile(fileSys, file1); in testSmallBlock()
[all …]
|
| H A D | TestDFSMkdirs.java | 33 private void writeFile(FileSystem fileSys, Path name) throws IOException { in writeFile() argument
34 DataOutputStream stm = fileSys.create(name); in writeFile()
46 FileSystem fileSys = cluster.getFileSystem(); in testDFSMkdirs() local
50 assertTrue(fileSys.mkdirs(myPath)); in testDFSMkdirs()
51 assertTrue(fileSys.exists(myPath)); in testDFSMkdirs()
52 assertTrue(fileSys.mkdirs(myPath)); in testDFSMkdirs()
56 writeFile(fileSys, myFile); in testDFSMkdirs()
63 fileSys.mkdirs(myIllegalPath); in testDFSMkdirs()
68 assertFalse(fileSys.exists(myIllegalPath)); in testDFSMkdirs()
69 fileSys.delete(myFile, true); in testDFSMkdirs()
[all …]
|
| H A D | TestDecommission.java | 99 fileSys.getFileStatus(name), 0, fileSize); in printFileLocations()
121 assertTrue("Not HDFS:"+fileSys.getUri(), fileSys instanceof DistributedFileSystem); in checkFile()
124 ((DistributedFileSystem)fileSys).open(name); in checkFile()
145 assertTrue(fileSys.exists(name)); in cleanupFile()
146 fileSys.delete(name, true); in cleanupFile()
147 assertTrue(!fileSys.exists(name)); in cleanupFile()
275 writeFile(fileSys, file1, replicas); in testDecommission()
278 checkFile(fileSys, file1, replicas); in testDecommission()
279 printFileLocations(fileSys, file1); in testDecommission()
285 cleanupFile(fileSys, file1); in testDecommission()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestNameEditsConfigs.java | 77 FSDataOutputStream stm = fileSys.create(name, true, fileSys.getConf() in writeFile()
120 fileSys.delete(name, true); in cleanupFile()
151 FileSystem fileSys = null; in testNameEditsConfigs() local
195 fileSys.close(); in testNameEditsConfigs()
232 fileSys.close(); in testNameEditsConfigs()
268 fileSys.close(); in testNameEditsConfigs()
309 fileSys.close(); in testNameEditsConfigs()
460 fileSys.close(); in testNameEditsConfigsFailure()
498 fileSys.close(); in testNameEditsConfigsFailure()
525 fileSys.close(); in testNameEditsConfigsFailure()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/fs/ |
| H A D | TestFsShellReturnCode.java | 89 writeFile(fileSys, p1); in testChmod()
105 writeFile(fileSys, p4); in testChmod()
107 writeFile(fileSys, p5); in testChmod()
109 writeFile(fileSys, p6); in testChmod()
150 writeFile(fileSys, p1); in testChown()
167 writeFile(fileSys, p4); in testChown()
169 writeFile(fileSys, p5); in testChown()
171 writeFile(fileSys, p6); in testChown()
212 writeFile(fileSys, p1); in testChgrp()
228 writeFile(fileSys, p4); in testChgrp()
[all …]
|
| H A D | TestLocalFileSystem.java | 78 assertTrue(fileSys.mkdirs(dir1)); in testWorkingDirectory()
82 fileSys.delete(dir1, true); in testWorkingDirectory()
83 assertTrue(!fileSys.exists(dir1)); in testWorkingDirectory()
88 writeFile(fileSys, file1); in testWorkingDirectory()
90 assertTrue(fileSys.exists(file1)); in testWorkingDirectory()
92 cleanupFile(fileSys, file2); in testWorkingDirectory()
94 cleanupFile(fileSys, file2); in testWorkingDirectory()
97 fileSys.rename(file1, file2); in testWorkingDirectory()
100 fileSys.rename(file2, file1); in testWorkingDirectory()
110 fileSys.delete(subdir, true); in testWorkingDirectory()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/fuse-dfs/src/test/ |
| H A D | TestFuseDFS.java | 121 mount(mpoint, fileSys.getUri()); in startStuff()
180 assertTrue(fileSys.exists(myPath)); in testWrites()
233 assertTrue(fileSys.exists(myPath)); in testRmdir()
249 assertTrue(fileSys.exists(myPath)); in testRmdir()
319 foo = fileSys.getFileStatus(path); in testChown()
374 assertTrue(fileSys.exists(path)); in testUtimes()
385 foo = fileSys.getFileStatus(path); in testUtimes()
464 s = fileSys.create(myPath); in testReads()
616 if(fileSys != null) { in close()
617 fileSys.close(); in close()
[all …]
|