@@ -46,10 +46,13 @@ func (instance *pbftCore) persistPSet() {
46
46
func (instance * pbftCore ) persistPQSet (key string , set []* ViewChange_PQ ) {
47
47
raw , err := proto .Marshal (& PQset {set })
48
48
if err != nil {
49
- logger .Warningf ("Replica %d could not persist pqset: %s" , instance .id , err )
49
+ logger .Warningf ("Replica %d could not persist pqset: %s: error: %s " , instance .id , key , err )
50
50
return
51
51
}
52
- instance .consumer .StoreState (key , raw )
52
+ err = instance .consumer .StoreState (key , raw )
53
+ if err != nil {
54
+ logger .Warningf ("Replica %d could not persist pqset: %s: error: %s" , instance .id , key , err )
55
+ }
53
56
}
54
57
55
58
func (instance * pbftCore ) restorePQSet (key string ) []* ViewChange_PQ {
@@ -74,7 +77,10 @@ func (instance *pbftCore) persistRequestBatch(digest string) {
74
77
logger .Warningf ("Replica %d could not persist request batch %s: %s" , instance .id , digest , err )
75
78
return
76
79
}
77
- instance .consumer .StoreState ("reqBatch." + digest , reqBatchPacked )
80
+ err = instance .consumer .StoreState ("reqBatch." + digest , reqBatchPacked )
81
+ if err != nil {
82
+ logger .Warningf ("Replica %d could not persist request batch %s: %s" , instance .id , digest , err )
83
+ }
78
84
}
79
85
80
86
func (instance * pbftCore ) persistDelRequestBatch (digest string ) {
@@ -92,7 +98,10 @@ func (instance *pbftCore) persistDelAllRequestBatches() {
92
98
93
99
func (instance * pbftCore ) persistCheckpoint (seqNo uint64 , id []byte ) {
94
100
key := fmt .Sprintf ("chkpt.%d" , seqNo )
95
- instance .consumer .StoreState (key , id )
101
+ err := instance .consumer .StoreState (key , id )
102
+ if err != nil {
103
+ logger .Warningf ("Could not persist Checkpoint %s: %s" , key , err )
104
+ }
96
105
}
97
106
98
107
func (instance * pbftCore ) persistDelCheckpoint (seqNo uint64 ) {
0 commit comments