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

s3-benchmark: make deleteAllObjects delete all objects. 

Signed-off-by: Mark Nelson <mnelson@redhat.com>
master
Mark Nelson 2019-08-12 10:07:17 -04:00
parent 7f3aa829d3
commit f2775ff94c
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") log.Fatal("can't list objects")
} }
n := len(out.Contents) n := len(out.Contents)
if n == 0 { for n > 0 {
return fmt.Printf("got existing %v objects, try to delete now...\n", n)
}
fmt.Printf("got existing %v objects, try to delete now...\n", n)
for _, v := range out.Contents { for _, v := range out.Contents {
svc.DeleteObject(&s3.DeleteObjectInput{ svc.DeleteObject(&s3.DeleteObjectInput{
Bucket: &buckets[bucket_num], Bucket: &buckets[bucket_num],
Key: v.Key, 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 // canonicalAmzHeaders -- return the x-amz headers canonicalized