This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/master by this push:
new 7e9350c ISSUE #256:
BookieInitializationTest.testWithDiskFullAndAbilityToCreateNewIndexFile failed
7e9350c is described below
commit 7e9350cff67f0cb72ab757d500d98044cbdd4264
Author: Sijie Guo <[email protected]>
AuthorDate: Wed Jul 19 08:43:14 2017 +0200
ISSUE #256:
BookieInitializationTest.testWithDiskFullAndAbilityToCreateNewIndexFile failed
Descriptions of the changes in this PR:
in c49621b, we allow creating FileInfo even when disk is full to allow
fence requests succeed at this case.
it is conflicted with Charan's change. Since there is already a setting to
configure the min usable size to allow index file creation. if we configure
that to be zero, it is same as allowing index file creation even disks are
full. so removing the fallback logic introduced in c49621b.
Author: Sijie Guo <[email protected]>
Reviewers: Charan Reddy Guttapalem, Enrico Olivelli
This closes #257 from sijie/issue_256, closes #256
---
.../bookkeeper/bookie/IndexPersistenceMgr.java | 35 ++--------------------
1 file changed, 2 insertions(+), 33 deletions(-)
diff --git
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexPersistenceMgr.java
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexPersistenceMgr.java
index d8bed79..859e8d7 100644
---
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexPersistenceMgr.java
+++
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexPersistenceMgr.java
@@ -128,7 +128,7 @@ public class IndexPersistenceMgr {
throw new Bookie.NoLedgerException(ledger);
}
// We don't have a ledger index file on disk, so create it.
- lf = getNewLedgerIndexFile(ledger, null, true);
+ lf = getNewLedgerIndexFile(ledger, null);
createdNewFile = true;
}
}
@@ -179,38 +179,7 @@ public class IndexPersistenceMgr {
*/
private File getNewLedgerIndexFile(Long ledger, File excludedDir)
throws NoWritableLedgerDirException {
- return getNewLedgerIndexFile(ledger, excludedDir, false);
- }
-
- /**
- * Get a new index file for a ledger in a lazy way.
- *
- + <p>If fallback is false, this function will throw exception when there
are no writable dirs.
- + If fallback is true and there's no writable dirs, it will ignore the
error and pick any dir.
- + Set fallback to true is useful when we want to delay disk check and
just get the File pointer, e.g. fence ledger
- *
- * @param ledger
- * Ledger id.
- * @param excludedDir
- * The ledger directory to exclude.
- * @param fallback
- * If fallback is false, the function will throw exception when
there are no writable dirs;
- * If it is true and there's no writable dirs, it will ignore the
error and pick any dir.
- * @return new index file object.
- * @throws NoWritableLedgerDirException if there is no writable dir
available.
- */
- private File getNewLedgerIndexFile(Long ledger, File excludedDir, boolean
fallback)
- throws NoWritableLedgerDirException {
- File dir = null;
- try {
- dir =
ledgerDirsManager.pickRandomWritableDirForNewIndexFile(excludedDir);
- } catch (NoWritableLedgerDirException e) {
- if (fallback) {
- dir = ledgerDirsManager.pickRandomDir(excludedDir);
- } else {
- throw e;
- }
- }
+ File dir =
ledgerDirsManager.pickRandomWritableDirForNewIndexFile(excludedDir);
String ledgerName = getLedgerName(ledger);
return new File(dir, ledgerName);
}
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
