| 262 | } |
| 263 | |
| 264 | func (u *Unit) Mgrt(c, dst *Conn, exists bool) { |
| 265 | var rsp interface{} |
| 266 | defer func() { |
| 267 | if x := recover(); x != nil { |
| 268 | Panic("slotsmgrtone: c = %s, key = '%s', dst = %s, error = '%s', rsp = %v", c.Addr(), u.key, dst.Addr(), x, rsp) |
| 269 | } |
| 270 | }() |
| 271 | var err error |
| 272 | if rsp, err = c.Do("slotsmgrtone", dst.Host, dst.Port, Timeout, u.key); err != nil { |
| 273 | panic(err) |
| 274 | } |
| 275 | v := c.Int(rsp) |
| 276 | if exists && v != 1 { |
| 277 | panic("not exists") |
| 278 | } |
| 279 | } |
| 280 | |
| 281 | func (u *Unit) MgrtTag(c, dst *Conn, exists bool) { |
| 282 | var rsp interface{} |