return err
}
- if err := saveVoteResult(batch, voteResults); err != nil {
- return err
+ for _, vote := range voteResults {
+ bytes, err := json.Marshal(vote)
+ if err != nil {
+ return err
+ }
+
+ batch.Set(calcVoteResultKey(vote.Seq), bytes)
+ if _, ok := s.cache.getVoteResult(vote.Seq); ok {
+ s.cache.addVoteResult(vote)
+ }
}
bytes, err := json.Marshal(protocol.BlockStoreState{
batch.Write()
return nil
}
-
-// saveVoteResult update the voting results generated by each irreversible block
-func saveVoteResult(batch dbm.Batch, voteResults []*state.VoteResult) error {
- for _, vote := range voteResults {
- bytes, err := json.Marshal(vote)
- if err != nil {
- return err
- }
-
- batch.Set(calcVoteResultKey(vote.Seq), bytes)
- }
- return nil
-}