From 0d1558fa7cabaf35f7da9adf0f5a5804c9404f2a Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期三, 01 十二月 2021 14:42:59 +0800
Subject: [PATCH] foreach 添加error返回
---
bolt_store.go | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/bolt_store.go b/bolt_store.go
index 505e2ea..368467a 100644
--- a/bolt_store.go
+++ b/bolt_store.go
@@ -242,10 +242,10 @@
return tx.Commit()
}
-func (b *BoltStore) ForEach(f func(lc *LogCon) error) {
+func (b *BoltStore) ForEach(f func(lc *LogCon) error) error {
tx, err := b.conn.Begin(true)
if err != nil {
- return
+ return err
}
defer tx.Rollback()
@@ -256,13 +256,13 @@
cLog := &confLog{}
err := b.GetConfLog(start, cLog)
if err != nil {
- return
+ return err
}
bucketName := cLog.BucketName
bucket := tx.Bucket([]byte(bucketName))
if bucket == nil {
- return
+ return err
}
bucket.ForEach(func(k, v []byte) error {
@@ -275,6 +275,8 @@
return err
})
}
+
+ return nil
}
func (b *BoltStore) Delete(lc *LogCon) error {
--
Gitblit v1.8.0