Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/grpc/grpc-go
/ regenerateScheduler
Method
regenerateScheduler
balancer/weightedroundrobin/balancer.go:485–488 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
483
}
484
485
func
(p *picker) regenerateScheduler() {
486
s := p.newScheduler(true)
487
atomic.StorePointer(&p.scheduler, unsafe.Pointer(&s))
488
}
489
490
func
(p *picker) start(stopPicker *grpcsync.Event) {
491
p.regenerateScheduler()
Callers
2
start
Method · 0.95
TestWRR_Metrics_Scheduler_RR_Fallback
Method · 0.95
Calls
1
newScheduler
Method · 0.95
Tested by
1
TestWRR_Metrics_Scheduler_RR_Fallback
Method · 0.76