gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

avoid data race access to startDelay (#3548)

Browse source
This commit is contained in:
Konstantin Lebedev 2022-08-30 12:02:09 +05:00 committed by GitHub
parent 570b488572
commit 903a06a160
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
weed/command/filer.go
View file

@ -173,29 +173,29 @@ func runFiler(cmd *Command, args []string) bool {
if *f.dataCenter != "" && *filerS3Options.dataCenter == "" { if *f.dataCenter != "" && *filerS3Options.dataCenter == "" {
filerS3Options.dataCenter = f.dataCenter filerS3Options.dataCenter = f.dataCenter
} }
go func() { go func(delay time.Duration) {
time.Sleep(startDelay * time.Second) time.Sleep(delay * time.Second)
filerS3Options.startS3Server() filerS3Options.startS3Server()
}() }(startDelay)
startDelay++ startDelay++
} }
if *filerStartWebDav { if *filerStartWebDav {
filerWebDavOptions.filer = &filerAddress filerWebDavOptions.filer = &filerAddress
go func() { go func(delay time.Duration) {
time.Sleep(startDelay * time.Second) time.Sleep(delay * time.Second)
filerWebDavOptions.startWebDav() filerWebDavOptions.startWebDav()
}() }(startDelay)
startDelay++ startDelay++
} }
if *filerStartIam { if *filerStartIam {
filerIamOptions.filer = &filerAddress filerIamOptions.filer = &filerAddress
filerIamOptions.masters = f.mastersString filerIamOptions.masters = f.mastersString
go func() { go func(delay time.Duration) {
time.Sleep(startDelay * time.Second) time.Sleep(delay * time.Second)
filerIamOptions.startIamServer() filerIamOptions.startIamServer()
}() }(startDelay)
} }
f.masters = pb.ServerAddresses(*f.mastersString).ToAddressMap() f.masters = pb.ServerAddresses(*f.mastersString).ToAddressMap()