mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-05-19 00:01:31 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
enhance-erasure-coding
seaweedfs/weed/util/log_buffer
History
Chris Lu 7d147f238c avoid repeated reading disk (#7369) 
* avoid repeated reading disk

* checks both flush time AND read position advancement

* wait on cond

* fix reading

Gap detection and skipping to earliest memory time
Time-based reads that include events at boundary times for first reads (offset ≤ 0)
Aggregated subscriber wake-up via ListenersWaits signaling

* address comments
2025-10-24 01:26:42 -07:00
..
disk_buffer_cache.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
log_buffer_flush_gap_test.go
Fixes for kafka gateway (#7329)
2025-10-17 20:49:47 -07:00
log_buffer_queryability_test.go
avoid repeated reading disk (#7369)
2025-10-24 01:26:42 -07:00
log_buffer_test.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
log_buffer.go
avoid repeated reading disk (#7369)
2025-10-24 01:26:42 -07:00
log_read_integration_test.go
Fixes for kafka gateway (#7329)
2025-10-17 20:49:47 -07:00
log_read_stateless_test.go
Fixes for kafka gateway (#7329)
2025-10-17 20:49:47 -07:00
log_read_stateless.go
avoid repeated reading disk (#7369)
2025-10-24 01:26:42 -07:00
log_read_test.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
log_read.go
avoid repeated reading disk (#7369)
2025-10-24 01:26:42 -07:00
sealed_buffer.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00