zourunxin commented on a change in pull request #2919:
URL: https://github.com/apache/rocketmq/pull/2919#discussion_r642461944
##########
File path: store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
##########
@@ -189,24 +177,14 @@ public boolean isTimeMatched(final long begin, final long
end) {
}
public void selectPhyOffset(final List<Long> phyOffsets, final String key,
final int maxNum,
- final long begin, final long end, boolean lock) {
+ final long begin, final long end) {
if (this.mappedFile.hold()) {
int keyHash = indexKeyHashMethod(key);
int slotPos = keyHash % this.hashSlotNum;
int absSlotPos = IndexHeader.INDEX_HEADER_SIZE + slotPos *
hashSlotSize;
- FileLock fileLock = null;
Review comment:
its like upper
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
