-
Notifications
You must be signed in to change notification settings - Fork 198
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Unit test elastic indexer #2288
Conversation
# Conflicts: # core/indexer/dataDispatcher.go # core/indexer/elasticProcessor_test.go
@@ -237,7 +237,7 @@ func (ei *elasticProcessor) RemoveMiniblocks(header data.HeaderHandler, body *bl | |||
|
|||
isDstMe := selfShardID == miniblock.ReceiverShardID | |||
isCrossShard := miniblock.ReceiverShardID != miniblock.SenderShardID | |||
if !(isDstMe && isCrossShard) { | |||
if isDstMe && isCrossShard { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
So the condition is completely reversed. The bulk remove is not done anymore for cross miniblocks wit dest me.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes. Now is right because if a miniblock is indexed on source shard and if a rollback appears cross shard miniblocks should not be removed because I have to keep information that was indexed on source shard. When miniblock will be executed again on destination shard information will be rewritten.
# Conflicts: # core/indexer/dataDispatcher.go # core/indexer/dataDispatcher_test.go # core/indexer/errors.go # core/indexer/workItems/workItemRemoveBlock.go
Unit test for package core/indexer