0
0

Adding guards for config casting.

This commit is contained in:
Sreekanth Sivasankaran 2017-03-07 22:51:27 +05:30
parent 0cdd0b38e2
commit f759d841c2

View File

@ -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()
}