[GitHub] [rocketmq] jianglianggithub opened a new issue #1919: org.apache.rocketmq.store.index.IndexFile#putKey

[GitBox]

jianglianggithub opened a new issue #1919: 
org.apache.rocketmq.store.index.IndexFile#putKey
URL: https://github.com/apache/rocketmq/issues/1919
 
 
   begin
                  if (this.indexHeader.getIndexCount() <= 1) {
                      this.indexHeader.setBeginPhyOffset(phyOffset);
                      this.indexHeader.setBeginTimestamp(storeTimestamp);
                  }
   
                  this.indexHeader.incHashSlotCount();
                  this.indexHeader.incIndexCount();
                  this.indexHeader.setEndPhyOffset(phyOffset);
                  this.indexHeader.setEndTimestamp(storeTimestamp);
   
   update 
   
   
                  if (this.indexHeader.getIndexCount() <= 1) {
                      this.indexHeader.setBeginPhyOffset(phyOffset);
                      this.indexHeader.setBeginTimestamp(storeTimestamp);
                  }
   
                 //Hash collision  send 2 msg  [ method param ] key is equal    
but HashSlot use 1
                 //  key= topic+ keys  hashcode  equal
                  if(slotValue == 0) {
                     this.indexHeader.incHashSlotCount();
                  }
                  this.indexHeader.incIndexCount();
                  this.indexHeader.setEndPhyOffset(phyOffset);
                  this.indexHeader.setEndTimestamp(storeTimestamp);
   
   
   

----------------------------------------------------------------
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:
us...@infra.apache.org


With regards,
Apache Git Services