Add missing closed check in sqlite piece completion Get

diff --git a/storage/sqlite-piece-completion.go b/storage/sqlite-piece-completion.go
index 73407f3f235e0b6d32ec4aa8db6c6d0ff6198bfd..7005dacb575daf450fdc78da4f10843de6198531 100644 (file)
--- a/storage/sqlite-piece-completion.go
+++ b/storage/sqlite-piece-completion.go
@@ -48,6 +48,10 @@ func NewSqlitePieceCompletion(dir string) (ret *sqlitePieceCompletion, err error
 func (me *sqlitePieceCompletion) Get(pk metainfo.PieceKey) (c Completion, err error) {
        me.mu.Lock()
        defer me.mu.Unlock()
+       if me.closed {
+               err = errors.New("closed")
+               return
+       }
        err = sqlitex.Exec(
                me.db, `select complete from piece_completion where infohash=? and "index"=?`,
                func(stmt *sqlite.Stmt) error {