Function AckReadThread

internal/utils/bfs/threads_limiter.go:11–13 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

9	var writeThreadsLimiter = make(chan zero.Zero, 8)
10
11	func AckReadThread() {
12	readThreadsLimiter <- zero.Zero{}
13	}
14
15	func ReleaseReadThread() {
16	<-readThreadsLimiter

ReadAtMethod · 0.85

NewBlocksFileWithRawFileFunction · 0.85

OpenFileReaderMethod · 0.85

loadMethod · 0.85

WriteCloseMethod · 0.85

CompactMethod · 0.85

no outgoing calls

no test coverage detected