提交 86e99ef0 authored 作者: Andrei Tokar's avatar Andrei Tokar

oops

上级 88e6a94a
......@@ -162,10 +162,9 @@ public class MVPrimaryIndex extends BaseIndex {
}
}
public void lockRows(Session session, Iterator<Row> rowsForUpdate) {
public void lockRows(Session session, Iterable<Row> rowsForUpdate) {
TransactionMap<Value, Value> map = getMap(session);
while (rowsForUpdate.hasNext()) {
Row row = rowsForUpdate.next();
for (Row row : rowsForUpdate) {
long key = row.getKey();
try {
map.lock(ValueLong.get(key));
......
......@@ -749,7 +749,7 @@ public class MVTable extends TableBase {
}
@Override
public void lockRows(Session session, Iterator<Row> rowsForUpdate) {
public void lockRows(Session session, Iterable<Row> rowsForUpdate) {
primaryIndex.lockRows(session, rowsForUpdate);
}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论