storage/sqlite/new.go                 | 10 +++++-----
 storage/sqlite/sqlite-storage_test.go | 41 +++++++++++++++++++++++++++--------------

diff --git a/storage/sqlite/new.go b/storage/sqlite/new.go
index 99a5c33a8e5c9ef1d74bd1509dc7ad7b2455180e..2ce6ac445960f27d88269f08564db8bf13e0eeff 100644
--- a/storage/sqlite/new.go
+++ b/storage/sqlite/new.go
@@ -98,16 +98,16 @@ 	blob   **sqlite.Blob
 }
 
 func (p2 piece) getBlob() *sqlite.Blob {
+	rowid, err := rowidForBlob(p2.conn, p2.name, p2.length)
+	if err != nil {
+		panic(err)
+	}
 	if *p2.blob != nil {
 		err := (*p2.blob).Close()
 		if err != nil {
 			panic(err)
 		}
 		*p2.blob = nil
-	}
-	rowid, err := rowidForBlob(p2.conn, p2.name, p2.length)
-	if err != nil {
-		panic(err)
 	}
 	*p2.blob, err = p2.conn.OpenBlob("main", "blob", "data", rowid, true)
 	if err != nil {
@@ -144,7 +144,7 @@ 	return nil
 }
 
 func (p2 piece) MarkNotComplete() error {
-	panic("implement me")
+	return sqlitex.Exec(p2.conn, "update blob set verified=false where name=?", nil, p2.name)
 }
 
 func (p2 piece) Completion() (ret storage.Completion) {
diff --git a/storage/sqlite/sqlite-storage_test.go b/storage/sqlite/sqlite-storage_test.go
index a903e3a9c5bd37b3093952b39810199dddec27b1..ff4511af9be41e6d1a2788652a8ef4b14ec880f5 100644
--- a/storage/sqlite/sqlite-storage_test.go
+++ b/storage/sqlite/sqlite-storage_test.go
@@ -76,21 +76,34 @@ 			for _, batchWrites := range []bool{false, true} {
 				b.Run(fmt.Sprintf("BatchWrites=%v", batchWrites), func(b *testing.B) {
 					dbPath := filepath.Join(b.TempDir(), "storage.db")
 					//b.Logf("storage db path: %q", dbPath)
-					ci, err := NewPiecesStorage(NewPiecesStorageOpts{
-						NewPoolOpts: NewPoolOpts{
-							Path:                  dbPath,
-							Capacity:              4*pieceSize - 1,
-							NoConcurrentBlobReads: false,
-							PageSize:              1 << 14,
-							Memory:                memory,
-						},
-						ProvOpts: func(opts *ProviderOpts) {
-							opts.BatchWrites = batchWrites
-						},
+					newPoolOpts := NewPoolOpts{
+						Path:                  dbPath,
+						Capacity:              4*pieceSize - 1,
+						NoConcurrentBlobReads: false,
+						PageSize:              1 << 14,
+						Memory:                memory,
+					}
+					provOpts := func(opts *ProviderOpts) {
+						opts.BatchWrites = batchWrites
+					}
+					b.Run("SqlitePieceStorage", func(b *testing.B) {
+						ci, err := NewPiecesStorage(NewPiecesStorageOpts{
+							NewPoolOpts: newPoolOpts,
+							ProvOpts:    provOpts,
+						})
+						c.Assert(err, qt.IsNil)
+						defer ci.Close()
+						test_storage.BenchmarkPieceMarkComplete(b, ci, pieceSize, test_storage.DefaultNumPieces, capacity)
+					})
+					b.Run("SqliteDirect", func(b *testing.B) {
+						ci, err := NewDirectStorage(NewDirectStorageOpts{
+							NewPoolOpts: newPoolOpts,
+							ProvOpts:    provOpts,
+						})
+						c.Assert(err, qt.IsNil)
+						defer ci.Close()
+						test_storage.BenchmarkPieceMarkComplete(b, ci, pieceSize, test_storage.DefaultNumPieces, capacity)
 					})
-					c.Assert(err, qt.IsNil)
-					defer ci.Close()
-					test_storage.BenchmarkPieceMarkComplete(b, ci, pieceSize, test_storage.DefaultNumPieces, capacity)
 				})
 			}
 		})