(ctx context.Context)
| 221 | } |
| 222 | |
| 223 | func (f *Fs) listMultipartUploadsAll(ctx context.Context) (uploadsMap map[string][]*objectstorage.MultipartUpload, |
| 224 | err error) { |
| 225 | uploadsMap = make(map[string][]*objectstorage.MultipartUpload) |
| 226 | bucket, directory := f.split("") |
| 227 | if bucket != "" { |
| 228 | uploads, err := f.listMultipartUploads(ctx, bucket, directory) |
| 229 | if err != nil { |
| 230 | return uploadsMap, err |
| 231 | } |
| 232 | uploadsMap[bucket] = uploads |
| 233 | return uploadsMap, nil |
| 234 | } |
| 235 | entries, err := f.listBuckets(ctx) |
| 236 | if err != nil { |
| 237 | return uploadsMap, err |
| 238 | } |
| 239 | for _, entry := range entries { |
| 240 | bucket := entry.Remote() |
| 241 | uploads, listErr := f.listMultipartUploads(ctx, bucket, "") |
| 242 | if listErr != nil { |
| 243 | err = listErr |
| 244 | fs.Errorf(f, "%v", err) |
| 245 | } |
| 246 | uploadsMap[bucket] = uploads |
| 247 | } |
| 248 | return uploadsMap, err |
| 249 | } |
| 250 | |
| 251 | // listMultipartUploads lists all outstanding multipart uploads for (bucket, key) |
| 252 | // |
no test coverage detected