apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-28 10:52:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixup! Reformat source #2

Browse Source
This commit is contained in:
Xiaoge Su 2022-06-14 11:39:10 -07:00
parent c2676df2f8
commit 21ee76a44d
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
fdbclient/S3BlobStore.actor.cpp
View File

@ -484,9 +484,7 @@ ACTOR Future<Void> deleteRecursively_impl(Reference<S3BlobStoreEndpoint> b,
loop { loop {
choose { choose {
// Throw if done throws, otherwise don't stop until end_of_stream // Throw if done throws, otherwise don't stop until end_of_stream
when(wait(done)) { when(wait(done)) { done = Never(); }
done = Never();
}
when(S3BlobStoreEndpoint::ListResult list = waitNext(resultStream.getFuture())) { when(S3BlobStoreEndpoint::ListResult list = waitNext(resultStream.getFuture())) {
for (auto& object : list.objects) { for (auto& object : list.objects) {
@ -1197,9 +1195,7 @@ ACTOR Future<S3BlobStoreEndpoint::ListResult> listObjects_impl(Reference<S3BlobS
loop { loop {
choose { choose {
// Throw if done throws, otherwise don't stop until end_of_stream // Throw if done throws, otherwise don't stop until end_of_stream
when(wait(done)) { when(wait(done)) { done = Never(); }
done = Never();
}
when(S3BlobStoreEndpoint::ListResult info = waitNext(resultStream.getFuture())) { when(S3BlobStoreEndpoint::ListResult info = waitNext(resultStream.getFuture())) {
results.commonPrefixes.insert( results.commonPrefixes.insert(