RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-19 17:08:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Hadoop: cleanup compile bugs from previous cleanup work.

Browse Source
This commit is contained in:
Greg Farnum 2009-08-17 12:38:00 -07:00
parent 4d0589f392
commit 4a0767202d
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/client/hadoop/ceph/CephFileSystem.java
View File

@ -489,7 +489,7 @@ public class CephFileSystem extends FileSystem {
// Step 2: create any nonexistent directories in the path
Path parent = abs_path.getParent();
if (parent != null) { // if parent is root, we're done
int r = mkdirs(parent);
int r = ceph_mkdirs(parent.toString(), permission.toShort());
if (!(r==0 || r==-EEXIST))
throw new IOException ("Error creating parent directory; code: " + r);
}
@ -537,7 +537,9 @@ public class CephFileSystem extends FileSystem {
if (fh < 0) {
throw new IOException("open: Failed to open file " + abs_path.toString());
}
long size = ceph_getfilesize(abs_path.toString());
Stat lstat = new Stat();
ceph_stat(abs_path.toString(), lstat);
long size = lstat.size;
if (size < 0) {
throw new IOException("Failed to get file size for file " + abs_path.toString() +
" but succeeded in opening file. Something bizarre is going on.");