| 279 | } |
| 280 | |
| 281 | func (u *Unit) MgrtTag(c, dst *Conn, exists bool) { |
| 282 | var rsp interface{} |
| 283 | defer func() { |
| 284 | if x := recover(); x != nil { |
| 285 | Panic("slotsmgrttagone: c = %s, key = '%s', dst = %s, error = '%s', rsp = %v", c.Addr(), u.key, dst.Addr(), x, rsp) |
| 286 | } |
| 287 | }() |
| 288 | var err error |
| 289 | if rsp, err = c.Do("slotsmgrttagone", dst.Host, dst.Port, Timeout, u.key); err != nil { |
| 290 | panic(err) |
| 291 | } |
| 292 | v := c.Int(rsp) |
| 293 | if exists && v == 0 { |
| 294 | panic("not exists") |
| 295 | } |
| 296 | } |
| 297 | |
| 298 | func (u *Unit) Incr(c *Conn) { |
| 299 | var rsp interface{} |