当前位置：网站首页>Chang'an chain learning research - storage analysis wal mechanism

Chang'an chain learning research - storage analysis wal mechanism

2022-07-19 14:57:00 【InfoQ】

This article has participated in 「 Open source star picking program 」, Welcome to join us . Activity Links ：
https://github.com/weopenprojects/WeOpen-Star

func (bc *Blockchain) initStore() (err error) blockchain_init.go
 func (m *Factory) NewStore(chainId string, storeConfig *conf.StorageConfig, logger protocol.Logger, p11Handle *pkcs11.P11Handle) (protocol.BlockchainStore, error) store_factory.go
null
Register compass data encryption , Don't look at , Look at the registration first wal
//  register wal  perhaps bfdb
if err = m.registerFileOrLogDB(chainId, storeConfig, logger); err != nil {
 return err
}
//  register bfdb perhaps wal
func (m *Factory) registerFileOrLogDB(chainId string, storeConfig *conf.StorageConfig, logger protocol.Logger) error {
var (
err error
bfdb *blockfiledb.BlockFile
walLog *wal.Log
)
// Handle  bfdb, To complete the registration
if !storeConfig.DisableBlockFileDb {
opts := blockfiledb.DefaultOptions
opts.NoCopy = true
opts.NoSync = storeConfig.LogDBSegmentAsync
if storeConfig.LogDBSegmentSize > 64 { // LogDBSegmentSize default is 64MB
opts.SegmentSize = storeConfig.LogDBSegmentSize * 1024 * 1024
}

bfdbPath := filepath.Join(storeConfig.StorePath, chainId, blockFilePath)
bfdb, err = blockfiledb.Open(bfdbPath, opts, logger)
if err != nil {
panic(fmt.Sprintf("open block file db failed, path:%s, error:%s", bfdbPath, err))
}
return m.ioc.Register(func() binlog.BinLogger { return bfdb })
}
// Handle  wal, To complete the registration
opts := wal.DefaultOptions
opts.NoCopy = true
opts.NoSync = storeConfig.LogDBSegmentAsync
if storeConfig.LogDBSegmentSize > 0 {
// LogDBSegmentSize default is 20MB
opts.SegmentSize = storeConfig.LogDBSegmentSize * 1024 * 1024
}

walPath := filepath.Join(storeConfig.StorePath, chainId, walLogPath)
walLog, err = wal.Open(walPath, opts)
if err != nil {
panic(fmt.Sprintf("open wal log failed, path:%s, error:%s", walPath, err))
}
return m.ioc.Register(func() *wal.Log { return walLog })
}
The default is forbidden , Don't go bfdb This piece of
null
wal Address
By the storage path of the configuration file +chainid +wallogpath Path composition ：
null
Configuration file ledger storage path ：
null
chainid:
null
wal route ：
null
So the composed path is the path position spliced above
This is wal.open Method creates one wallog, Registered to ioc In the container
walLog, err = wal.Open(walPath, opts)
return m.ioc.Register(func() *wal.Log { return walLog })
  Get into open Look in the method
l := &Log{path: path, opts: *opts}  Create a log example
l.scache.Resize(l.opts.SegmentCacheSize) 
if err := os.MkdirAll(path, 0777); err != nil {  establish wal Daily path
return nil, err
}
if err := l.load(); err != nil 
The core is l.load The method , Study tomorrow .

Previous tls The connection problem is solved , The reason is that Alibaba cloud environment may have special treatment , Lead to sdk When connecting , Because it is not a formal certificate , Directly be rst 了 , Unable to shake hands successfully .
原网站

版权声明
本文为[InfoQ]所创，转载请带上原文链接，感谢
https://yzsam.com/2022/200/202207172204491016.html

边栏推荐

猜你喜欢

随机推荐