1
This commit is contained in:
parent
251bdb0e54
commit
4b99b28a97
@ -274,6 +274,9 @@ func (this *mailMgr) addMail(m *mail) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (this *mailMgr) updateMail(m *mail) {
|
||||||
|
}
|
||||||
|
|
||||||
func (this *mailMgr) addGroup(g *userGroup) {
|
func (this *mailMgr) addGroup(g *userGroup) {
|
||||||
this.groupHash.Store(g.groupId, g)
|
this.groupHash.Store(g.groupId, g)
|
||||||
}
|
}
|
||||||
@ -395,6 +398,13 @@ func (this* mailMgr) procMailUpdate(e *dbEvent) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
if ds.Next() {
|
||||||
|
p := newMail()
|
||||||
|
p.loadFromDb(ds)
|
||||||
|
this.updateMail(p)
|
||||||
|
} else {
|
||||||
|
panic(fmt.Sprintf("procMailUpdate error:%s", err));
|
||||||
|
}
|
||||||
e.entry.DelInit()
|
e.entry.DelInit()
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user