mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-26 03:26:57 +08:00
log
This commit is contained in:
parent
883e7f96ee
commit
04a9788bc0
@ -272,7 +272,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 = 20
|
||||||
for k, v := range m {
|
for k, v := range m {
|
||||||
remain := len(v) % split
|
remain := len(v) % split
|
||||||
for i := 0; i < len(v)/split; i++ {
|
for i := 0; i < len(v)/split; i++ {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user