gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

storage: use non-blocking send to StateUpdateChan

Browse Source
This commit is contained in:
Chris Lu
2026-01-12 10:49:26 -08:00
parent 2af293ce60
commit 587e782feb
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
weed/storage/store.go
View File

@@ -161,7 +161,11 @@ func NewStore(
func (s *Store) LoadState() error { func (s *Store) LoadState() error {
err := s.State.Load() err := s.State.Load()
if s.State.Pb != nil && err == nil { 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 return err
} }
@@ -174,7 +178,11 @@ func (s *Store) SaveState() error {
err := s.State.Save() err := s.State.Save()
if s.State.Pb != nil && err == nil { 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 return err
} }