Skip to content

Commit f6d1be2

Browse files
committed
[FAB-1190] Make Rawledger accept metadata
SBFT needs to persist its own batch headers and signatures on its ledger (Rawledger, implementations: Fileledger, Ramledger). Rawledger interface needs to be modified to accept custom metadata where those objects can be stored. Change-Id: I0127b2a31a327c8ac39082b07627871951f82a0e Signed-off-by: Gabor Hosszu <[email protected]>
1 parent 68aef4e commit f6d1be2

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

orderer/rawledger/fileledger/fileledger.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ func (fl *fileLedger) Height() uint64 {
149149
}
150150

151151
// Append creates a new block and appends it to the ledger
152-
func (fl *fileLedger) Append(messages []*cb.Envelope, proof []byte) *cb.Block {
152+
func (fl *fileLedger) Append(messages []*cb.Envelope, metadata [][]byte) *cb.Block {
153153
data := &cb.BlockData{
154154
Data: make([][]byte, len(messages)),
155155
}
@@ -170,7 +170,7 @@ func (fl *fileLedger) Append(messages []*cb.Envelope, proof []byte) *cb.Block {
170170
},
171171
Data: data,
172172
Metadata: &cb.BlockMetadata{
173-
Metadata: [][]byte{proof},
173+
Metadata: metadata,
174174
},
175175
}
176176
fl.writeBlock(block)

orderer/rawledger/ramledger/ramledger.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ func (cu *cursor) ReadyChan() <-chan struct{} {
133133
}
134134

135135
// Append creates a new block and appends it to the ledger
136-
func (rl *ramLedger) Append(messages []*cb.Envelope, proof []byte) *cb.Block {
136+
func (rl *ramLedger) Append(messages []*cb.Envelope, metadata [][]byte) *cb.Block {
137137
data := &cb.BlockData{
138138
Data: make([][]byte, len(messages)),
139139
}
@@ -154,7 +154,7 @@ func (rl *ramLedger) Append(messages []*cb.Envelope, proof []byte) *cb.Block {
154154
},
155155
Data: data,
156156
Metadata: &cb.BlockMetadata{
157-
Metadata: [][]byte{proof},
157+
Metadata: metadata,
158158
},
159159
}
160160
rl.appendBlock(block)

orderer/rawledger/rawledger.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ type Reader interface {
4040
// Writer allows the caller to modify the raw ledger
4141
type Writer interface {
4242
// Append a new block to the ledger
43-
Append(blockContents []*cb.Envelope, proof []byte) *cb.Block
43+
Append(blockContents []*cb.Envelope, metadata [][]byte) *cb.Block
4444
}
4545

4646
// ReadWriter encapsulated both the reading and writing functions of the rawledger

orderer/sbft/backend/backend.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -302,7 +302,7 @@ func (t *Backend) Deliver(batch *s.Batch) {
302302
logger.Warningf("Payload cannot be unmarshalled.")
303303
}
304304
}
305-
t.ledger.Append(blockContents, []byte{})
305+
t.ledger.Append(blockContents, nil)
306306
}
307307

308308
func (t *Backend) Persist(key string, data proto.Message) {

0 commit comments

Comments
 (0)