Apache/jclouds
1
0
Fork 0
mirror of https://github.com/apache/jclouds.git synced 2025-02-22 10:29:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

adjusted perftest code

Browse Source
This commit is contained in:
Adrian Cole 2010-08-01 07:56:57 -07:00
parent 6f180ddb4e
commit d79eb21e69
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
aws/perftest/src/test/java/org/jclouds/aws/s3/BasePerformanceLiveTest.java
View File

@ -18,7 +18,7 @@
*/
package org.jclouds.aws.s3;
import static org.jclouds.concurrent.ConcurrentUtils.awaitCompletion;
import static org.jclouds.concurrent.FutureIterables.awaitCompletion;
import java.io.ByteArrayInputStream;
import java.io.File;
@ -144,8 +144,12 @@ public abstract class BasePerformanceLiveTest extends BaseBlobStoreIntegrationTe
Map<Integer, ListenableFuture<?>> responses = Maps.newHashMap();
for (int i = 0; i < loopCount; i++)
responses.put(i, provider.get());
assert awaitCompletion(responses, exec, null, logger,
String.format("putting into containerName: %s", containerName)).size() == 0;
Map<Integer, Exception> exceptions = awaitCompletion(responses, exec, null, Logger.NULL, String.format(
"putting into containerName: %s", containerName));
assert exceptions.size() == 0 : exceptions;
}
class PutBytesFuture implements Provider<ListenableFuture<?>> {

1
core/src/main/java/org/jclouds/crypto/Pems.java
View File

@ -45,7 +45,6 @@ import org.jclouds.crypto.Pems.PemProcessor.ResultParser;
import com.google.common.annotations.Beta;
import com.google.common.collect.ImmutableMap;
import com.google.common.io.ByteProcessor;
import com.google.common.io.ByteStreams;
import com.google.common.io.InputSupplier;