vitalif
/
hsbench
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #5 from markhpc/wip-delete-all 

s3-benchmark: make deleteAllObjects delete all objects.
master
Mark Nelson 2019-08-12 09:08:42 -05:00 committed by GitHub
parent 7f3aa829d3 f2775ff94c
commit dfb66eded1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
s3-benchmark.go
View File

@ -118,22 +118,22 @@ func deleteAllObjects(bucket_num int) {
log.Fatal("can't list objects")
}
n := len(out.Contents)
if n == 0 {
return
}
fmt.Printf("got existing %v objects, try to delete now...\n", n)
for n > 0 {
fmt.Printf("got existing %v objects, try to delete now...\n", n)
for _, v := range out.Contents {
svc.DeleteObject(&s3.DeleteObjectInput{
Bucket: &buckets[bucket_num],
Key: v.Key,
})
for _, v := range out.Contents {
svc.DeleteObject(&s3.DeleteObjectInput{
Bucket: &buckets[bucket_num],
Key: v.Key,
})
}
out, err = svc.ListObjects(&s3.ListObjectsInput{Bucket: &buckets[bucket_num]})
if err != nil {
log.Fatal("can't list objects")
}
n = len(out.Contents)
fmt.Printf("after delete, got %v objects\n", n)
}
out, err = svc.ListObjects(&s3.ListObjectsInput{Bucket: &buckets[bucket_num]})
if err != nil {
log.Fatal("can't list objects")
}
fmt.Printf("after delete, got %v objects\n", len(out.Contents))
}
// canonicalAmzHeaders -- return the x-amz headers canonicalized