Fix listMultipart cannot get complete uploaded parts (#28)

* Fix listMultipart cannot get complete uploaded parts

* Set the capacity of slice

iterator.go

@@ -25,11 +25,11 @@ func (i *storagePageStatus) ContinuationToken() string {
 
 type partPageStatus struct {
 	key              string
-	maxParts         int64
-	partNumberMarker int64
+	maxParts         int
+	partNumberMarker int
 	uploadId         string
 }
 
 func (i *partPageStatus) ContinuationToken() string {
-	return strconv.FormatInt(i.partNumberMarker, 10)
+	return strconv.Itoa(i.partNumberMarker)
 }

storage.go

@@ -63,7 +63,7 @@ func (s *Storage) create(path string, opt pairStorageCreate) (o *Object) {
 func (s *Storage) createAppend(ctx context.Context, path string, opt pairStorageCreateAppend) (o *Object, err error) {
 	rp := s.getAbsPath(path)
 
-	options := make([]oss.Option, 0)
+	options := make([]oss.Option, 0, 3)
 	options = append(options, oss.ContentLength(0))
 	if opt.HasContentType {
 		options = append(options, oss.ContentType(opt.ContentType))
@@ -97,7 +97,7 @@ func (s *Storage) createAppend(ctx context.Context, path string, opt pairStorage
 func (s *Storage) createMultipart(ctx context.Context, path string, opt pairStorageCreateMultipart) (o *Object, err error) {
 	rp := s.getAbsPath(path)
 
-	options := make([]oss.Option, 0)
+	options := make([]oss.Option, 0, 3)
 	if opt.HasContentType {
 		options = append(options, oss.ContentType(opt.ContentType))
 	}
@@ -275,7 +275,7 @@ func (s *Storage) nextObjectPageByPrefix(ctx context.Context, page *ObjectPage)
 func (s *Storage) nextPartObjectPageByPrefix(ctx context.Context, page *ObjectPage) error {
 	input := page.Status.(*objectPageStatus)
 
-	options := make([]oss.Option, 0)
+	options := make([]oss.Option, 0, 5)
 	options = append(options, oss.Delimiter(input.delimiter))
 	options = append(options, oss.MaxKeys(input.maxKeys))
 	options = append(options, oss.Prefix(input.prefix))
@@ -312,11 +312,17 @@ func (s *Storage) nextPartObjectPageByPrefix(ctx context.Context, page *ObjectPa
 func (s *Storage) nextPartPage(ctx context.Context, page *PartPage) error {
 	input := page.Status.(*partPageStatus)
 
-	output, err := s.bucket.ListUploadedParts(oss.InitiateMultipartUploadResult{
+	imur := oss.InitiateMultipartUploadResult{
 		Bucket:   s.bucket.BucketName,
 		Key:      input.key,
 		UploadID: input.uploadId,
-	})
+	}
+
+	options := make([]oss.Option, 0, 2)
+	options = append(options, oss.MaxParts(input.maxParts))
+	options = append(options, oss.PartNumberMarker(input.partNumberMarker))
+
+	output, err := s.bucket.ListUploadedParts(imur, options...)
 	if err != nil {
 		return err
 	}
@@ -337,7 +343,7 @@ func (s *Storage) nextPartPage(ctx context.Context, page *PartPage) error {
 		return IterateDone
 	}
 
-	partNumberMarker, err := strconv.ParseInt(output.NextPartNumberMarker, 10, 64)
+	partNumberMarker, err := strconv.Atoi(output.NextPartNumberMarker)
 	if err != nil {
 		return err
 	}
@@ -443,7 +449,7 @@ func (s *Storage) write(ctx context.Context, path string, r io.Reader, size int6
 
 	rp := s.getAbsPath(path)
 
-	options := make([]oss.Option, 0)
+	options := make([]oss.Option, 0, 3)
 	options = append(options, oss.ContentLength(size))
 	if opt.HasContentMd5 {
 		options = append(options, oss.ContentMD5(opt.ContentMd5))
@@ -477,7 +483,7 @@ func (s *Storage) writeAppend(ctx context.Context, o *Object, r io.Reader, size
 
 	offset, _ := o.GetAppendOffset()
 
-	options := make([]oss.Option, 0)
+	options := make([]oss.Option, 0, 1)
 	options = append(options, oss.ContentLength(size))
 	if opt.HasContentMd5 {
 		options = append(options, oss.ContentMD5(opt.ContentMd5))
@@ -500,7 +506,7 @@ func (s *Storage) writeMultipart(ctx context.Context, o *Object, r io.Reader, si
 		UploadID: o.MustGetMultipartID(),
 	}
 
-	options := make([]oss.Option, 0)
+	options := make([]oss.Option, 0, 1)
 	options = append(options, oss.ContentLength(size))
 	if opt.HasContentMd5 {
 		options = append(options, oss.ContentMD5(opt.ContentMd5))