(s *Slot, r *Request)
| 214 | } |
| 215 | |
| 216 | func (d *forwardHelper) forward2(s *Slot, r *Request) *BackendConn { |
| 217 | var database, seed = r.Database, r.Seed16() |
| 218 | if s.migrate.bc == nil && !r.IsMasterOnly() && len(s.replicaGroups) != 0 { |
| 219 | for _, group := range s.replicaGroups { |
| 220 | var i = seed |
| 221 | for range group { |
| 222 | i = (i + 1) % uint(len(group)) |
| 223 | if bc := group[i].BackendConn(database, seed, false); bc != nil { |
| 224 | return bc |
| 225 | } |
| 226 | } |
| 227 | } |
| 228 | } |
| 229 | return s.backend.bc.BackendConn(database, seed, true) |
| 230 | } |
no test coverage detected