MCPcopy
hub / github.com/grpc/grpc-go / newPickerWrapper

Function newPickerWrapper

picker_wrapper.go:53–59  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

51}
52
53func newPickerWrapper() *pickerWrapper {
54 pw := &pickerWrapper{}
55 pw.pickerGen.Store(&pickerGeneration{
56 blockingCh: make(chan struct{}),
57 })
58 return pw
59}
60
61// updatePicker is called by UpdateState calls from the LB policy. It
62// unblocks all blocked pick.

Callers 6

NewClientFunction · 0.85
TestBlockingPickMethod · 0.85

Calls

no outgoing calls