diff --git a/weed/storage/store.go b/weed/storage/store.go index 5343ec12d..389980667 100644 --- a/weed/storage/store.go +++ b/weed/storage/store.go @@ -161,7 +161,11 @@ func NewStore( func (s *Store) LoadState() error { err := s.State.Load() if s.State.Pb != nil && err == nil { - s.StateUpdateChan <- s.State.Pb + select { + case s.StateUpdateChan <- s.State.Pb: + default: + glog.V(2).Infof("StateUpdateChan full during LoadState, state will be reported in heartbeat") + } } return err } @@ -174,7 +178,11 @@ func (s *Store) SaveState() error { err := s.State.Save() if s.State.Pb != nil && err == nil { - s.StateUpdateChan <- s.State.Pb + select { + case s.StateUpdateChan <- s.State.Pb: + default: + glog.V(2).Infof("StateUpdateChan full during SaveState, state will be reported in heartbeat") + } } return err }