.

go/neo/storage.go

@@ -156,6 +156,11 @@ func (stor *Storage) Run(ctx context.Context, l xnet.Listener) (err error) {
 	serveCancel()
 	wg.Wait()
 
+	err2 := stor.back.Close()
+	if err == nil {
+		err = err2
+	}
+
 	return err // XXX err ctx
 }
 

go/neo/storage/fs1/fs1.go

@@ -56,6 +56,9 @@ func Open(ctx context.Context, path string) (*Backend, error) {
 	return &Backend{zstor: zstor}, nil
 }
 
+func (f *Backend) Close() error {
+	return f.zstor.Close()
+}
 
 func (f *Backend) LastTid(ctx context.Context) (zodb.Tid, error) {
 	return f.zstor.Sync(ctx)

go/neo/storage/storage.go

@@ -47,6 +47,8 @@ type Backend interface {
 
 	// Load, similarly to zodb.IStorageDriver.Load should load object data addressed by xid.
 	Load(ctx context.Context, xid zodb.Xid) (*proto.AnswerObject, error)
+
+	Close() error
 }
 
 // BackendOpener is a function to open a NEO storage backend