136
// TODO(pri): ForwarderMaxOutstandingTasks > 1 is not supported: it will cause alternating
137
// tasks to be sent to the validator, which will make the validator not validate anything.
139
>
go tm.forwardTasks(lim, retrier)
140
>
}
141
142
>
if normal, ok := tm.partition.(*tqid.NormalPartition); ok { // always true here, sticky has nil tm.fwdr
pri_matcher.go
143
>
degree := tm.config.ForwarderMaxChildrenPerNode()
144
>
if parent, err := normal.ParentPartition(degree); err == nil {
145
>
for range tm.config.ForwarderMaxOutstandingPolls() {
146
>
go tm.forwardPolls(tm.tqCtx, 0, pollForwarderPriority, parentPollForwarder, parent)
147
>
}
148
}
149
}