diff options
| author | chrislu <chris.lu@gmail.com> | 2022-08-27 00:19:13 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-08-27 00:19:13 -0700 |
| commit | 580a7fa685da41c9968c38351340e34d24683bdf (patch) | |
| tree | 6aa95c875c2a98ab3b56a65c36ad2b6252b2802b | |
| parent | 87b70a6809fd4ca0f6fc557314966d459d77302b (diff) | |
| download | seaweedfs-580a7fa685da41c9968c38351340e34d24683bdf.tar.xz seaweedfs-580a7fa685da41c9968c38351340e34d24683bdf.zip | |
adjust for data race
fix https://github.com/seaweedfs/seaweedfs/issues/3512
| -rw-r--r-- | weed/server/filer_server_handlers_write_upload.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/filer_server_handlers_write_upload.go b/weed/server/filer_server_handlers_write_upload.go index c4565b08b..519f989c0 100644 --- a/weed/server/filer_server_handlers_write_upload.go +++ b/weed/server/filer_server_handlers_write_upload.go @@ -57,14 +57,14 @@ func (fs *FilerServer) uploadReaderToChunks(w http.ResponseWriter, r *http.Reque // need to throttle used byte buffer bytesBufferLimitCond.L.Lock() for atomic.LoadInt64(&bytesBufferCounter) >= 4 { - glog.V(4).Infof("waiting for byte buffer %d", bytesBufferCounter) + glog.V(4).Infof("waiting for byte buffer %d", atomic.LoadInt64(&bytesBufferCounter)) bytesBufferLimitCond.Wait() } atomic.AddInt64(&bytesBufferCounter, 1) bytesBufferLimitCond.L.Unlock() bytesBuffer := bufPool.Get().(*bytes.Buffer) - glog.V(4).Infof("received byte buffer %d", bytesBufferCounter) + glog.V(4).Infof("received byte buffer %d", atomic.LoadInt64(&bytesBufferCounter)) limitedReader := io.LimitReader(partReader, int64(chunkSize)) |