group chat log
This commit is contained in:
committed by
Xinwei Xiong(cubxxw-openim)
parent
57b70c0490
commit
4c5766b7af
@@ -261,7 +261,7 @@ func (rpc *rpcChat) SendMsg(_ context.Context, pb *pbChat.SendMsgReq) (*pbChat.S
|
|||||||
//split parallel send
|
//split parallel send
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
var sendTag bool
|
var sendTag bool
|
||||||
var split = 50
|
var split = 10
|
||||||
remain := len(memberUserIDList) % split
|
remain := len(memberUserIDList) % split
|
||||||
for i := 0; i < len(memberUserIDList)/split; i++ {
|
for i := 0; i < len(memberUserIDList)/split; i++ {
|
||||||
wg.Add(1)
|
wg.Add(1)
|
||||||
|
|||||||
Reference in New Issue
Block a user