akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

channeldb: convert invoice settle/cancel calls to use Batch

Browse Source
This commit is contained in:
Olaoluwa Osuntokun 2019-03-13 13:34:19 -07:00
parent e8da6dd0b4
commit da76c34418
No known key found for this signature in database
GPG Key ID: CE58F7F8E20FD9A2
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
channeldb/invoices.go
View File

@ -242,7 +242,9 @@ func (d *DB) AddInvoice(newInvoice *Invoice, paymentHash lntypes.Hash) (
}
var invoiceAddIndex uint64
err := d.Update(func(tx *bbolt.Tx) error {
err := d.Batch(func(tx *bbolt.Tx) error {
invoiceAddIndex = 0
invoices, err := tx.CreateBucketIfNotExists(invoiceBucket)
if err != nil {
return err
@ -635,7 +637,9 @@ func (d *DB) AcceptOrSettleInvoice(paymentHash [32]byte,
amtPaid lnwire.MilliSatoshi) (*Invoice, error) {
var settledInvoice *Invoice
err := d.Update(func(tx *bbolt.Tx) error {
err := d.Batch(func(tx *bbolt.Tx) error {
settledInvoice = nil
invoices, err := tx.CreateBucketIfNotExists(invoiceBucket)
if err != nil {
return err
@ -714,7 +718,9 @@ func (d *DB) SettleHoldInvoice(preimage lntypes.Preimage) (*Invoice, error) {
// payment hash.
func (d *DB) CancelInvoice(paymentHash lntypes.Hash) (*Invoice, error) {
var canceledInvoice *Invoice
err := d.Update(func(tx *bbolt.Tx) error {
err := d.Batch(func(tx *bbolt.Tx) error {
canceledInvoice = nil
invoices, err := tx.CreateBucketIfNotExists(invoiceBucket)
if err != nil {
return err