highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-10-06 22:43:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #8587 from zhiqiangxu/add_nil_check

Browse Source 
channeldb: check return value of ReadWriteBucket
This commit is contained in:
Oliver Gugger
2024-03-26 09:30:07 -06:00
committed by GitHub
parent d3e5b2f799 5fd46b0dce
commit b76f733a9e
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
channeldb/channel.go
View File

@@ -1157,7 +1157,13 @@ func fetchFinalHtlcsBucketRw(tx kvdb.RwTx,
func (c *OpenChannel) fullSync(tx kvdb.RwTx) error { func (c *OpenChannel) fullSync(tx kvdb.RwTx) error {
// Fetch the outpoint bucket and check if the outpoint already exists. // Fetch the outpoint bucket and check if the outpoint already exists.
opBucket := tx.ReadWriteBucket(outpointBucket) opBucket := tx.ReadWriteBucket(outpointBucket)
if opBucket == nil {
return ErrNoChanDBExists
}
cidBucket := tx.ReadWriteBucket(chanIDBucket) cidBucket := tx.ReadWriteBucket(chanIDBucket)
if cidBucket == nil {
return ErrNoChanDBExists
}
var chanPointBuf bytes.Buffer var chanPointBuf bytes.Buffer
if err := writeOutpoint(&chanPointBuf, &c.FundingOutpoint); err != nil { if err := writeOutpoint(&chanPointBuf, &c.FundingOutpoint); err != nil {
@@ -3513,6 +3519,9 @@ func (c *OpenChannel) CloseChannel(summary *ChannelCloseSummary,
// Fetch the outpoint bucket to see if the outpoint exists or // Fetch the outpoint bucket to see if the outpoint exists or
// not. // not.
opBucket := tx.ReadWriteBucket(outpointBucket) opBucket := tx.ReadWriteBucket(outpointBucket)
if opBucket == nil {
return ErrNoChanDBExists
}
// Add the closed outpoint to our outpoint index. This should // Add the closed outpoint to our outpoint index. This should
// replace an open outpoint in the index. // replace an open outpoint in the index.