shkong/MiraiGo
1
0
Fork 0
mirror of https://github.com/Mrs4s/MiraiGo.git synced 2025-05-05 03:23:50 +08:00
Code Issues Projects Releases Wiki Activity

update.

Browse Source
This commit is contained in:
Mrs4s 2021-01-04 20:52:50 +08:00
parent a2025e22ac
commit 4588cec0df
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client/client.go
View File

@ -639,7 +639,7 @@ func (c *QQClient) UploadGroupImageByFile(groupCode int64, path string) (*messag
c.srvSsoAddrs = append(c.srvSsoAddrs, fmt.Sprintf("%v:%v", binary.UInt32ToIPV4Address(uint32(addr)), rsp.UploadPort[i])) c.srvSsoAddrs = append(c.srvSsoAddrs, fmt.Sprintf("%v:%v", binary.UInt32ToIPV4Address(uint32(addr)), rsp.UploadPort[i]))
} }
} }
if _, err = c.highwayUploadFileMultiThreadingByBDH(path, 2, 2, rsp.UploadKey, EmptyBytes); err == nil { if _, err = c.highwayUploadFileMultiThreadingByBDH(path, 2, 4, rsp.UploadKey, EmptyBytes); err == nil {
goto ok goto ok
} }
return nil, errors.New("upload failed") return nil, errors.New("upload failed")

4
client/highway.go
View File

@ -192,7 +192,7 @@ func (c *QQClient) highwayUploadFileMultiThreadingByBDH(path string, cmdId int32
if err != nil { if err != nil {
return nil, errors.Wrap(err, "open file error") return nil, errors.Wrap(err, "open file error")
} }
if stat.Size() < 1024*1024*5 { if stat.Size() < 1024*1024*3 {
return c.highwayUploadByBDH(file, cmdId, ticket, ext) return c.highwayUploadByBDH(file, cmdId, ticket, ext)
} }
type BlockMetaData struct { type BlockMetaData struct {
@ -205,7 +205,7 @@ func (c *QQClient) highwayUploadFileMultiThreadingByBDH(path string, cmdId int32
h := md5.New() h := md5.New()
_, _ = io.Copy(h, file) _, _ = io.Copy(h, file)
fh := h.Sum(nil) fh := h.Sum(nil)
var blockSize int64 = 1024 * 1024 var blockSize int64 = 8192 * 8
var blocks []*BlockMetaData var blocks []*BlockMetaData
var rspExt []byte var rspExt []byte
// Init Blocks // Init Blocks