1
0
Fork 0
mirror of https://github.com/chrislusf/seaweedfs synced 2025-09-08 20:32:47 +02:00
seaweedfs/weed/mq/logstore
Chris Lu 4af182f880
Context cancellation during reading range reading large files (#7093)
* context cancellation during reading range reading large files

* address comments

* cancellation for fuse read

* fix cancellation

* pass in context for each function to avoid racing condition

* Update reader_at_test.go

* remove dead code

* Update weed/filer/reader_at.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update weed/filer/filechunk_group.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update weed/filer/filechunk_group.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* address comments

* Update weed/mount/weedfs_file_read.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update weed/mount/weedfs_file_lseek.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update weed/mount/weedfs_file_read.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update weed/filer/reader_at.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update weed/mount/weedfs_file_lseek.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* test cancellation

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
2025-08-06 10:09:26 -07:00
..
log_to_parquet.go convert error fromating to %w everywhere (#6995) 2025-07-16 23:39:27 -07:00
merged_read.go merge current message queue code changes (#6201) 2024-11-04 12:08:25 -08:00
read_log_from_disk.go convert error fromating to %w everywhere (#6995) 2025-07-16 23:39:27 -07:00
read_parquet_to_log.go Context cancellation during reading range reading large files (#7093) 2025-08-06 10:09:26 -07:00