(r *Request, d *Router)
| 366 | } |
| 367 | |
| 368 | func (s *Session) handleRequestInfo(r *Request, d *Router) error { |
| 369 | var addr string |
| 370 | var nblks = len(r.Multi) - 1 |
| 371 | switch { |
| 372 | case nblks == 0: |
| 373 | slot := uint32(time.Now().Nanosecond()) % MaxSlotNum |
| 374 | return d.dispatchSlot(r, int(slot)) |
| 375 | default: |
| 376 | addr = string(r.Multi[1].Value) |
| 377 | copy(r.Multi[1:], r.Multi[2:]) |
| 378 | r.Multi = r.Multi[:nblks] |
| 379 | } |
| 380 | if !d.dispatchAddr(r, addr) { |
| 381 | r.Resp = redis.NewErrorf("ERR backend server '%s' not found", addr) |
| 382 | return nil |
| 383 | } |
| 384 | return nil |
| 385 | } |
| 386 | |
| 387 | func (s *Session) handleRequestMGet(r *Request, d *Router) error { |
| 388 | var nkeys = len(r.Multi) - 1 |
no test coverage detected