coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 18:37:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

mdbx: copy values on batch

Browse Source
This commit is contained in:
Victor Shyba 2025-05-24 02:12:15 -03:00
parent 53b0c9821b
commit a682134adc
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
node/store/mdbx.go
View File

@ -674,13 +674,19 @@ func (m *MDBXBatch) Commit() error {
// Delete implements Transaction.
func (m *MDBXBatch) Delete(key []byte) error {
m.operations = append(m.operations, BatchOperation{opcode: Delete, operand1: key})
keyCopy := make([]byte, len(key))
copy(keyCopy, key)
m.operations = append(m.operations, BatchOperation{opcode: Delete, operand1: keyCopy})
return nil
}
// DeleteRange implements Transaction.
func (m *MDBXBatch) DeleteRange(lowerBound []byte, upperBound []byte) error {
m.operations = append(m.operations, BatchOperation{opcode: DeleteRange, operand1: lowerBound, operand2: upperBound})
lowCopy := make([]byte, len(lowerBound))
copy(lowCopy, lowerBound)
upCopy := make([]byte, len(upperBound))
copy(upCopy, upperBound)
m.operations = append(m.operations, BatchOperation{opcode: DeleteRange, operand1: lowCopy, operand2: upCopy})
return nil
}
@ -696,7 +702,11 @@ func (m *MDBXBatch) NewIter(lowerBound []byte, upperBound []byte) (Iterator, err
// Set implements Transaction.
func (m *MDBXBatch) Set(key []byte, value []byte) error {
m.operations = append(m.operations, BatchOperation{opcode: Set, operand1: key, operand2: value})
keyCopy := make([]byte, len(key))
copy(keyCopy, key)
valueCopy := make([]byte, len(value))
copy(valueCopy, value)
m.operations = append(m.operations, BatchOperation{opcode: Set, operand1: keyCopy, operand2: valueCopy})
return nil
}