blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-24 02:16:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'errcode' of github.com:OpenIMSDK/Open-IM-Server into errcode

Browse Source
This commit is contained in:
wangchuxiao 2023-05-16 17:28:26 +08:00
commit 5377f1501d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/msggateway/client.go
View File

@ -235,14 +235,14 @@ func (c *Client) writeBinaryMsg(resp Resp) error {
} }
encodedBuf := bufferPool.Get().([]byte) encodedBuf := bufferPool.Get().([]byte)
resultBuf := bufferPool.Get().([]byte) resultBuf := bufferPool.Get().([]byte)
encodeBuf, err := c.longConnServer.Encode(resp) encodedBuf, err := c.longConnServer.Encode(resp)
if err != nil { if err != nil {
return utils.Wrap(err, "") return utils.Wrap(err, "")
} }
_ = c.conn.SetWriteDeadline(writeWait) _ = c.conn.SetWriteDeadline(writeWait)
if c.isCompress { if c.isCompress {
var compressErr error var compressErr error
resultBuf, compressErr = c.longConnServer.Compress(encodeBuf) resultBuf, compressErr = c.longConnServer.Compress(encodedBuf)
if compressErr != nil { if compressErr != nil {
return utils.Wrap(compressErr, "") return utils.Wrap(compressErr, "")
} }