mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-08 20:11:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

torrent: don't cancel storage, because lib can't handle such error and can graceful-shutdown anyway (#937)

Browse Source
This commit is contained in:
Alex Sharov 2023-03-14 15:40:30 +07:00 committed by GitHub
parent b7f18a5de1
commit 474982ecaf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
downloader/mdbx_piece_completion.go
View File

@ -33,18 +33,17 @@ const (
type mdbxPieceCompletion struct {
db kv.RwDB
ctx context.Context
}
var _ storage.PieceCompletion = (*mdbxPieceCompletion)(nil)
func NewMdbxPieceCompletion(ctx context.Context, db kv.RwDB) (ret storage.PieceCompletion, err error) {
ret = &mdbxPieceCompletion{ctx: ctx, db: db}
func NewMdbxPieceCompletion(db kv.RwDB) (ret storage.PieceCompletion, err error) {
ret = &mdbxPieceCompletion{db: db}
return
}
func (m mdbxPieceCompletion) Get(pk metainfo.PieceKey) (cn storage.Completion, err error) {
err = m.db.View(m.ctx, func(tx kv.Tx) error {
err = m.db.View(context.Background(), func(tx kv.Tx) error {
var key [infohash.Size + 4]byte
copy(key[:], pk.InfoHash[:])
binary.BigEndian.PutUint32(key[infohash.Size:], uint32(pk.Index))
@ -84,12 +83,12 @@ func (m mdbxPieceCompletion) Set(pk metainfo.PieceKey, b bool) error {
// 1K fsyncs/2minutes it's quite expensive, but even on cloud (high latency) drive it allow download 100mb/s
// and Erigon doesn't do anything when downloading snapshots
if b {
tx, err = m.db.BeginRwNosync(m.ctx)
tx, err = m.db.BeginRwNosync(context.Background())
if err != nil {
return err
}
} else {
tx, err = m.db.BeginRw(m.ctx)
tx, err = m.db.BeginRw(context.Background())
if err != nil {
return err
}