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

channeldb: temporary hack...

Browse Source 
Need to add a channeldb.NewOpenChannel() method to once again allow a
channel’s db pointer to be private.
This commit is contained in:
Olaoluwa Osuntokun 2016-03-24 00:00:22 -07:00
parent 87603e780f
commit afb45ffe8b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
channeldb/channel.go
View File

@ -149,7 +149,8 @@ type OpenChannel struct {
// TODO(roasbeef): scrap? already have snapshots now? // TODO(roasbeef): scrap? already have snapshots now?
isPrevState bool isPrevState bool
db *DB // TODO(roasbeef): eww
Db *DB
sync.RWMutex sync.RWMutex
} }
@ -201,7 +202,7 @@ func (c OpenChannel) RecordChannelDelta(theirRevokedCommit *wire.MsgTx, updateNu
// NOTE: This method requires an active EncryptorDecryptor to be registered in // NOTE: This method requires an active EncryptorDecryptor to be registered in
// order to encrypt sensitive information. // order to encrypt sensitive information.
func (c *OpenChannel) FullSync() error { func (c *OpenChannel) FullSync() error {
return c.db.store.Update(func(tx *bolt.Tx) error { return c.Db.store.Update(func(tx *bolt.Tx) error {
// First fetch the top level bucket which stores all data related to // First fetch the top level bucket which stores all data related to
// current, active channels. // current, active channels.
chanBucket := tx.Bucket(openChannelBucket) chanBucket := tx.Bucket(openChannelBucket)
@ -213,7 +214,7 @@ func (c *OpenChannel) FullSync() error {
return err return err
} }
return putOpenChannel(chanBucket, nodeChanBucket, c, c.db.cryptoSystem) return putOpenChannel(chanBucket, nodeChanBucket, c, c.Db.cryptoSystem)
}) })
} }