From afb45ffe8bb9b208095b6153b78c9a3e0ffc2c73 Mon Sep 17 00:00:00 2001 From: Olaoluwa Osuntokun Date: Thu, 24 Mar 2016 00:00:22 -0700 Subject: [PATCH] channeldb: temporary hack... MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Need to add a channeldb.NewOpenChannel() method to once again allow a channel’s db pointer to be private. --- channeldb/channel.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/channeldb/channel.go b/channeldb/channel.go index 933de6dba..740c0c8de 100644 --- a/channeldb/channel.go +++ b/channeldb/channel.go @@ -149,7 +149,8 @@ type OpenChannel struct { // TODO(roasbeef): scrap? already have snapshots now? isPrevState bool - db *DB + // TODO(roasbeef): eww + Db *DB 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 // order to encrypt sensitive information. 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 // current, active channels. chanBucket := tx.Bucket(openChannelBucket) @@ -213,7 +214,7 @@ func (c *OpenChannel) FullSync() error { return err } - return putOpenChannel(chanBucket, nodeChanBucket, c, c.db.cryptoSystem) + return putOpenChannel(chanBucket, nodeChanBucket, c, c.Db.cryptoSystem) }) }