MCPcopy Create free account
hub / github.com/rabbitstack/fibratus / close

Method close

pkg/util/va/ws.go:171–176  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

169}
170
171func (p *pool) close() {
172 close(p.free)
173 for w := range p.free {
174 w.close()
175 }
176}
177
178func newWorker() (*worker, error) {
179 w := &worker{

Callers 13

newPoolFunction · 0.95
TestNewWorkerCreatesValidHandlesFunction · 0.45
TestWorkerCloseIsIdempotentFunction · 0.45
TestWorkerSubmitSetsContextFunction · 0.45
TestNewPoolCreatesCorrectNumberOfWorkersFunction · 0.45
TestPoolAcquireReturnsWorkerFunction · 0.45
TestPoolAcquireReturnsNilWhenExhaustedFunction · 0.45
TestPoolReleaseHealthyWorkerReturnsItToPoolFunction · 0.45
TestPoolReleaseHealthyWorkerResetsContextFunction · 0.45
TestPoolReleasePoisonedWorkerSpawnsReplacementFunction · 0.45
TestPoolConcurrentAcquireReleaseFunction · 0.45
TestQueryWorkingSetPoolExhaustionFunction · 0.45

Calls

no outgoing calls

Tested by 11

TestNewWorkerCreatesValidHandlesFunction · 0.36
TestWorkerCloseIsIdempotentFunction · 0.36
TestWorkerSubmitSetsContextFunction · 0.36
TestNewPoolCreatesCorrectNumberOfWorkersFunction · 0.36
TestPoolAcquireReturnsWorkerFunction · 0.36
TestPoolAcquireReturnsNilWhenExhaustedFunction · 0.36
TestPoolReleaseHealthyWorkerReturnsItToPoolFunction · 0.36
TestPoolReleaseHealthyWorkerResetsContextFunction · 0.36
TestPoolReleasePoisonedWorkerSpawnsReplacementFunction · 0.36
TestPoolConcurrentAcquireReleaseFunction · 0.36
TestQueryWorkingSetPoolExhaustionFunction · 0.36