diff --git a/index/store/moss/store.go b/index/store/moss/store.go index d0676412..a7aa4d41 100644 --- a/index/store/moss/store.go +++ b/index/store/moss/store.go @@ -175,14 +175,15 @@ func New(mo store.MergeOperator, config map[string]interface{}) ( } func (s *Store) Close() error { - if v, ok := s.config["mossAbortCloseEnabled"]; ok && v.(bool) == true { - if msw, ok := s.llstore.(*mossStoreWrapper); ok { - if s := msw.Actual(); s != nil { - _ = s.CloseEx(moss.StoreCloseExOptions{Abort: true}) + if val, ok := s.config["mossAbortCloseEnabled"]; ok { + if v, ok := val.(bool); ok && v { + if msw, ok := s.llstore.(*mossStoreWrapper); ok { + if s := msw.Actual(); s != nil { + _ = s.CloseEx(moss.StoreCloseExOptions{Abort: true}) + } } } } - return s.ms.Close() }