diff options
| author | chrislu <chris.lu@gmail.com> | 2022-09-01 13:08:34 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-09-01 13:08:34 -0700 |
| commit | d1bb23645e7a16430e712bd0ea0c768082bea8e3 (patch) | |
| tree | 123184c7635b1f578884c5ec5d0e4c64f8122e64 | |
| parent | c37d6fc01a8b70ea3686a81c2acf9d3da0b5ef09 (diff) | |
| download | seaweedfs-d1bb23645e7a16430e712bd0ea0c768082bea8e3.tar.xz seaweedfs-d1bb23645e7a16430e712bd0ea0c768082bea8e3.zip | |
Revert "avoid data race on grace.hooks (#3572)"
This reverts commit c37d6fc01a8b70ea3686a81c2acf9d3da0b5ef09.
| -rw-r--r-- | weed/util/grace/signal_handling.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/weed/util/grace/signal_handling.go b/weed/util/grace/signal_handling.go index 24d2b184f..fc7afcad9 100644 --- a/weed/util/grace/signal_handling.go +++ b/weed/util/grace/signal_handling.go @@ -12,7 +12,7 @@ import ( var signalChan chan os.Signal var hooks = make([]func(), 0) -var hookLock sync.RWMutex +var hookLock sync.Mutex func init() { signalChan = make(chan os.Signal, 1) @@ -27,9 +27,7 @@ func init() { // syscall.SIGQUIT, ) go func() { - hookLock.RLock() - defer hookLock.RUnlock() - for range signalChan { + for _ = range signalChan { for _, hook := range hooks { hook() } |