diff --git a/account/account_test.go b/account/account_test.go index 313f78f..e42dfd8 100644 --- a/account/account_test.go +++ b/account/account_test.go @@ -20,5 +20,5 @@ func TestAccount_Quota(t *testing.T) { if err != nil { t.Fail() } - t.Logf("TestAccount_UserInfo res: %+v", res) + t.Logf("TestAccount_Quota res: %+v", res) } diff --git a/file/upload.go b/file/upload.go index 81a35a2..ea338c0 100644 --- a/file/upload.go +++ b/file/upload.go @@ -116,9 +116,9 @@ func (u *Uploader) Upload() (UploadResponse, error) { return ret, err } defer file.Close() - buffer := make([]byte, sliceSize) uploadRespChan := make(chan SuperFile2UploadResponse) for i := 0; i < sliceNum; i++ { + buffer := make([]byte, sliceSize) n, err := file.Read(buffer[:]) if err != nil && err != io.EOF { log.Println("file.Read failed, err:", err) @@ -127,13 +127,13 @@ func (u *Uploader) Upload() (UploadResponse, error) { if n == 0 { break } - go func(partSeq int) { - uploadResp, err := u.SuperFile2Upload(uploadID, partSeq, buffer[0:n]) + go func(partSeq int, partByte []byte) { + uploadResp, err := u.SuperFile2Upload(uploadID, partSeq, partByte) uploadRespChan <- uploadResp if err != nil { - log.Printf("SuperFile2UploadFailed, partseq[%d] err[%+v]", partSeq, err) + log.Printf("SuperFile2UploadFailed, partseq[%d] err[%v]", partSeq, err) } - }(i) + }(i, buffer[0:n]) } blockList := make([]string, sliceNum) @@ -209,7 +209,6 @@ func (u *Uploader) PreCreate() (PreCreateResponse, error) { body := v.Encode() requestUrl := conf.OpenApiDomain + PreCreateUri + "&access_token=" + u.AccessToken - headers := make(map[string]string) resp, err := httpclient.Post(requestUrl, headers, body) if err != nil {