diff options
| author | Mariano Ntrougkas <44480600+marios1861@users.noreply.github.com> | 2025-10-24 03:09:46 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-10-23 17:09:46 -0700 |
| commit | f06ddd05cc148e2fc9ea60566ca4f6346e1f2762 (patch) | |
| tree | 22c3b1ced2b78778e1a2c1eca8e1d1553e7cf957 /weed/s3api/s3api_streaming_copy.go | |
| parent | 557aa4ec097267ff31e34a5c2fdd7b256e42d1be (diff) | |
| download | seaweedfs-f06ddd05cc148e2fc9ea60566ca4f6346e1f2762.tar.xz seaweedfs-f06ddd05cc148e2fc9ea60566ca4f6346e1f2762.zip | |
Improve-worker (#7367)
* ♻️ refactor(worker): remove goto
* ♻️ refactor(worker): let manager loop exit by itself
* ♻️ refactor(worker): fix race condition when closing worker
CloseSend is not safe to call when another
goroutine concurrently calls Send. streamCancel
already handles proper stream closure. Also,
streamExit signal should be called AFTER
sending shutdownMsg
Now the worker has no race condition if stopped
during any moment (hopefully, tested with -race
flag)
* 🐛 fix(task_logger): deadlock in log closure
* 🐛 fix(balance): fix balance task
Removes the outdated "UnloadVolume" step as it is handled by "DeleteVolume".
#7346
Diffstat (limited to 'weed/s3api/s3api_streaming_copy.go')
0 files changed, 0 insertions, 0 deletions