报错【bolt.Close(): funlock error: The segment is already unlocked】

[MrGlp]

报错【bolt.Close(): funlock error: The segment is already unlocked】

1. 代码中有一个 init 方法，每次服务直接终止，那么未完成的下载任务状态会变成 pause
   我会在 init 方法中调用 continueAll() 方法重新唤起未完成的任务，保障服务挂掉任务不丢失，随后就会报日志的错误

本次测试我启动了俩下载任务，就是左侧导航栏的两个文件夹，每次重启都会报这个错，有时候服务就会阻塞住

但是也有可能恢复服务启动成功

这个大概是什么原因，只知道锁已经释放，但是目前没分析出来出错的具体原因

[MrGlp]

init 方法是我代码中的，服务启动时候我期待重新唤起 上次异常终止的任务就这样写了

[monkeyWie]

可以给个能复现的代码吗，另外错误是在哪个地方触发打印的？

[MrGlp]

核心代码在这块，这个是我一个web服务下面的 init 方法，加上这行代码就报错【Downloader.ContinueAll() // TODO:初始化锁释放问题】

项目启动时候会先卡在红圈这里

卡大概几十秒然后下面正常执行
本地如果我有两个下载任务进行中，然后我直接停止服务，然后重新启动服务，初始化调用 ContinueAll() 方法就会报这错

报错日志是bbolt里面的日志

package downloader

import (
"fmt"
"github.com/GopeedLab/gopeed/pkg/base"
"github.com/GopeedLab/gopeed/pkg/download"
"github.com/GopeedLab/gopeed/pkg/protocol/http"
"runtime/debug"
)

// Downloader 初始化全局下载器
var Downloader *download.Downloader

// 初始化下载器
// 初始化离线下载文件存储路径 StorageDir
func init() {
defer func() {
if r := recover(); r != nil {
fmt.Printf("Recovered from panic: %v\n", r)
debug.PrintStack()
}
}()
downloadStoreCfg := &download.DownloaderStoreConfig{
FirstLoad: true, // 读取新配置
MaxRunning: 2000,
DownloadDir: "./library/download/base/", // 默认存储目录
ProtocolConfig: map[string]any{
"http": map[string]any{
"connections": 8,
},
"bt": map[string]any{
"trackerSubscribeUrls": []string{
"https://cf.trackerslist.com/best.txt",
},
"trackers": []string{
"udp://tracker.coppersurfer.tk:6969/announce",
"udp://tracker.leechers-paradise.org:6969/announce",
"udp://tracker.altrosky.nl:6969/announce",
"udp://opentracker.i2p.rocks:6969/announce",
},
},
}, //特殊协议支持
Extra: map[string]any{}, //额外配置信息
}
downloadCfg := &download.DownloaderConfig{
Storage: download.NewBoltStorage("./library/download/bolt/"), // bolt 存储, 事务保证
DownloaderStoreConfig: downloadStoreCfg,
}
downloadCfg.Init()
Downloader = download.NewDownloader(downloadCfg)
Downloader.Listener(func(event *download.Event) {
// ticker := time.NewTicker(10 * time.Second)
// defer ticker.Stop()
//OuterLoop:
// for {
// select {
// case <-ticker.C:
taskId := event.Task.ID

	speedInMB := float64(event.Task.Progress.Speed) / (1024 * 1024)
	fmt.Printf("taskId: %s speed: %.2f MB/s\n", taskId, speedInMB)

	progressPercentage := float64(event.Task.Progress.Downloaded) / float64(event.Task.Size) * 100
	fmt.Printf("taskId: %s transferred: %.2f%%\n", taskId, progressPercentage)

	switch event.Key {
	case download.EventKeyDone:

	case download.EventKeyFinally: // 调用 s3 上传 api
		fmt.Println("task 下载完成, taskId: ", taskId)
		break
	default:

	}
})

if err := Downloader.Setup(); err != nil {
	panic(err)
}
Downloader.PutConfig(downloadStoreCfg)
fmt.Println("Downloader init ok!")

// 每次重启下载服务后, 需要激活受影响的服务
Downloader.ContinueAll() // TODO:初始化锁释放问题

}

/*
type ReqExtra struct {
Method string json:"method"
Header map[string]string json:"header"
Body string json:"body"
}

type OptsExtra struct {
	Connections int `json:"connections"`
}

*/
func main() {
resolveRes, err := Downloader.Resolve(&base.Request{
URL: "https://www.baidu.com/index.htmlss",
})
if err != nil {
fmt.Println("resolver err")
panic(err)
}
fmt.Println("resolve_id", resolveRes.ID)

id, err := Downloader.Create(resolveRes.ID, &base.Options{
	Name: "testIndex.html",
	Path: "./download/gopeed/file2",
	Extra: http.OptsExtra{
		Connections: 8,
	},
})
if err != nil {
	panic(err)
}
fmt.Println("third_task_id", id)

}

[MrGlp]

Downloader.ContinueAll() // TODO:初始化锁释放问题

是这行代码导致的，他好像唤起了服务异常终止导致暂停的两个任务，然后两个任务开始恢复下载阶段报错

[MrGlp]

我这个就是一个 web 服务，上面那一大段是初始化下载器配置的 init 代码，最后那一行目的是想每次服务如果异常终止，重新启动服务的时候恢复下载的任务

但是加上目前确实会恢复，但是也会有那行报错

下载任务的接口代码感觉不用贴，那个没啥
最后的代码内容就这样，创建个下载任务就返回了
taskId, err = downloader.Downloader.Create(resolveRes.ID, options)
if err != nil {
panic(err)
}

return

[monkeyWie]

打个断点在错误日志输出的地方，看看堆栈是哪里触发的，而且看起来是文件句柄被占用导致无法关闭，你排查下是不是哪里还有占用数据库文件没有释放：

[MrGlp]

确实是我服务初始化的时候调用这个 continue 方法导致的报错，有两个任务，第二个任务调用 continue 就出错了

另外还有就是我这边生成了两个db，这种情况是不是不该出现，初始化的时候有问题了

[monkeyWie]

拉下最新的代码试试

[MrGlp]

拉取最新代码后这个问题解决了

请问下大概是啥原因，多任务锁释放问题么
另外我这边同时存在 .torrent.bolt.db 和 gopeed.db 俩文件应该是正常的吧，第一个是默认的位置不支持修改，功能不一样

[monkeyWie]

之前bt任务初始化的地方有并发问题，刚好修复掉了，两个db是正常的

[MrGlp]

多谢