1
This commit is contained in:
parent
7e782bf715
commit
b00a8aac22
@ -139,7 +139,10 @@ func (this *mailMgr) addMail(m *mail) {
|
|||||||
this.groupMails.Store(m.mailId, m)
|
this.groupMails.Store(m.mailId, m)
|
||||||
} else if m.isType(constant.MAIL_TYPE_PERSONAL) {
|
} else if m.isType(constant.MAIL_TYPE_PERSONAL) {
|
||||||
if hum, ok := this.personalMails.Load(m.reciver); ok {
|
if hum, ok := this.personalMails.Load(m.reciver); ok {
|
||||||
(hum.(*sync.Map)).Store(m.mailId, m)
|
(hum.(*sync.Map)).Range(
|
||||||
|
func (k, v interface{}) bool {
|
||||||
|
return true
|
||||||
|
})
|
||||||
} else {
|
} else {
|
||||||
p := new(sync.Map)
|
p := new(sync.Map)
|
||||||
p.Store(m.mailId, m)
|
p.Store(m.mailId, m)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user