(addr string)
| 107 | } |
| 108 | |
| 109 | func (d *db) delServerStatus(addr string) (err error) { |
| 110 | if d == nil { |
| 111 | return errDBConn |
| 112 | } |
| 113 | if addr == "" { |
| 114 | return errParam |
| 115 | } |
| 116 | d.statusLock.Lock() |
| 117 | defer d.statusLock.Unlock() |
| 118 | if err = d.sdb.Where("server_addr = ?", addr).Delete(&serverStatus{}).Error; err != nil { |
| 119 | // logrus.Errorln(logPrefix+"deleteSubscribe ERROR: ", err) |
| 120 | return |
| 121 | } |
| 122 | return |
| 123 | } |
| 124 | |
| 125 | // 新增订阅 |
| 126 | func (d *db) newSubscribe(addr string, targetID, targetType int64) (err error) { |
no outgoing calls