提交 d43e9df2 authored 作者: Andrei Tokar's avatar Andrei Tokar

change test lockTimeout #3

上级 d427e911
...@@ -142,7 +142,7 @@ public class Transaction { ...@@ -142,7 +142,7 @@ public class Transaction {
/** /**
* Map on which this transaction is blocked. * Map on which this transaction is blocked.
*/ */
MVMap blockingMap; MVMap<?,VersionedValue> blockingMap;
/** /**
* Key in blockingMap on which this transaction is blocked. * Key in blockingMap on which this transaction is blocked.
......
...@@ -228,7 +228,7 @@ public class TransactionStore { ...@@ -228,7 +228,7 @@ public class TransactionStore {
* @param logId the log id * @param logId the log id
* @return the operation id * @return the operation id
*/ */
private static long getOperationId(int transactionId, long logId) { static long getOperationId(int transactionId, long logId) {
DataUtils.checkArgument(transactionId >= 0 && transactionId < (1 << (64 - LOG_ID_BITS)), DataUtils.checkArgument(transactionId >= 0 && transactionId < (1 << (64 - LOG_ID_BITS)),
"Transaction id out of range: {0}", transactionId); "Transaction id out of range: {0}", transactionId);
DataUtils.checkArgument(logId >= 0 && logId <= LOG_ID_MASK, DataUtils.checkArgument(logId >= 0 && logId <= LOG_ID_MASK,
......
...@@ -51,7 +51,13 @@ public class TestIndex extends TestBase { ...@@ -51,7 +51,13 @@ public class TestIndex extends TestBase {
testHashIndexOnMemoryTable(); testHashIndexOnMemoryTable();
testErrorMessage(); testErrorMessage();
testDuplicateKeyException(); testDuplicateKeyException();
testConcurrentUpdate(); int to = config.lockTimeout;
config.lockTimeout = 50000;
try {
testConcurrentUpdate();
} finally {
config.lockTimeout = to;
}
testNonUniqueHashIndex(); testNonUniqueHashIndex();
testRenamePrimaryKey(); testRenamePrimaryKey();
testRandomized(); testRandomized();
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论