in hbase-oss/src/main/java/org/apache/hadoop/hbase/oss/HBaseObjectStoreSemantics.java [335:351]
public FSDataOutputStream create(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress) throws IOException {
AutoLock lock = sync.lockWrite(f);
try {
FSDataOutputStream stream = fs.create(f, permission, flags, bufferSize,
replication, blockSize, progress);
return new LockedFSDataOutputStream(stream, lock);
} catch (IOException e) {
lock.close();
throw(e);
}
}